Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -32,17 +32,22 @@
@RestController
@RequestMapping(value = "/api/v1/meta", produces = MediaType.APPLICATION_JSON_VALUE)
public class BatchJobController {
@Autowired
JobService jobService;

@Autowired
InfluxIOService influxIOService;
private JobService jobService;

private InfluxIOService influxIOService;

private static final String REGEX_PATTERN = "^(?=.{1,64}@)[A-Za-z0-9_-]+(\\.[A-Za-z0-9_-]+)*@"
+ "[^-][A-Za-z0-9-]+(\\.[A-Za-z0-9-]+)*(\\.[A-Za-z]{2,})$"; //this is used to validate that the userEmail is an email

private static final String REGEX = "\\d+";

@Autowired
public BatchJobController(JobService jobService, InfluxIOService influxIOService){
this.jobService = jobService;
this.influxIOService = influxIOService;
}

/**
* Returns all the jobs with the corresponding userEmail
* This call should be done if you only want the JobIds
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,18 +24,22 @@
@Service
public class JobService {

@Autowired
BatchJobRepository batchJobRepository;
private BatchJobRepository batchJobRepository;

@Autowired
BatchJobParamRepository batchJobParamRepository;
private BatchJobParamRepository batchJobParamRepository;

private BatchJobMapper mapper = Mappers.getMapper(BatchJobMapper.class);

private static final String STRING_VAL = "STRING";
private static final String LONG_VAL = "LONG";
private static final String DOUBLE_VAL = "DOUBLE";

@Autowired
public JobService(BatchJobParamRepository batchJobParamRepository, BatchJobRepository batchJobRepository) {
this.batchJobParamRepository = batchJobParamRepository;
this.batchJobRepository = batchJobRepository;
}

public BatchJobData getJobStat(Long jobId) {
log.info("JobId: {}", jobId);
BatchJobData batchJobData = new BatchJobData();
Expand Down