You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2021/05/10 12:18:15 UTC
[incubator-streampipes-extensions] branch STREAMPIPES-319 updated
(8f013da -> 7dfb31e)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch STREAMPIPES-319
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git.
from 8f013da [STREAMPIPES-319] Migrate pipeline element descriptions to servicedefinition builder
add 71bacb9 Resolve dependency version issues
add f5b11b9 allow user to enter connection string with and without "opc.tcp://"
add 0aa317c Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into dev
add d91ed20 Fix error for connection via Host&Port
add 68f917e Merge remote-tracking branch 'origin/dev' into dev
add d243b9b [STREAMPIPES-301] change package structure
add 14aeb1a [STREAMPIPES-301] update docu
add ded0ae2 [STREAMPIPES-300] implement resolveOptions
add 359461f [STREAMPIPES-301] replace getConfiguration with OpcUa.from()
add 4c411f1 [STREAMPIPES-300] add label for available nodes
add 6632618 [STREAMPIPES-301] introduce helper class OpcUaConnect & refactoring
add fc2395c Merge remote-tracking branch 'origin/dev' into dev
add 5dc0f66 Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into dev
add 2e465a3 [STREAMPIPES-301] move code to OpcUaUtil
add 0a3278f [STREAMPIPES-301] extend functionality of OpcNode
add 61396e5 [STREAMPIPES-306] create OPC Pull Adapter
add d83517e [STREAMPIPES-306] adapt namespaces
add e75f7e4 [STREAMPIPES-306] small adaptions
add c39de86 [STREAMPIPES-306] add resources
add 50581a8 [STREAMPIPES-308] Add String mappings to BooleanToState Processor
add 9b98c7f [STREAMPIPES-289] Add type checking for incoming event and OPC UA node
add 921243b add String as potential data type
add e47b55d Merge pull request #36 from bossenti/STREAMPIPES-289
add 64a331b Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into dev
add 03a7bc8 Add mean to schema desctiption of statistics summary processor
add 589ec38 Throw SpRuntimeException if exception occurs in onDetatch() of websocket server
add 0bdbf9e [STREAMPIPES-301] adapt strings.en to OPC UA wording
add d42c96a [STREAMPIPES-301] add javadoc comments
add 77f338f [STREAMPIPES-306] integrate pull an subscription mode into one adapter
add 79bada9 Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into dev
add 834b324 [STREAMPIPES-306] improve implementation
add 319e3af Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into dev
add 56f4c14 [STREAMPIPES-315] fix issue
add c5511bb [STREAMPIPES-317] Support SSL connections for PostgreSql sink
add ae31c1c [STREAMPIPES-339] adaptions to changes in ObjectDetection
add e1af357 [STREAMPIPES-334] add UI option for label name
add 639f844 [STREAMPIPES-334] implement changes for Buffer Labeler as well
add 724beb7 STREAMPIPES-322:Create boolean logical operator processor
add 3e8fc4e STREAMPIPES-322:Addressed review comments
add 8d8ffb0 STREAMPIPES-322:Added strings.en and documentation.md files for boolean operator processor.
add 0b0c560 STREAMPIPES-322:Addressed review comments.
add e607f1f STREAMPIPES-322:Added Apache licence header to new files.
add 52b6939 STREAMPIPES-322:Addressed review comments.
add 0852256 STREAMPIPES-322:Added BooleanOperatorProcessor to AllPipelineElementsInit.
add 1dd869c Merge pull request #38 from sndp2693/STREAMPIPES-322
add 64902b7 Added Merge by Schema
add 9b4bac7 Implement Merge by Schema
add 1e6f809 Formatted the code
add f4495c8 Merge by schema processor
add a9eccfc [STREAMPIPES-323] Added strings.en and documentation.md in resource folder
add f4b6f00 Merge pull request #39 from Samarth08/STREAMPIPES-323
add 36ed531 [STREAMPIPES-339] adaptions to changes in ObjectDetection
add 89a80b9 [STREAMPIPES-334] add UI option for label name
add 12f6079 [STREAMPIPES-334] implement changes for Buffer Labeler as well
add 97abdff STREAMPIPES-322:Create boolean logical operator processor
add 8074b8b STREAMPIPES-322:Addressed review comments
add a43dd10 STREAMPIPES-322:Added strings.en and documentation.md files for boolean operator processor.
add e608690 STREAMPIPES-322:Addressed review comments.
add 716ad6a STREAMPIPES-322:Added Apache licence header to new files.
add 31626e4 STREAMPIPES-322:Addressed review comments.
add e3e02e2 STREAMPIPES-322:Added BooleanOperatorProcessor to AllPipelineElementsInit.
add c6339a9 Delted schema
add 0ba103a [STREAMPIPES-338] Added single field rename processor
add 885bc8e Review comments fixed
add 07275eb Merge remote-tracking branch 'upstream/dev' into dev
add 40ff097 Delted schema
add 09627ae [STREAMPIPES-338] Added single field rename processor
add 9af5250 review comment fixed
add 4071a7a review comments fixed
add 2cee3f3 [STREAMPIPES-338] Rename and removed Assets.icons
add fb5eb6c [STREAMPIPES-338] Addressed Review Comment.
add c6c60e5 Merge pull request #42 from Samarth08/STREAMPIPES-338_new
add 409fe7d [STREAMPIPES-339] fix data type of timestamp
add 302af04 [STREAMPIPES-344] change polling interval to milliseconds
add cdd0398 [STREAMPIPES-345] refactoring
add 76ba564 [STREAMPIPES-345] support for data type long
add 066ea04 [STREAMPIPES-345] implement method to retrieve data types from server
add a8e3ef0 Fix NameLabeler to work with double values
add 0dddf4e Merge pull request #46 from mohanvive/bug-fix
add 56aa199 Add extension to send events to NATS broker
add 82478c7 Merge pull request #44 from mohanvive/dev
new 7dfb31e Merge branch 'dev' into STREAMPIPES-319
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
pom.xml | 11 +
.../streampipes/connect/ConnectAdapterInit.java | 2 +-
.../connect/adapters/opcua/OpcNode.java | 50 +++
.../streampipes/connect/adapters/opcua/OpcUa.java | 236 +++++++++++---
.../connect/adapters/opcua/OpcUaAdapter.java | 354 ++++++++-------------
.../opcua/{ => utils}/OpcUaNodeVariants.java | 7 +-
.../adapters/opcua/{ => utils}/OpcUaTypes.java | 11 +-
.../connect/adapters/opcua/utils/OpcUaUtil.java | 181 +++++++++++
.../documentation.md | 41 ++-
.../strings.en | 29 +-
.../extensions/all/jvm/AllExtensionsInit.java | 2 +
.../pe/jvm/AllPipelineElementsInit.java | 10 +-
.../processors/filters/jvm/FiltersJvmInit.java | 16 +-
.../processor/schema/MergeBySchemaProcessor.java | 77 +++++
.../documentation.md | 19 +-
.../strings.en | 3 +
.../jvm/processor/imagecropper/ImageCropper.java | 3 +-
.../imagecropper/ImageCropperController.java | 2 +-
.../stat/summary/StatisticsSummaryController.java | 1 +
.../transformation/jvm/TransformationJvmInit.java | 6 +-
.../logical/BooleanOperationInputConfigs.java} | 37 +--
.../logical/BooleanOperatorProcessor.java | 129 ++++++++
.../logical/enums/BooleanOperatorType.java | 64 ++++
.../logical/operations/ANDBoolOperation.java | 9 +-
.../logical/operations/IBoolOperation.java} | 40 +--
.../logical/operations/NORBoolOperation.java | 9 +-
.../logical/operations/NOTBooleanOperation.java | 9 +-
.../logical/operations/ORBooleanOperation.java | 9 +-
.../logical/operations/XNORBoolOperation.java | 9 +-
.../logical/operations/XORBooleanOperation.java | 9 +-
.../operations/factory/BoolOperationFactory.java | 56 ++++
.../booloperator/state/BooleanToState.java | 16 +-
.../state/BooleanToStateController.java | 31 +-
.../state/BooleanToStateParameters.java | 13 +-
.../fieldrename/FiledRenameProcessor.java | 77 +++++
.../jvm/processor/state/labeler/LabelerUtils.java | 33 ++
.../state/labeler/buffer/StateBufferLabeler.java | 4 +-
.../buffer/StateBufferLabelerController.java | 23 +-
.../buffer/StateBufferLabelerParameters.java | 15 +-
.../state/labeler/model/StatementUtils.java | 19 +-
.../state/labeler/number/NumberLabeler.java | 5 +-
.../labeler/number/NumberLabelerController.java | 34 +-
.../labeler/number/NumberLabelerParameters.java | 15 +-
.../documentation.md | 32 +-
.../strings.en | 9 +
.../documentation.md | 12 +-
.../strings.en | 10 +
.../documentation.md | 9 +-
.../strings.en | 5 +-
.../strings.en | 4 +
.../strings.en | 3 +
streampipes-sinks-brokers-jvm/pom.xml | 4 +
.../sinks/brokers/jvm/BrokersJvmInit.java | 4 +-
.../sinks/brokers/jvm/nats/NatsController.java | 122 +++++++
.../sinks/brokers/jvm/nats/NatsParameters.java | 49 ++-
.../sinks/brokers/jvm/nats/NatsPublisher.java | 119 +++++++
.../brokers/jvm/websocket/WebsocketServerSink.java | 4 +-
.../documentation.md | 37 ++-
.../icon.png | Bin 0 -> 6986 bytes
.../strings.en | 39 +++
streampipes-sinks-databases-jvm/pom.xml | 8 +
.../sinks/databases/jvm/iotdb/IotDb.java | 1 +
.../sinks/databases/jvm/jdbcclient/JdbcClient.java | 29 +-
.../sinks/databases/jvm/mysql/Mysql.java | 1 +
.../sinks/databases/jvm/opcua/OpcUa.java | 61 +++-
.../sinks/databases/jvm/postgresql/PostgreSql.java | 1 +
.../jvm/postgresql/PostgreSqlController.java | 15 +-
.../jvm/postgresql/PostgreSqlParameters.java | 8 +-
.../strings.en | 4 +-
.../strings.en | 2 +
70 files changed, 1804 insertions(+), 514 deletions(-)
rename streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/opcua/{ => utils}/OpcUaNodeVariants.java (89%)
rename streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/opcua/{ => utils}/OpcUaTypes.java (81%)
create mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/opcua/utils/OpcUaUtil.java
create mode 100644 streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/schema/MergeBySchemaProcessor.java
copy {streampipes-sinks-databases-jvm/src/main/resources/org.apache.streampipes.sinks.databases.ditto => streampipes-processors-filters-jvm/src/main/resources/org.apache.streampipes.processors.filters.jvm.schema}/documentation.md (74%)
create mode 100644 streampipes-processors-filters-jvm/src/main/resources/org.apache.streampipes.processors.filters.jvm.schema/strings.en
copy streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/{state/labeler/model/Statement.java => booloperator/logical/BooleanOperationInputConfigs.java} (61%)
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/logical/BooleanOperatorProcessor.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/logical/enums/BooleanOperatorType.java
copy streampipes-processors-enricher-flink/src/main/java/org/apache/streampipes/processors/enricher/flink/processor/math/operation/OperationAddition.java => streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/logical/operations/ANDBoolOperation.java (74%)
copy streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/{timestampextractor/OutputFields.java => booloperator/logical/operations/IBoolOperation.java} (65%)
copy streampipes-processors-enricher-flink/src/main/java/org/apache/streampipes/processors/enricher/flink/processor/math/operation/OperationAddition.java => streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/logical/operations/NORBoolOperation.java (74%)
copy streampipes-processors-enricher-flink/src/main/java/org/apache/streampipes/processors/enricher/flink/processor/math/operation/OperationAddition.java => streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/logical/operations/NOTBooleanOperation.java (75%)
copy streampipes-processors-enricher-flink/src/main/java/org/apache/streampipes/processors/enricher/flink/processor/math/operation/OperationAddition.java => streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/logical/operations/ORBooleanOperation.java (74%)
copy streampipes-processors-enricher-flink/src/main/java/org/apache/streampipes/processors/enricher/flink/processor/math/operation/OperationAddition.java => streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/logical/operations/XNORBoolOperation.java (74%)
copy streampipes-processors-enricher-flink/src/main/java/org/apache/streampipes/processors/enricher/flink/processor/math/operation/OperationAddition.java => streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/logical/operations/XORBooleanOperation.java (74%)
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/logical/operations/factory/BoolOperationFactory.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/fieldrename/FiledRenameProcessor.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/LabelerUtils.java
copy {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.ros => streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.booloperator.logical}/documentation.md (70%)
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.booloperator.logical/strings.en
copy {streampipes-processors-transformation-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.field-renamer => streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.fieldrename}/documentation.md (86%)
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.fieldrename/strings.en
create mode 100644 streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/nats/NatsController.java
copy streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/mysql/MysqlParameters.java => streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/nats/NatsParameters.java (59%)
create mode 100644 streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/nats/NatsPublisher.java
copy {streampipes-sinks-databases-jvm/src/main/resources/org.apache.streampipes.sinks.databases.jvm.mysql => streampipes-sinks-brokers-jvm/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.nats}/documentation.md (57%)
create mode 100644 streampipes-sinks-brokers-jvm/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.nats/icon.png
create mode 100644 streampipes-sinks-brokers-jvm/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.nats/strings.en
[incubator-streampipes-extensions] 01/01: Merge branch 'dev' into
STREAMPIPES-319
Posted by ri...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch STREAMPIPES-319
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
commit 7dfb31e67ff1386f7e82683aa09e889a91eaffe1
Merge: 8f013da 82478c7
Author: Dominik Riemer <ri...@fzi.de>
AuthorDate: Mon May 10 14:17:53 2021 +0200
Merge branch 'dev' into STREAMPIPES-319
pom.xml | 11 +
.../streampipes/connect/ConnectAdapterInit.java | 2 +-
.../connect/adapters/opcua/OpcNode.java | 50 +++
.../streampipes/connect/adapters/opcua/OpcUa.java | 236 +++++++++++---
.../connect/adapters/opcua/OpcUaAdapter.java | 354 ++++++++-------------
.../opcua/{ => utils}/OpcUaNodeVariants.java | 7 +-
.../adapters/opcua/{ => utils}/OpcUaTypes.java | 11 +-
.../connect/adapters/opcua/utils/OpcUaUtil.java | 181 +++++++++++
.../documentation.md | 41 ++-
.../strings.en | 29 +-
.../extensions/all/jvm/AllExtensionsInit.java | 2 +
.../pe/jvm/AllPipelineElementsInit.java | 10 +-
.../processors/filters/jvm/FiltersJvmInit.java | 16 +-
.../processor/schema/MergeBySchemaProcessor.java | 77 +++++
.../documentation.md | 19 +-
.../strings.en | 3 +
.../jvm/processor/imagecropper/ImageCropper.java | 3 +-
.../imagecropper/ImageCropperController.java | 2 +-
.../stat/summary/StatisticsSummaryController.java | 1 +
.../transformation/jvm/TransformationJvmInit.java | 6 +-
.../logical/BooleanOperationInputConfigs.java | 34 +-
.../logical/BooleanOperatorProcessor.java | 129 ++++++++
.../logical/enums/BooleanOperatorType.java | 64 ++++
.../logical/operations/ANDBoolOperation.java | 31 +-
.../logical/operations/IBoolOperation.java | 41 +--
.../logical/operations/NORBoolOperation.java | 31 +-
.../logical/operations/NOTBooleanOperation.java | 31 +-
.../logical/operations/ORBooleanOperation.java | 31 +-
.../logical/operations/XNORBoolOperation.java | 31 +-
.../logical/operations/XORBooleanOperation.java | 31 +-
.../operations/factory/BoolOperationFactory.java | 56 ++++
.../booloperator/state/BooleanToState.java | 16 +-
.../state/BooleanToStateController.java | 31 +-
.../state/BooleanToStateParameters.java | 13 +-
.../fieldrename/FiledRenameProcessor.java | 77 +++++
.../jvm/processor/state/labeler/LabelerUtils.java | 33 ++
.../state/labeler/buffer/StateBufferLabeler.java | 4 +-
.../buffer/StateBufferLabelerController.java | 23 +-
.../buffer/StateBufferLabelerParameters.java | 15 +-
.../state/labeler/model/StatementUtils.java | 19 +-
.../state/labeler/number/NumberLabeler.java | 5 +-
.../labeler/number/NumberLabelerController.java | 34 +-
.../labeler/number/NumberLabelerParameters.java | 15 +-
.../documentation.md | 17 +-
.../strings.en | 9 +
.../documentation.md | 29 +-
.../strings.en | 10 +
.../documentation.md | 9 +-
.../strings.en | 5 +-
.../strings.en | 4 +
.../strings.en | 3 +
streampipes-sinks-brokers-jvm/pom.xml | 4 +
.../sinks/brokers/jvm/BrokersJvmInit.java | 4 +-
.../sinks/brokers/jvm/nats/NatsController.java | 122 +++++++
.../sinks/brokers/jvm/nats/NatsParameters.java | 61 ++++
.../sinks/brokers/jvm/nats/NatsPublisher.java | 119 +++++++
.../brokers/jvm/websocket/WebsocketServerSink.java | 4 +-
.../documentation.md | 45 ++-
.../icon.png | Bin 0 -> 6986 bytes
.../strings.en | 39 +++
streampipes-sinks-databases-jvm/pom.xml | 8 +
.../sinks/databases/jvm/iotdb/IotDb.java | 1 +
.../sinks/databases/jvm/jdbcclient/JdbcClient.java | 29 +-
.../sinks/databases/jvm/mysql/Mysql.java | 1 +
.../sinks/databases/jvm/opcua/OpcUa.java | 61 +++-
.../sinks/databases/jvm/postgresql/PostgreSql.java | 1 +
.../jvm/postgresql/PostgreSqlController.java | 15 +-
.../jvm/postgresql/PostgreSqlParameters.java | 8 +-
.../strings.en | 4 +-
.../strings.en | 2 +
70 files changed, 1899 insertions(+), 571 deletions(-)
diff --cc streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/FiltersJvmInit.java
index 41929fb,abe18c8..e3cb629
--- a/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/FiltersJvmInit.java
+++ b/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/FiltersJvmInit.java
@@@ -18,56 -18,53 +18,70 @@@
package org.apache.streampipes.processors.filters.jvm;
-import org.apache.streampipes.container.init.DeclarersSingleton;
+import org.apache.streampipes.container.model.SpServiceDefinition;
+import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
-import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
-import org.apache.streampipes.dataformat.smile.SmileDataFormatFactory;
import org.apache.streampipes.messaging.jms.SpJmsProtocolFactory;
import org.apache.streampipes.messaging.kafka.SpKafkaProtocolFactory;
-import org.apache.streampipes.messaging.mqtt.SpMqttProtocolFactory;
-import org.apache.streampipes.processors.filters.jvm.config.FiltersJvmConfig;
+ import org.apache.streampipes.processors.filters.jvm.processor.compose.ComposeController;
+ import org.apache.streampipes.processors.filters.jvm.processor.enrich.MergeByEnrichController;
+ import org.apache.streampipes.processors.filters.jvm.processor.limit.RateLimitController;
+ import org.apache.streampipes.processors.filters.jvm.processor.merge.MergeByTimeController;
import org.apache.streampipes.processors.filters.jvm.processor.numericalfilter.NumericalFilterController;
+ import org.apache.streampipes.processors.filters.jvm.processor.numericaltextfilter.NumericalTextFilterController;
+ import org.apache.streampipes.processors.filters.jvm.processor.projection.ProjectionController;
+ import org.apache.streampipes.processors.filters.jvm.processor.schema.MergeBySchemaProcessor;
import org.apache.streampipes.processors.filters.jvm.processor.textfilter.TextFilterController;
import org.apache.streampipes.processors.filters.jvm.processor.threshold.ThresholdDetectionController;
public class FiltersJvmInit extends StandaloneModelSubmitter {
public static void main(String[] args) {
- DeclarersSingleton.getInstance()
- .add(new NumericalFilterController())
- .add(new ThresholdDetectionController())
- .add(new TextFilterController())
- .add(new ProjectionController())
- .add(new MergeByEnrichController())
- .add(new MergeByTimeController())
- .add(new MergeBySchemaProcessor())
- .add(new ComposeController())
- .add(new NumericalTextFilterController())
- .add(new RateLimitController());
- DeclarersSingleton.getInstance().registerDataFormats(
- new JsonDataFormatFactory(),
- new CborDataFormatFactory(),
- new SmileDataFormatFactory(),
- new FstDataFormatFactory());
+ SpServiceDefinition serviceDef = SpServiceDefinitionBuilder.create("org.apache.streampipes.processors.filters.jvm",
+ "StreamPipes Processors Filters (JVM)",
+ "",
+ 8090)
+// .registerAdapters(new MqttProtocol(),
+// new IssAdapter())
+ .registerPipelineElements(new TextFilterController(),
+ new NumericalFilterController(),
- new ThresholdDetectionController())
++ new ThresholdDetectionController(),
++ new ProjectionController(),
++ new MergeByEnrichController(),
++ new MergeByTimeController(),
++ new MergeBySchemaProcessor(),
++ new ComposeController(),
++ new NumericalTextFilterController(),
++ new RateLimitController())
+ .registerMessagingFormats(new JsonDataFormatFactory(), new CborDataFormatFactory())
+ .registerMessagingProtocols(new SpKafkaProtocolFactory(), new SpJmsProtocolFactory())
+ .build();
- DeclarersSingleton.getInstance().registerProtocols(
- new SpKafkaProtocolFactory(),
- new SpMqttProtocolFactory(),
- new SpJmsProtocolFactory());
+// DeclarersSingleton.getInstance()
+// .add(new NumericalFilterController())
+// .add(new ThresholdDetectionController())
+// .add(new TextFilterController())
+// .add(new ProjectionController())
+// .add(new MergeByEnrichController())
+// .add(new MergeByTimeController())
+// .add(new ComposeController())
+// .add(new NumericalTextFilterController())
+// .add(new RateLimitController());
+//
+// DeclarersSingleton.getInstance().registerDataFormats(
+// new JsonDataFormatFactory(),
+// new CborDataFormatFactory(),
+// new SmileDataFormatFactory(),
+// new FstDataFormatFactory());
+//
+// DeclarersSingleton.getInstance().registerProtocols(
+// new SpKafkaProtocolFactory(),
+// new SpMqttProtocolFactory(),
+// new SpJmsProtocolFactory());
- new FiltersJvmInit().init(FiltersJvmConfig.INSTANCE);
+ new FiltersJvmInit().init(serviceDef);
}
}