@Test public void tupleArgsTestNoParent() throws Exception { StreamlineEvent injectedEvent = sut.injectCorrelationInformation( new Values(INPUT_STREAMLINE_EVENT), Collections.emptyList(), TEST_COMPONENT_NAME); StreamlineEventTestUtil.assertEventIsProperlyCopied(injectedEvent, INPUT_STREAMLINE_EVENT); assertEquals(Collections.emptySet(), EventCorrelationInjector.getRootIds(injectedEvent)); assertEquals(Collections.emptySet(), EventCorrelationInjector.getParentIds(injectedEvent)); assertEquals(StormTopologyUtil.extractStreamlineComponentName(TEST_COMPONENT_NAME), EventCorrelationInjector.getSourceComponentName(injectedEvent)); }
public StreamlineEvent injectCorrelationInformation(List<Object> tuple, List<Tuple> parentTuples, String componentName) { EventCorrelationInjector eventCorrelationInjector = new EventCorrelationInjector(); return eventCorrelationInjector.injectCorrelationInformation( getStreamlineEventFromValues(tuple), parentTuples.stream().map(this::getStreamlineEventFromTuple).collect(Collectors.toList()), StormTopologyUtil.extractStreamlineComponentName(componentName)); }
StormEventCorrelationInjector { public StreamlineEvent injectCorrelationInformation(List<Object> tuple, List<Tuple> parentTuples, String componentName) { EventCorrelationInjector eventCorrelationInjector = new EventCorrelationInjector(); return eventCorrelationInjector.injectCorrelationInformation( getStreamlineEventFromValues(tuple), parentTuples.stream().map(this::getStreamlineEventFromTuple).collect(Collectors.toList()), StormTopologyUtil.extractStreamlineComponentName(componentName)); } }
StormEventCorrelationInjector { public StreamlineEvent injectCorrelationInformation(List<Object> tuple, List<Tuple> parentTuples, String componentName) { EventCorrelationInjector eventCorrelationInjector = new EventCorrelationInjector(); return eventCorrelationInjector.injectCorrelationInformation( getStreamlineEventFromValues(tuple), parentTuples.stream().map(this::getStreamlineEventFromTuple).collect(Collectors.toList()), StormTopologyUtil.extractStreamlineComponentName(componentName)); }  }
StormEventCorrelationInjector { public StreamlineEvent injectCorrelationInformation(List<Object> tuple, List<Tuple> parentTuples, String componentName) { EventCorrelationInjector eventCorrelationInjector = new EventCorrelationInjector(); return eventCorrelationInjector.injectCorrelationInformation( getStreamlineEventFromValues(tuple), parentTuples.stream().map(this::getStreamlineEventFromTuple).collect(Collectors.toList()), StormTopologyUtil.extractStreamlineComponentName(componentName)); }  StreamlineEvent injectCorrelationInformation(List<Object> tuple, List<Tuple> parentTuples, String componentName); }
StormEventCorrelationInjector { public StreamlineEvent injectCorrelationInformation(List<Object> tuple, List<Tuple> parentTuples, String componentName) { EventCorrelationInjector eventCorrelationInjector = new EventCorrelationInjector(); return eventCorrelationInjector.injectCorrelationInformation( getStreamlineEventFromValues(tuple), parentTuples.stream().map(this::getStreamlineEventFromTuple).collect(Collectors.toList()), StormTopologyUtil.extractStreamlineComponentName(componentName)); }  StreamlineEvent injectCorrelationInformation(List<Object> tuple, List<Tuple> parentTuples, String componentName);  }