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/08/17 21:46:21 UTC
[incubator-streampipes-extensions] branch dev updated (5d1cb73 ->
af47b03)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git.
from 5d1cb73 Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into dev
add 8f013da [STREAMPIPES-319] Migrate pipeline element descriptions to servicedefinition builder
add 7dfb31e Merge branch 'dev' into STREAMPIPES-319
add 1bd9622 [STREAMPIPES-319] Refactor service definition
add a8a76ab Merge branch 'dev' into STREAMPIPES-319
add 12fa3fc [STREAMPIPES-319] Refactor JVM-based pipeline elements to use new ServiceDefinitionBuilder
add 8677093 [STREAMPIPES-319] Refactor adapters and pipeline elements to support service builder
add 1b6daa0 Merge branch 'dev' into STREAMPIPES-319
add e3cf1be [STREAMPIPES-319] Refactor config management
add bb7a300 [STREAMPIPES-319] Refactor config of watertank simulator service
add 3559fb4 [STREAMPIPES-319] Refactor config of vehicle simulator service
add 2647b97 [STREAMPIPES-319] Remove config provider of notifications service
add 528b2f7 [STREAMPIPES-319] Remove obsolete config
add 5c945a8 Merge branch 'dev' into STREAMPIPES-319
add 2569742 Merge branch 'STREAMPIPES-319' of github.com:apache/incubator-streampipes-extensions into STREAMPIPES-319
add e9977e4 [hotfix] Upate maven plugin versions
add 89d4a07 [STREAMPIPES-319] Refactor Flink API to support config extractor and StreamPipes client
add d4aa0d5 [hotfix] Set update policy for snapshots
add 0c469cf [hotfix] Modify repository settings
add f4f27c3 [STREAMPIPES-319] Refactor flink config
add aaa011c [STREAMPIPES-319] Refactor text mining config
add af47b03 [STREAMPIPES-319] Modify Flink config
No new revisions were added by this update.
Summary of changes:
pom.xml | 37 +--
.../streampipes/connect/ConnectAdapterInit.java | 113 +++++----
.../streampipes/connect/adapters/PullAdapter.java | 2 +-
.../connect/adapters/PullRestAdapter.java | 2 +-
.../adapters/coindesk/CoindeskBitcoinAdapter.java | 4 +-
.../connect/adapters/flic/FlicMQTTAdapter.java | 2 +-
.../connect/adapters/gdelt/GdeltAdapter.java | 2 +-
.../connect/adapters/iex/IexCloudNewsAdapter.java | 4 +-
.../connect/adapters/iex/IexCloudStockAdapter.java | 4 +-
.../connect/adapters/image/ImageZipAdapter.java | 2 +-
.../adapters/image/set/ImageSetAdapter.java | 4 +-
.../adapters/image/stream/ImageStreamAdapter.java | 4 +-
.../connect/adapters/influxdb/InfluxDbClient.java | 2 +-
.../adapters/influxdb/InfluxDbSetAdapter.java | 4 +-
.../adapters/influxdb/InfluxDbStreamAdapter.java | 4 +-
.../connect/adapters/iss/IssAdapter.java | 4 +-
.../connect/adapters/mysql/MySqlAdapter.java | 6 +-
.../connect/adapters/mysql/MySqlClient.java | 4 +-
.../connect/adapters/mysql/MySqlSetAdapter.java | 4 +-
.../connect/adapters/mysql/MySqlStreamAdapter.java | 4 +-
.../connect/adapters/netio/NetioMQTTAdapter.java | 2 +-
.../connect/adapters/netio/NetioRestAdapter.java | 2 +-
.../streampipes/connect/adapters/opcua/OpcUa.java | 2 +-
.../connect/adapters/opcua/OpcUaAdapter.java | 4 +-
.../connect/adapters/opcua/utils/OpcUaUtil.java | 4 +-
.../adapters/plc4x/modbus/Plc4xModbusAdapter.java | 4 +-
.../plc4x/passive/Plc4xPassiveAdapter.java | 4 +-
.../connect/adapters/plc4x/s7/Plc4xS7Adapter.java | 2 +-
.../connect/adapters/ros/RosBridgeAdapter.java | 7 +-
.../adapters/sensemap/OpenSenseMapAdapter.java | 2 +-
.../simulator/machine/MachineDataSimulator.java | 2 +-
.../machine/MachineDataSimulatorUtils.java | 2 +-
.../machine/MachineDataStreamAdapter.java | 4 +-
.../simulator/random/RandomDataSetAdapter.java | 4 +-
.../simulator/random/RandomDataStreamAdapter.java | 4 +-
.../connect/adapters/slack/SlackAdapter.java | 4 +-
.../connect/adapters/ti/TISensorTag.java | 4 +-
.../adapters/wikipedia/WikipediaAdapter.java | 4 +-
.../connect/config/ConnectWorkerConfig.java | 5 +-
.../connect/protocol/set/FileProtocol.java | 23 +-
.../connect/protocol/set/HttpProtocol.java | 22 +-
.../connect/protocol/stream/BrokerProtocol.java | 8 +-
.../protocol/stream/FileStreamProtocol.java | 20 +-
.../connect/protocol/stream/HDFSProtocol.java | 20 +-
.../protocol/stream/HttpServerProtocol.java | 14 +-
.../protocol/stream/HttpStreamProtocol.java | 9 +-
.../connect/protocol/stream/KafkaProtocol.java | 14 +-
.../connect/protocol/stream/MqttProtocol.java | 16 +-
.../connect/protocol/stream/PullProtocol.java | 19 +-
.../connect/protocol/stream/WebsocketProtocol.java | 10 +-
.../protocol/stream/pulsar/PulsarProtocol.java | 22 +-
.../extensions/all/jvm/AllExtensionsInit.java | 267 +++------------------
.../all/jvm/config/AllExtensionsConfig.java | 78 ------
.../extensions/all/jvm/config/ConfigKeys.java | 30 ---
.../apache/streampipes/pe/flink/config/Config.java | 5 +-
.../development/env | 4 +-
.../pe/jvm/AllPipelineElementsInit.java | 238 ++++--------------
.../pe/jvm/config/AllPipelineElementsConfig.java | 5 +-
.../flink/config/AggregationFlinkConfig.java | 5 +-
.../aggregation/AggregationController.java | 6 +-
.../flink/processor/count/CountController.java | 6 +-
.../processor/eventcount/EventCountController.java | 7 +-
.../flink/processor/rate/EventRateController.java | 8 +-
.../pom.xml | 6 +-
.../jvm/ChangeDetectionJvmInit.java | 36 +--
.../jvm/config/ChangeDetectionJvmConfig.java | 5 +-
.../enricher/flink/config/EnricherFlinkConfig.java | 6 +-
.../processor/math/mathop/MathOpController.java | 7 +-
.../math/staticmathop/StaticMathOpController.java | 7 +-
.../processor/timestamp/TimestampController.java | 9 +-
.../trigonometry/TrigonometryController.java | 7 +-
.../UrlDereferencingController.java | 7 +-
.../processors/enricher/jvm/EnricherJvmInit.java | 39 +--
.../enricher/jvm/config/EnricherJvmConfig.java | 5 +-
streampipes-processors-filters-jvm/development/env | 2 +-
.../processors/filters/jvm/FiltersJvmInit.java | 56 +++--
.../filters/jvm/config/FiltersJvmConfig.java | 5 +-
.../jvm/processor/compose/ComposeController.java | 5 +-
.../processors/siddhi/FiltersSiddhiInit.java | 54 +++--
.../siddhi/config/FilterSiddhiConfig.java | 5 +-
.../processor/geo/flink/config/GeoFlinkConfig.java | 5 +-
.../SpatialGridEnrichmentController.java | 7 +-
.../streampipes/processors/geo/jvm/GeoJvmInit.java | 54 +++--
.../processors/geo/jvm/config/GeoJvmConfig.java | 5 +-
.../jvm/ImageProcessingJvmInit.java | 44 ++--
.../jvm/config/ImageProcessingJvmConfig.java | 9 +-
.../flink/config/PatternDetectionFlinkConfig.java | 5 +-
.../flink/processor/absence/AbsenceController.java | 7 +-
.../flink/processor/and/AndController.java | 7 +-
.../processor/peak/PeakDetectionController.java | 6 +-
.../processor/sequence/SequenceController.java | 6 +-
.../flink/config/StatisticsFlinkConfig.java | 5 +-
.../stat/summary/StatisticsSummaryController.java | 7 +-
.../window/StatisticsSummaryControllerWindow.java | 7 +-
.../flink/config/TextMiningFlinkConfig.java | 5 +-
.../language/LanguageDetectionController.java | 7 +-
.../processor/wordcount/WordCountController.java | 7 +-
.../textmining/jvm/TextMiningJvmInit.java | 48 ++--
.../textmining/jvm/config/TextMiningJvmConfig.java | 5 +-
.../flink/config/TransformationFlinkConfig.java | 5 +-
.../boilerplate/BoilerplateController.java | 7 +-
.../converter/FieldConverterController.java | 7 +-
.../processor/hasher/FieldHasherController.java | 8 +-
.../processor/mapper/FieldMapperController.java | 7 +-
.../MeasurementUnitConverterController.java | 7 +-
.../processor/rename/FieldRenamerController.java | 8 +-
.../transformation/jvm/TransformationJvmInit.java | 81 ++++---
.../jvm/config/TransformationJvmConfig.java | 5 +-
.../sinks/brokers/jvm/BrokersJvmInit.java | 54 +++--
.../sinks/brokers/jvm/config/BrokersJvmConfig.java | 5 +-
.../flink/config/DatabasesFlinkConfig.java | 5 +-
.../elasticsearch/ElasticSearchController.java | 7 +-
.../sinks/databases/jvm/DatabasesJvmInit.java | 52 ++--
.../databases/jvm/config/DatabasesJvmConfig.java | 5 +-
streampipes-sinks-internal-jvm/development/env | 2 +-
.../sinks/internal/jvm/SinksInternalJvmInit.java | 42 ++--
.../jvm/config/SinksInternalJvmConfig.java | 5 +-
streampipes-sinks-notifications-jvm/pom.xml | 2 +-
.../jvm/SinksNotificationsJvmInit.java | 51 ++--
.../sinks/notifications/jvm/config/ConfigKeys.java | 8 -
.../jvm/config/SinksNotificationsJvmConfig.java | 108 ---------
.../notifications/jvm/email/EmailPublisher.java | 31 +--
.../vehicle/simulator/VehicleSimulatorInit.java | 19 +-
.../vehicle/simulator/config/ConfigKeys.java | 8 +-
.../simulator/config/VehicleSimulatorConfig.java | 84 -------
.../simulator/simulator/VehicleDataSimulator.java | 9 +-
.../simulator/vehicle/streams/VehicleStream.java | 6 +-
.../simulator/WatertankSimulatorInit.java | 28 ++-
.../watertank/simulator/config/ConfigKeys.java | 8 +-
.../simulator/config/WatertankSimulatorConfig.java | 84 -------
.../simulator/utils/WatertankDataSimulator.java | 9 +-
.../watertank/streams/FlowRate1Stream.java | 9 +-
.../watertank/streams/FlowRate2Stream.java | 6 +-
.../watertank/streams/PressureTankStream.java | 6 +-
.../watertank/streams/WaterLevel1Stream.java | 6 +-
.../watertank/streams/WaterLevel2Stream.java | 6 +-
136 files changed, 963 insertions(+), 1478 deletions(-)
delete mode 100644 streampipes-extensions-all-jvm/src/main/java/org/apache/streampipes/extensions/all/jvm/config/AllExtensionsConfig.java
delete mode 100644 streampipes-extensions-all-jvm/src/main/java/org/apache/streampipes/extensions/all/jvm/config/ConfigKeys.java
delete mode 100644 streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/config/SinksNotificationsJvmConfig.java
delete mode 100644 streampipes-sources-vehicle-simulator/src/main/java/org/apache/streampipes/sources/vehicle/simulator/config/VehicleSimulatorConfig.java
delete mode 100644 streampipes-sources-watertank-simulator/src/main/java/org/apache/streampipes/sources/watertank/simulator/config/WatertankSimulatorConfig.java