@Test public void testGetJobStatusesForFlowExecution() throws IOException { super.testGetJobStatusesForFlowExecution(); }
@Override public Iterator<JobStatus> getJobStatusesForFlowExecution(String flowName, String flowGroup, long flowExecutionId) { String storeName = KafkaJobStatusMonitor.jobStatusStoreName(flowGroup, flowName); try { List<State> jobStatusStates; try (Timer.Context context = this.metricContext.contextAwareTimer(GET_LATEST_FLOW_STATUS_METRIC).time()) { jobStatusStates = this.stateStore.getAll(storeName, flowExecutionId); } return getJobStatuses(jobStatusStates); } catch (IOException e) { throw new RuntimeException(e); } }
MysqlJobStatusRetriever extends JobStatusRetriever { @Override public Iterator<JobStatus> getJobStatusesForFlowExecution(String flowName, String flowGroup, long flowExecutionId) { String storeName = KafkaJobStatusMonitor.jobStatusStoreName(flowGroup, flowName); try { List<State> jobStatusStates; try (Timer.Context context = this.metricContext.contextAwareTimer(GET_LATEST_FLOW_STATUS_METRIC).time()) { jobStatusStates = this.stateStore.getAll(storeName, flowExecutionId); } return getJobStatuses(jobStatusStates); } catch (IOException e) { throw new RuntimeException(e); } } }
MysqlJobStatusRetriever extends JobStatusRetriever { @Override public Iterator<JobStatus> getJobStatusesForFlowExecution(String flowName, String flowGroup, long flowExecutionId) { String storeName = KafkaJobStatusMonitor.jobStatusStoreName(flowGroup, flowName); try { List<State> jobStatusStates; try (Timer.Context context = this.metricContext.contextAwareTimer(GET_LATEST_FLOW_STATUS_METRIC).time()) { jobStatusStates = this.stateStore.getAll(storeName, flowExecutionId); } return getJobStatuses(jobStatusStates); } catch (IOException e) { throw new RuntimeException(e); } } MysqlJobStatusRetriever(Config config); }
MysqlJobStatusRetriever extends JobStatusRetriever { @Override public Iterator<JobStatus> getJobStatusesForFlowExecution(String flowName, String flowGroup, long flowExecutionId) { String storeName = KafkaJobStatusMonitor.jobStatusStoreName(flowGroup, flowName); try { List<State> jobStatusStates; try (Timer.Context context = this.metricContext.contextAwareTimer(GET_LATEST_FLOW_STATUS_METRIC).time()) { jobStatusStates = this.stateStore.getAll(storeName, flowExecutionId); } return getJobStatuses(jobStatusStates); } catch (IOException e) { throw new RuntimeException(e); } } MysqlJobStatusRetriever(Config config); @Override Iterator<JobStatus> getJobStatusesForFlowExecution(String flowName, String flowGroup, long flowExecutionId); @Override Iterator<JobStatus> getJobStatusesForFlowExecution(String flowName, String flowGroup, long flowExecutionId,
      String jobName, String jobGroup); @Override List<Long> getLatestExecutionIdsForFlow(String flowName, String flowGroup, int count); }
MysqlJobStatusRetriever extends JobStatusRetriever { @Override public Iterator<JobStatus> getJobStatusesForFlowExecution(String flowName, String flowGroup, long flowExecutionId) { String storeName = KafkaJobStatusMonitor.jobStatusStoreName(flowGroup, flowName); try { List<State> jobStatusStates; try (Timer.Context context = this.metricContext.contextAwareTimer(GET_LATEST_FLOW_STATUS_METRIC).time()) { jobStatusStates = this.stateStore.getAll(storeName, flowExecutionId); } return getJobStatuses(jobStatusStates); } catch (IOException e) { throw new RuntimeException(e); } } MysqlJobStatusRetriever(Config config); @Override Iterator<JobStatus> getJobStatusesForFlowExecution(String flowName, String flowGroup, long flowExecutionId); @Override Iterator<JobStatus> getJobStatusesForFlowExecution(String flowName, String flowGroup, long flowExecutionId,
      String jobName, String jobGroup); @Override List<Long> getLatestExecutionIdsForFlow(String flowName, String flowGroup, int count); static final String MYSQL_JOB_STATUS_RETRIEVER_PREFIX; static final String GET_LATEST_JOB_STATUS_METRIC; static final String GET_LATEST_FLOW_STATUS_METRIC; static final String GET_ALL_FLOW_STATUSES_METRIC; }