Formatted the code
@@ -14,7 +14,6 @@ import org.apache.streampipes.sdk.helpers.OutputStrategies;
import org.apache.streampipes.sdk.utils.Assets;
import org.apache.streampipes.wrapper.context.EventProcessorRuntimeContext;
import org.apache.streampipes.wrapper.routing.SpOutputCollector;
-import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor;
import org.apache.streampipes.wrapper.standalone.ProcessorParams;
import org.apache.streampipes.wrapper.standalone.StreamPipesDataProcessor;
@@ -30,7 +29,6 @@ public class MergeBySchemaProcessor extends StreamPipesDataProcessor {
private String selectedStream;
-
@Override
public DataProcessorDescription declareModel() {
return ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.schema")
@@ -79,6 +77,7 @@ public class MergeBySchemaProcessor extends StreamPipesDataProcessor {
}
}
}
+
private Event mergeEvents(Event e1, Event e2) {
return EventFactory.fromEvents(e1, e2, outputSchema).getSubset(outputKeySelectors);
}
