NoOpSourceOperationExecutor implements SourceOperationExecutor { public NoOpSourceOperationExecutor(SourceOperationRequest request) { this.request = request; } NoOpSourceOperationExecutor(SourceOperationRequest request); @Override CounterSet getOutputCounters(); @Override SourceOperationResponse getResponse(); @Override void execute(); @Override Iterable<CounterUpdate> extractMetricUpdates();  }
@Test public void testNoOpSourceOperationExecutor() throws Exception { executor.execute(); SourceOperationResponse response = executor.getResponse(); assertEquals("SOURCE_SPLIT_OUTCOME_USE_CURRENT", response.getSplit().getOutcome()); }