Added changed value processor to init
@@ -25,6 +25,7 @@ import org.streampipes.messaging.kafka.SpKafkaProtocolFactory;
import org.streampipes.processors.transformation.jvm.config.TransformationJvmConfig;
import org.streampipes.processors.transformation.jvm.processor.array.count.CountArrayController;
import org.streampipes.processors.transformation.jvm.processor.array.split.SplitArrayController;
+import org.streampipes.processors.transformation.jvm.processor.value.change.ChangedValueController;
public class TransformationJvmInit extends StandaloneModelSubmitter {
@@ -32,7 +33,8 @@ public class TransformationJvmInit extends StandaloneModelSubmitter {
DeclarersSingleton
.getInstance()
.add(new CountArrayController())
- .add(new SplitArrayController());
+ .add(new SplitArrayController())
+ .add(new ChangedValueController());
DeclarersSingleton.getInstance().registerDataFormat(new JsonDataFormatFactory());
DeclarersSingleton.getInstance().registerProtocol(new SpKafkaProtocolFactory());
