@Test public void runWithTwoSubstreams() { UntypedValues values = UntypedValues.builder() .source("test") .prefix("") .timestamp(123L) .values(Collections.singletonMap("test", "test")) .build(); MRecordSource source = MRecordSources.of(VALUES_FACTORY.apply(123L), VALUES_FACTORY.apply(124L), VALUES_FACTORY.apply(125L)); EvaluationPipeline pipeline = createPipelineWithTwoSubstreams(); EventSink sink = Mockito.mock(EventSink.class); CrunchExecutor crunchExecutor = new CrunchExecutor(source, pipeline, sink); crunchExecutor.run(); Mockito.verify(sink, times(4)).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);  }