@Test public void run() { Function<Long, UntypedValues> values = VALUES_FACTORY; MRecordSource source = MRecordSources.of(values.apply(123L), values.apply(124L)); EvaluationPipeline pipeline = createPipeline(); EventSink sink = Mockito.mock(EventSink.class); CrunchExecutor crunchExecutor = new CrunchExecutor(source, pipeline, sink); crunchExecutor.run(); Mockito.verify(sink, times(1)).handle(any()); }
public void run() { runWithSink(this.sink); }
CrunchExecutor { public void run() { runWithSink(this.sink); } }
CrunchExecutor { public void run() { runWithSink(this.sink); } CrunchExecutor(MRecordSource source, EvaluationPipeline evaluationPipeline, EventSink sink);  CrunchExecutor(MRecordSource source, EvaluationPipeline evaluationPipeline); }
CrunchExecutor { public void run() { runWithSink(this.sink); } CrunchExecutor(MRecordSource source, EvaluationPipeline evaluationPipeline, EventSink sink);  CrunchExecutor(MRecordSource source, EvaluationPipeline evaluationPipeline); void run(); void run(EventSink sink); }
CrunchExecutor { public void run() { runWithSink(this.sink); } CrunchExecutor(MRecordSource source, EvaluationPipeline evaluationPipeline, EventSink sink);  CrunchExecutor(MRecordSource source, EvaluationPipeline evaluationPipeline); void run(); void run(EventSink sink);  }