You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by bo...@apache.org on 2022/12/10 12:48:56 UTC
[streampipes] branch add-example-files-python-client updated (ac33fb6b5 -> 34add0b78)
This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a change to branch add-example-files-python-client
in repository https://gitbox.apache.org/repos/asf/streampipes.git
discard ac33fb6b5 add license information to notebook metadata and disable rat plugin for jupyter notebooks
discard 4297388ef add examples for Python client
discard dbf9708dd add describe() method to python client
add 928e812cd [#820] enable checkstyle for some extension modules
add 4e4eb90ed [hotfix] Update checkstyle plugin in extensions as described in #851
add 338cd0b84 [#820] Enable checkstyle for streampipes-processors-geo-jvm
add 647ae8f4f [hotfix] Fix failing e2e tests
add 7da2c1f0d [#820] enable checkstyle for three more modules
add a0a9909ed Rename artifact `integration` to `streampipes-integration-tests`.
add 694031887 Simplify checkstyle configuration.
add 26b198c06 Simplify checkstyle violation configuration.
add a9912fe94 Merge pull request #851 from RobertIndie/simplify-checkstyle
add e1af7694e [#820] enable checkstyle for some extension modules
add 5a56d293f Merge branch 'dev' into extension-modules-checkstyle-enablements
add 5e67aca52 [#820] Enable checkstyle for all extension modules
add eaa4c6c46 [#820] Enable checkstyle for all extension modules
add 303387d37 [hotfix] Add documentation assets to cusum and welford processor
add 81e081c43 Fix the checkstyle plugin doesn't fail on violation
add d8687e56f Set inherited of parent pom to false
add 03dc0cfcf Merge branch 'dev' into extension-modules-checkstyle-enablements
add 83a51757d [#820] enable checkstyle for adapters in extensions
add fd20ba661 [hotfix] Update checkstyle plugin as described in #851
add 425ccdbe4 Merge branch 'dev' into extension-modules-checkstyle-enablements
add 703208794 [#820] Fix final checkstyle issues in extensions module
add eef2f2403 hotfix: remove incubator status in streampipes-client-python (#852)
add 51c73443f [hotfix] Remove obsolete build config from ui
add 23a7a66ff [release] Bump development version to 0.90.0-SNAPSHOT
add e9b905f60 [release] Use next snapshot version in archetypes
add c6a6cf6c7 [release] Use next snapshot version in installer module
add e11e98b84 [release] Use next snapshot version in ui module
add 530277ac0 [maven-release-plugin] prepare branch @{releaseLabel}
add f132d9072 [maven-release-plugin] prepare for next development iteration
add cf75ca04a [release] Use next development version 0.91.0-SNAPSHOT
add 22fa255aa Merge branch 'dev' into extension-modules-checkstyle-enablements
add 49da23c6a Merge pull request #850 from apache/extension-modules-checkstyle-enablements
add 3fe07f61d add describe() method to python client
add 20832a2ad add examples for Python client
add 34add0b78 add license information to notebook metadata and disable rat plugin for jupyter notebooks
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (ac33fb6b5)
\
N -- N -- N refs/heads/add-example-files-python-client (34add0b78)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../streampipes-archetype-extensions-jvm/pom.xml | 15 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../pom.xml | 15 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../streampipes-archetype-pe-sinks-flink/pom.xml | 15 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
installer/cli/.env | 2 +-
installer/cli/README.md | 2 +-
installer/compose/.env | 2 +-
installer/compose/README.md | 2 +-
installer/k8s/Chart.yaml | 4 +-
installer/k8s/README.md | 6 +-
installer/k8s/values.yaml | 2 +-
pom.xml | 3675 ++++++++++----------
streampipes-backend/pom.xml | 14 +-
.../src/main/resources/openapi.yaml | 2 +-
streampipes-client-python/docs/index.md | 6 +-
streampipes-client-python/setup.py | 2 +-
.../client/credential_provider.py | 2 +-
.../streampipes_client/endpoint/endpoint.py | 2 +-
.../model/container/resource_container.py | 4 +-
streampipes-client/pom.xml | 18 +-
streampipes-commons/pom.xml | 5 +-
streampipes-config/pom.xml | 8 +-
streampipes-connect-api/pom.xml | 4 +-
streampipes-connect-container-master/pom.xml | 14 +-
streampipes-connect-container-worker/pom.xml | 16 +-
streampipes-connect/pom.xml | 34 +-
streampipes-container-extensions/pom.xml | 21 +-
streampipes-container-standalone/pom.xml | 6 +-
streampipes-container/pom.xml | 16 +-
streampipes-data-explorer-commons/pom.xml | 10 +-
streampipes-data-explorer/pom.xml | 8 +-
streampipes-data-export/pom.xml | 10 +-
streampipes-dataformat-cbor/pom.xml | 6 +-
streampipes-dataformat-fst/pom.xml | 6 +-
streampipes-dataformat-json/pom.xml | 6 +-
streampipes-dataformat-smile/pom.xml | 6 +-
streampipes-dataformat/pom.xml | 4 +-
streampipes-extensions/pom.xml | 7 +-
.../streampipes-connect-adapters-iiot/pom.xml | 14 +-
.../connect/iiot/ConnectAdapterIiotInit.java | 63 +-
.../connect/iiot/adapters/PullAdapter.java | 120 +-
.../connect/iiot/adapters/PullRestAdapter.java | 65 +-
.../iiot/adapters/influxdb/InfluxDbClient.java | 493 +--
.../iiot/adapters/influxdb/InfluxDbSetAdapter.java | 256 +-
.../adapters/influxdb/InfluxDbStreamAdapter.java | 306 +-
.../opcua/MiloOpcUaConfigurationProvider.java | 52 +-
.../connect/iiot/adapters/opcua/OpcNode.java | 195 +-
.../connect/iiot/adapters/opcua/OpcUaAdapter.java | 412 +--
.../iiot/adapters/opcua/OpcUaNodeBrowser.java | 18 +-
.../connect/iiot/adapters/opcua/SpOpcUaClient.java | 228 +-
.../opcua/configuration/SpOpcUaConfig.java | 68 +-
.../opcua/configuration/SpOpcUaConfigBuilder.java | 46 +-
.../adapters/opcua/utils/OpcUaNodeVariants.java | 39 +-
.../iiot/adapters/opcua/utils/OpcUaTypes.java | 57 +-
.../iiot/adapters/opcua/utils/OpcUaUtil.java | 35 +-
.../adapters/plc4x/modbus/ModbusConfigFile.java | 78 +-
.../adapters/plc4x/modbus/Plc4xModbusAdapter.java | 590 ++--
.../plc4x/passive/Plc4xPassiveAdapter.java | 157 +-
.../iiot/adapters/plc4x/s7/Plc4xS7Adapter.java | 568 +--
.../iiot/adapters/ros/RosBridgeAdapter.java | 326 +-
.../simulator/machine/MachineDataSimulator.java | 235 +-
.../machine/MachineDataSimulatorUtils.java | 205 +-
.../machine/MachineDataStreamAdapter.java | 99 +-
.../connect/iiot/protocol/set/FileProtocol.java | 195 +-
.../connect/iiot/protocol/set/HttpProtocol.java | 172 +-
.../iiot/protocol/stream/BrokerEventProcessor.java | 3 +-
.../iiot/protocol/stream/FileStreamProtocol.java | 130 +-
.../iiot/protocol/stream/HttpServerProtocol.java | 47 +-
.../iiot/protocol/stream/HttpStreamProtocol.java | 211 +-
.../iiot/protocol/stream/KafkaProtocol.java | 353 +-
.../connect/iiot/protocol/stream/MqttProtocol.java | 19 +-
.../connect/iiot/protocol/stream/NatsProtocol.java | 19 +-
.../connect/iiot/protocol/stream/PullProtocol.java | 105 +-
.../protocol/stream/pulsar/PulsarProtocol.java | 69 +-
.../iiot/protocol/stream/pulsar/PulsarUtils.java | 4 +-
.../protocol/stream/rocketmq/RocketMQConsumer.java | 6 +-
.../protocol/stream/rocketmq/RocketMQProtocol.java | 229 +-
.../protocol/stream/rocketmq/RocketMQUtils.java | 17 +-
.../connect/iiot/utils/FileProtocolUtils.java | 69 +-
.../streampipes-connect-adapters/pom.xml | 12 +-
.../streampipes/connect/ConnectAdapterInit.java | 38 +-
.../streampipes/connect/adapters/PullAdapter.java | 107 +-
.../connect/adapters/PullRestAdapter.java | 66 +-
.../adapters/coindesk/CoindeskBitcoinAdapter.java | 30 +-
.../connect/adapters/coindesk/model/Bpi.java | 60 +-
.../adapters/coindesk/model/CoindeskRawModel.java | 64 +-
.../connect/adapters/coindesk/model/EUR.java | 104 +-
.../connect/adapters/coindesk/model/GBP.java | 100 +-
.../connect/adapters/coindesk/model/Time.java | 60 +-
.../connect/adapters/coindesk/model/USD.java | 100 +-
.../connect/adapters/flic/FlicMQTTAdapter.java | 214 +-
.../connect/adapters/flic/FlicOutput.java | 41 +-
.../connect/adapters/flic/FlicUtils.java | 62 +-
.../connect/adapters/gdelt/GdeltAdapter.java | 327 +-
.../connect/adapters/iex/IexCloudAdapter.java | 12 +-
.../connect/adapters/iex/IexCloudNewsAdapter.java | 60 +-
.../connect/adapters/iex/IexCloudStockAdapter.java | 34 +-
.../connect/adapters/iex/model/IexNewsData.java | 180 +-
.../connect/adapters/iex/model/IexStockData.java | 656 ++--
.../connect/adapters/image/ImageZipAdapter.java | 113 +-
.../connect/adapters/image/ImageZipUtils.java | 16 +-
.../adapters/image/ZipFileImageIterator.java | 117 +-
.../adapters/image/set/ImageSetAdapter.java | 117 +-
.../adapters/image/stream/ImageStreamAdapter.java | 119 +-
.../connect/adapters/iss/IssAdapter.java | 211 +-
.../connect/adapters/iss/model/IssModel.java | 60 +-
.../connect/adapters/iss/model/IssPosition.java | 40 +-
.../connect/adapters/netio/NetioMQTTAdapter.java | 239 +-
.../connect/adapters/netio/NetioRestAdapter.java | 334 +-
.../connect/adapters/netio/NetioUtils.java | 282 +-
.../adapters/netio/model/NetioAllPowerOutputs.java | 32 +-
.../adapters/netio/model/NetioGlobalMeasure.java | 96 +-
.../adapters/netio/model/NetioPowerOutput.java | 144 +-
.../adapters/sensemap/OpenSenseMapAdapter.java | 578 +--
.../connect/adapters/sensemap/SensorNames.java | 213 +-
.../adapters/sensemap/model/CurrentLocation.java | 52 +-
.../connect/adapters/sensemap/model/Geometry.java | 52 +-
.../adapters/sensemap/model/LastMeasurement.java | 40 +-
.../connect/adapters/sensemap/model/Loc.java | 40 +-
.../connect/adapters/sensemap/model/SenseBox.java | 184 +-
.../connect/adapters/sensemap/model/Sensor.java | 120 +-
.../simulator/random/RandomDataSetAdapter.java | 19 +-
.../simulator/random/RandomDataSimulatorUtils.java | 22 +-
.../simulator/random/RandomDataStreamAdapter.java | 21 +-
.../connect/adapters/slack/SlackAdapter.java | 35 +-
.../connect/adapters/slack/SlackConsumer.java | 3 +-
.../connect/adapters/ti/TISensorTag.java | 325 +-
.../adapters/wikipedia/WikipediaAdapter.java | 104 +-
.../wikipedia/WikipediaEditedArticlesAdapter.java | 8 +-
.../wikipedia/WikipediaModelConverter.java | 17 +-
.../wikipedia/WikipediaNewArticlesAdapter.java | 8 +-
.../adapters/wikipedia/WikipediaSseConsumer.java | 3 +-
.../connect/adapters/wikipedia/model/Length.java | 40 +-
.../connect/adapters/wikipedia/model/Meta.java | 180 +-
.../connect/adapters/wikipedia/model/Revision.java | 40 +-
.../adapters/wikipedia/model/WikipediaModel.java | 338 +-
.../streampipes/connect/config/ConfigKeys.java | 12 +-
.../connect/config/ConnectWorkerConfig.java | 6 +-
.../streampipes/connect/adapters/generic/Mock.java | 4 +-
.../connect/adapters/generic/UtilTest.java | 29 +-
.../generic/elements/AddTimestampTest.java | 17 +-
.../generic/elements/DuplicateFilterTest.java | 84 +-
.../generic/protocol/set/HttpProtocolTest.java | 7 +-
.../adapters/sensemap/OpenSenseMapAdapterTest.java | 3 +-
.../connect/adapters/sensemap/SensorNamesTest.java | 54 +-
.../connect/adapters/ti/TISensorTagTest.java | 68 +-
.../streampipes-extensions-all-iiot/pom.xml | 28 +-
.../streampipes-extensions-all-jvm/pom.xml | 26 +-
.../pom.xml | 22 +-
.../streampipes-pipeline-elements-all-jvm/pom.xml | 30 +-
.../pe/jvm/config/AllPipelineElementsConfig.java | 12 +-
.../streampipes/pe/jvm/config/ConfigKeys.java | 6 +-
.../pom.xml | 12 +-
.../pe/simulator/StreamPipesSimulationRunner.java | 9 +-
.../streampipes-pipeline-elements-shared/pom.xml | 19 +-
.../pe/shared/PlaceholderExtractor.java | 2 +-
.../pe/shared/config/kafka/KafkaConfig.java | 96 +-
.../pe/shared/config/kafka/KafkaConnectUtils.java | 174 +-
.../pe/shared/config/kafka/kafka/KafkaConfig.java | 74 +-
.../config/kafka/kafka/KafkaConnectUtils.java | 184 +-
.../pe/shared/config/mqtt/MqttConnectUtils.java | 112 +-
.../pe/shared/config/mqtt/MqttConsumer.java | 7 +-
.../pom.xml | 14 +-
.../flink/AbstractAggregationProgram.java | 13 +-
.../aggregation/flink/AggregationFlinkInit.java | 46 +-
.../aggregation/flink/config/ConfigKeys.java | 8 +-
.../flink/processor/aggregation/Aggregation.java | 7 +-
.../aggregation/AggregationController.java | 101 +-
.../aggregation/AggregationParameters.java | 96 +-
.../processor/aggregation/AggregationProgram.java | 28 +-
.../processor/aggregation/CountAggregation.java | 11 +-
.../processor/aggregation/TimeAggregation.java | 10 +-
.../flink/processor/count/CountController.java | 44 +-
.../flink/processor/count/CountMapper.java | 5 +-
.../flink/processor/count/CountProgram.java | 21 +-
.../flink/processor/count/CountTrigger.java | 3 +-
.../flink/processor/count/Tuple2MapMapper.java | 3 +-
.../processor/eventcount/EventCountController.java | 40 +-
.../processor/eventcount/EventCountMapper.java | 3 +-
.../eventcount/EventCountOutputMapper.java | 3 +-
.../processor/eventcount/EventCountProgram.java | 12 +-
.../flink/processor/rate/EventRate.java | 7 +-
.../flink/processor/rate/EventRateController.java | 28 +-
.../flink/processor/rate/EventRateParameter.java | 18 +-
.../flink/processor/rate/EventRateProgram.java | 33 +-
.../processor/aggregation/AggregationTestData.java | 2 +-
.../aggregation/TestTimeAggregationProgram.java | 34 +-
.../flink/processor/count/TestCountProgram.java | 22 +-
.../flink/processor/rate/TestRateProgram.java | 37 +-
.../pom.xml | 15 +-
.../jvm/ChangeDetectionJvmInit.java | 48 +-
.../changedetection/jvm/cusum/Cusum.java | 145 +-
.../changedetection/jvm/cusum/CusumController.java | 78 +-
.../jvm/cusum/CusumEventFields.java | 8 +-
.../changedetection/jvm/cusum/CusumParameters.java | 44 +-
.../jvm/cusum/WelfordAggregate.java | 74 +-
.../jvm/welford/WelfordAggregate.java | 66 +-
.../jvm/welford/WelfordChangeDetection.java | 210 +-
.../jvm/welford/WelfordEventFields.java | 24 +-
.../documentation.md | 19 +-
.../documentation.md | 17 +-
.../streampipes-processors-enricher-flink/pom.xml | 10 +-
.../enricher/flink/AbstractEnricherProgram.java | 13 +-
.../enricher/flink/EnricherFlinkInit.java | 38 +-
.../enricher/flink/config/ConfigKeys.java | 8 +-
.../processor/timestamp/TimestampController.java | 30 +-
.../processor/timestamp/TimestampEnricher.java | 3 +-
.../processor/timestamp/TimestampParameters.java | 20 +-
.../processor/timestamp/TimestampProgram.java | 23 +-
.../urldereferencing/UrlDereferencing.java | 59 +-
.../UrlDereferencingController.java | 63 +-
.../UrlDereferencingParameter.java | 26 +-
.../urldereferencing/UrlDereferencingProgram.java | 23 +-
.../streampipes-processors-enricher-jvm/pom.xml | 15 +-
.../processors/enricher/jvm/EnricherJvmInit.java | 34 +-
.../enricher/jvm/processor/jseval/JSEval.java | 57 +-
.../jvm/processor/jseval/JSEvalController.java | 44 +-
.../jvm/processor/jseval/JSEvalParameters.java | 16 +-
.../jvm/processor/math/MathOpProcessor.java | 63 +-
.../jvm/processor/math/operation/Operation.java | 2 +-
.../math/operation/OperationAddition.java | 8 +-
.../processor/math/operation/OperationDivide.java | 8 +-
.../processor/math/operation/OperationModulo.java | 8 +-
.../math/operation/OperationMultiply.java | 10 +-
.../math/operation/OperationSubtracting.java | 8 +-
.../math/staticmathop/StaticMathOpProcessor.java | 58 +-
.../jvm/processor/sizemeasure/SizeMeasure.java | 3 +-
.../sizemeasure/SizeMeasureController.java | 53 +-
.../trigonometry/TrigonometryProcessor.java | 52 +-
.../valueChange/ValueChangeProcessor.java | 96 -
.../valuechange/ValueChangeProcessor.java | 101 +
.../documentation.md | 0
.../strings.en | 4 +-
.../streampipes-processors-filters-jvm/pom.xml | 15 +-
.../processors/filters/jvm/FiltersJvmInit.java | 50 +-
.../booleanfilter/BooleanFilterProcessor.java | 79 +-
.../jvm/processor/compose/ComposeProcessor.java | 37 +-
.../processor/enrich/MergeByEnrichProcessor.java | 39 +-
.../jvm/processor/limit/RateLimitProcessor.java | 215 +-
.../jvm/processor/limit/util/EventSelection.java | 6 +-
.../jvm/processor/limit/util/ProcessJob.java | 11 +-
.../jvm/processor/limit/util/SchedulerUtil.java | 49 +-
.../jvm/processor/limit/util/WindowFactory.java | 46 +-
.../jvm/processor/limit/util/WindowType.java | 6 +-
.../jvm/processor/limit/window/CronWindow.java | 31 +-
.../jvm/processor/limit/window/LengthWindow.java | 84 +-
.../jvm/processor/limit/window/ScheduleWindow.java | 133 +-
.../jvm/processor/limit/window/TimeWindow.java | 31 +-
.../filters/jvm/processor/limit/window/Window.java | 8 +-
.../jvm/processor/merge/MergeByTimeProcessor.java | 33 +-
.../filters/jvm/processor/merge/StreamBuffer.java | 58 +-
.../movingaverage/MovingAverageProcessor.java | 110 +-
.../movingaverage/util/MovingAverageFilter.java | 20 +-
.../processor/movingaverage/util/MovingFilter.java | 36 +-
.../movingaverage/util/MovingMedianFilter.java | 24 +-
.../numericalfilter/NumericalFilterProcessor.java | 35 +-
.../NumericalTextFilterProcessor.java | 68 +-
.../numericaltextfilter/StringOperator.java | 2 +-
.../processor/projection/ProjectionProcessor.java | 23 +-
.../processor/schema/MergeBySchemaProcessor.java | 63 +-
.../jvm/processor/textfilter/StringOperator.java | 2 +-
.../processor/textfilter/TextFilterProcessor.java | 40 +-
.../threshold/ThresholdDetectionProcessor.java | 80 +-
.../throughputmon/ThroughputMonitorProcessor.java | 53 +-
.../streampipes-processors-filters-siddhi/pom.xml | 17 +-
.../processors/siddhi/FiltersSiddhiInit.java | 36 +-
.../processors/siddhi/count/CountAggregation.java | 77 +-
.../processors/siddhi/filter/NumericalFilter.java | 22 +-
.../siddhi/filter/NumericalFilterController.java | 42 +-
.../siddhi/filter/NumericalFilterParameters.java | 2 +-
.../processors/siddhi/frequency/Frequency.java | 18 +-
.../siddhi/frequency/FrequencyController.java | 31 +-
.../siddhi/frequencychange/FrequencyChange.java | 18 +-
.../frequencychange/FrequencyChangeController.java | 36 +-
.../siddhi/listcollector/ListCollector.java | 70 +-
.../processors/siddhi/listfilter/ListFilter.java | 32 +-
.../processors/siddhi/sequence/Sequence.java | 24 +-
.../siddhi/sequence/SequenceController.java | 36 +-
.../processors/siddhi/stop/StreamStop.java | 22 +-
.../siddhi/stop/StreamStopController.java | 35 +-
.../streampipes/processors/siddhi/topk/TopK.java | 86 +-
.../streampipes/processors/siddhi/trend/Trend.java | 44 +-
.../processors/siddhi/trend/TrendController.java | 93 +-
.../processors/siddhi/trend/TrendOperator.java | 2 +-
.../processors/siddhi/trend/TrendParameters.java | 60 +-
.../siddhi/trend/TestTrendProcessor.java | 87 +-
.../streampipes-processors-geo-flink/pom.xml | 10 +-
.../processor/geo/flink/AbstractGeoProgram.java | 12 +-
.../processor/geo/flink/GeoFlinkInit.java | 36 +-
.../processor/geo/flink/config/ConfigKeys.java | 8 +-
.../flink/processor/gridenricher/CellOption.java | 212 +-
.../processor/gridenricher/EnrichmentSettings.java | 3 +-
.../gridenricher/SpatialGridCalculator.java | 21 +-
.../gridenricher/SpatialGridEnricher.java | 7 +-
.../SpatialGridEnrichmentController.java | 75 +-
.../gridenricher/SpatialGridEnrichmentProgram.java | 3 +-
.../streampipes-processors-geo-jvm/pom.xml | 20 +-
.../streampipes/processors/geo/jvm/GeoJvmInit.java | 8 +-
.../processors/geo/jvm/config/ConfigKeys.java | 2 +-
.../geo/jvm/jts/helper/SpGeometryBuilder.java | 28 +-
.../geo/jvm/jts/helper/SpTrajectoryBuilder.java | 161 +-
.../{latLngToGeo => latlngtogeo}/LatLngToGeo.java | 29 +-
.../LatLngToGeoController.java | 22 +-
.../LatLngToGeoParameter.java | 2 +-
.../processor/{setEPSG => setepsg}/SetEPSG.java | 11 +-
.../{setEPSG => setepsg}/SetEpsgController.java | 25 +-
.../{setEPSG => setepsg}/SetEpsgParameter.java | 2 +-
.../trajectory/CreateTrajectoryFromPoints.java | 26 +-
.../CreateTrajectoryFromPointsController.java | 50 +-
.../CreateTrajectoryFromPointsParameter.java | 3 +-
.../distancecalculator/DistanceCalculator.java | 5 +-
.../DistanceCalculatorController.java | 52 +-
.../DistanceCalculatorParameters.java | 3 +-
.../processor/geocoder/GoogleMapsGeocoding.java | 25 +-
.../geocoder/GoogleMapsGeocodingController.java | 33 +-
.../processor/revgeocoder/ReverseGeocoding.java | 12 +-
.../revgeocoder/ReverseGeocodingController.java | 38 +-
.../jvm/processor/revgeocoder/geocode/GeoName.java | 138 +-
.../revgeocoder/geocode/ReverseGeoCode.java | 2 +-
.../revgeocoder/geocode/kdtree/KDNode.java | 17 +-
.../geocode/kdtree/KDNodeComparator.java | 19 +-
.../revgeocoder/geocode/kdtree/KDTree.java | 67 +-
.../geo/jvm/processor/speed/SpeedCalculator.java | 34 +-
.../processor/speed/SpeedCalculatorController.java | 81 +-
.../processor/speed/SpeedCalculatorParameters.java | 26 +-
.../StaticDistanceCalculator.java | 31 +-
.../StaticDistanceCalculatorController.java | 82 +-
.../StaticDistanceCalculatorParameters.java | 26 +-
.../staticgeocoder/StaticGoogleMapsGeocoder.java | 23 +-
.../StaticGoogleMapsGeocodingController.java | 39 +-
.../geo/jvm/processor/util/DistanceUtil.java | 38 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../strings.en | 2 +-
.../pom.xml | 16 +-
.../jvm/ImageProcessingJvmInit.java | 30 +-
.../jvm/processor/commons/ImageTransformer.java | 8 +-
.../processor/commons/PlainImageTransformer.java | 4 +-
.../jvm/processor/commons/RequiredBoxStream.java | 19 +-
.../GenericImageClassification.java | 22 +-
.../GenericImageClassificationController.java | 44 +-
.../jvm/processor/imagecropper/ImageCropper.java | 5 +-
.../imagecropper/ImageCropperController.java | 23 +-
.../imagecropper/ImageCropperParameters.java | 3 +-
.../processor/imageenrichment/BoxCoordinates.java | 23 +-
.../jvm/processor/imageenrichment/ColorUtil.java | 43 +-
.../processor/imageenrichment/ImageEnricher.java | 19 +-
.../imageenrichment/ImageEnrichmentController.java | 21 +-
.../imageenrichment/ImageEnrichmentParameters.java | 10 +-
.../jvm/processor/qrreader/QrCodeReader.java | 18 +-
.../processor/qrreader/QrCodeReaderController.java | 37 +-
.../processor/qrreader/QrCodeReaderParameters.java | 2 +-
.../documentation.md | 2 +-
.../documentation.md | 4 +-
.../documentation.md | 8 +-
.../documentation.md | 4 +-
.../pom.xml | 33 +-
.../flink/AbstractPatternDetectionProgram.java | 18 +-
.../detection/flink/PatternDetectionFlinkInit.java | 46 +-
.../pattern/detection/flink/config/ConfigKeys.java | 8 +-
.../flink/processor/absence/AbsenceController.java | 38 +-
.../flink/processor/absence/AbsenceParameters.java | 49 +-
.../flink/processor/absence/AbsenceProgram.java | 84 +-
.../flink/processor/and/AndController.java | 46 +-
.../flink/processor/and/AndParameters.java | 3 +-
.../detection/flink/processor/and/AndProgram.java | 65 +-
.../flink/processor/common/TimestampExtractor.java | 3 +-
.../processor/peak/PeakDetectionCalculator.java | 15 +-
.../processor/peak/PeakDetectionController.java | 48 +-
.../processor/peak/PeakDetectionParameters.java | 6 +-
.../flink/processor/peak/PeakDetectionProgram.java | 30 +-
.../processor/peak/utils/SlidingBatchWindow.java | 8 +-
.../flink/processor/sequence/Sequence.java | 9 +-
.../processor/sequence/SequenceController.java | 26 +-
.../flink/processor/sequence/SequenceProgram.java | 12 +-
.../detection/processor/absence/TestAbsence.java | 24 +-
.../pattern/detection/processor/and/TestAnd.java | 32 +-
.../pom.xml | 10 +-
.../flink/AbstractStatisticsProgram.java | 13 +-
.../statistics/flink/StatisticsFlinkInit.java | 38 +-
.../statistics/flink/config/ConfigKeys.java | 8 +-
.../flink/extensions/MapKeySelector.java | 3 +-
.../flink/extensions/SlidingBatchWindow.java | 8 +-
.../flink/extensions/SlidingEventTimeWindow.java | 22 +-
.../flink/extensions/TimestampMappingFunction.java | 4 +-
.../stat/summary/StatisticsSummaryCalculator.java | 9 +-
.../stat/summary/StatisticsSummaryController.java | 49 +-
.../stat/summary/StatisticsSummaryProgram.java | 3 +-
.../window/StatisticsSummaryCalculatorWindow.java | 11 +-
.../window/StatisticsSummaryControllerWindow.java | 91 +-
.../window/StatisticsSummaryParametersWindow.java | 3 +-
.../StatisticsSummaryParamsSerializable.java | 2 +-
.../window/StatisticsSummaryProgramWindow.java | 37 +-
.../pom.xml | 12 +-
.../flink/AbstractTextMiningProgram.java | 13 +-
.../textmining/flink/TextMiningFlinkInit.java | 34 +-
.../textmining/flink/config/ConfigKeys.java | 8 +-
.../processor/language/LanguageDetection.java | 11 +-
.../language/LanguageDetectionController.java | 48 +-
.../language/LanguageDetectionParameters.java | 3 +-
.../language/LanguageDetectionProgram.java | 5 +-
.../processor/wordcount/WordCountController.java | 45 +-
.../processor/wordcount/WordCountParameters.java | 27 +-
.../processor/wordcount/WordCountProgram.java | 13 +-
.../flink/processor/wordcount/WordSplitter.java | 3 +-
.../processor/wordcount/WordToEventConverter.java | 11 +-
.../streampipes-processors-text-mining-jvm/pom.xml | 20 +-
.../textmining/jvm/TextMiningJvmInit.java | 32 +-
.../textmining/jvm/processor/TextMiningUtil.java | 41 +-
.../textmining/jvm/processor/chunker/Chunker.java | 12 +-
.../jvm/processor/chunker/ChunkerController.java | 61 +-
.../jvm/processor/chunker/ChunkerParameters.java | 37 +-
.../jvm/processor/language/LanguageDetection.java | 15 +-
.../language/LanguageDetectionController.java | 54 +-
.../language/LanguageDetectionParameters.java | 27 +-
.../jvm/processor/namefinder/NameFinder.java | 11 +-
.../processor/namefinder/NameFinderController.java | 45 +-
.../processor/namefinder/NameFinderParameters.java | 28 +-
.../jvm/processor/partofspeech/PartOfSpeech.java | 11 +-
.../partofspeech/PartOfSpeechController.java | 53 +-
.../partofspeech/PartOfSpeechParameters.java | 27 +-
.../sentencedetection/SentenceDetection.java | 12 +-
.../SentenceDetectionController.java | 37 +-
.../SentenceDetectionParameters.java | 27 +-
.../jvm/processor/tokenizer/Tokenizer.java | 11 +-
.../processor/tokenizer/TokenizerController.java | 41 +-
.../processor/tokenizer/TokenizerParameters.java | 27 +-
.../pom.xml | 14 +-
.../boilerpipe/BoilerpipeDocumentSource.java | 10 +-
.../boilerpipe/BoilerpipeExtractor.java | 23 +-
.../kohlschutter/boilerpipe/BoilerpipeFilter.java | 12 +-
.../kohlschutter/boilerpipe/BoilerpipeInput.java | 12 +-
.../boilerpipe/conditions/TextBlockCondition.java | 14 +-
.../kohlschutter/boilerpipe/document/Image.java | 14 +-
.../boilerpipe/document/TextBlock.java | 34 +-
.../boilerpipe/document/TextDocument.java | 29 +-
.../document/TextDocumentStatistics.java | 16 +-
.../boilerpipe/estimators/SimpleEstimator.java | 16 +-
.../boilerpipe/extractors/ArticleExtractor.java | 34 +-
.../extractors/ArticleSentencesExtractor.java | 14 +-
.../boilerpipe/extractors/CanolaExtractor.java | 20 +-
.../boilerpipe/extractors/CommonExtractors.java | 10 +-
.../boilerpipe/extractors/DefaultExtractor.java | 16 +-
.../boilerpipe/extractors/ExtractorBase.java | 35 +-
.../extractors/KeepEverythingExtractor.java | 10 +-
.../KeepEverythingWithMinKWordsExtractor.java | 10 +-
.../extractors/LargestContentExtractor.java | 10 +-
.../extractors/NumWordsRulesExtractor.java | 10 +-
.../boilerpipe/filters/debug/PrintDebugFilter.java | 18 +-
.../filters/english/DensityRulesClassifier.java | 16 +-
.../filters/english/HeuristicFilterBase.java | 10 +-
.../english/IgnoreBlocksAfterContentFilter.java | 18 +-
.../english/KeepLargestFulltextBlockFilter.java | 18 +-
.../filters/english/MinFulltextWordsFilter.java | 10 +-
.../filters/english/NumWordsRulesClassifier.java | 16 +-
.../filters/english/TerminatingBlocksFinder.java | 14 +-
.../boilerpipe/filters/english/package-info.java | 2 +-
.../heuristics/AddPrecedingLabelsFilter.java | 22 +-
.../filters/heuristics/ArticleMetadataFilter.java | 19 +-
.../filters/heuristics/BlockProximityFusion.java | 22 +-
.../filters/heuristics/ContentFusion.java | 20 +-
.../heuristics/DocumentTitleMatchClassifier.java | 20 +-
.../heuristics/ExpandTitleToContentFilter.java | 12 +-
.../filters/heuristics/KeepLargestBlockFilter.java | 22 +-
.../boilerpipe/filters/heuristics/LabelFusion.java | 24 +-
.../LargeBlockSameTagLevelToContentFilter.java | 10 +-
.../filters/heuristics/ListAtEndFilter.java | 10 +-
.../heuristics/SimpleBlockFusionProcessor.java | 18 +-
.../TrailingHeadlineToBoilerplateFilter.java | 18 +-
.../filters/simple/BoilerplateBlockFilter.java | 18 +-
.../boilerpipe/filters/simple/InvertedFilter.java | 14 +-
.../filters/simple/LabelToBoilerplateFilter.java | 13 +-
.../filters/simple/LabelToContentFilter.java | 13 +-
.../simple/MarkEverythingBoilerplateFilter.java | 10 +-
.../simple/MarkEverythingContentFilter.java | 10 +-
.../filters/simple/MinClauseWordsFilter.java | 20 +-
.../boilerpipe/filters/simple/MinWordsFilter.java | 10 +-
.../filters/simple/SplitParagraphBlocksFilter.java | 22 +-
.../filters/simple/SurroundingToContentFilter.java | 18 +-
.../boilerpipe/labels/ConditionalLabelAction.java | 10 +-
.../boilerpipe/labels/DefaultLabels.java | 10 +-
.../boilerpipe/labels/LabelAction.java | 16 +-
.../sax/BoilerpipeHTMLContentHandler.java | 33 +-
.../boilerpipe/sax/BoilerpipeHTMLParser.java | 14 +-
.../boilerpipe/sax/BoilerpipeSAXInput.java | 23 +-
.../boilerpipe/sax/CommonTagActions.java | 62 +-
.../boilerpipe/sax/DefaultTagActionMap.java | 14 +-
.../kohlschutter/boilerpipe/sax/HTMLDocument.java | 14 +-
.../kohlschutter/boilerpipe/sax/HTMLFetcher.java | 12 +-
.../boilerpipe/sax/HTMLHighlighter.java | 56 +-
.../boilerpipe/sax/ImageExtractor.java | 46 +-
.../boilerpipe/sax/InputSourceable.java | 10 +-
.../boilerpipe/sax/MarkupTagAction.java | 25 +-
.../com/kohlschutter/boilerpipe/sax/TagAction.java | 21 +-
.../kohlschutter/boilerpipe/sax/TagActionMap.java | 16 +-
.../boilerpipe/util/UnicodeTokenizer.java | 12 +-
.../flink/AbstractFlinkTransformationProgram.java | 13 +-
.../flink/TransformationFlinkInit.java | 53 +-
.../transformation/flink/config/ConfigKeys.java | 8 +-
.../boilerplate/BoilerplateController.java | 120 +-
.../boilerplate/BoilerplateParameters.java | 45 +-
.../processor/boilerplate/BoilerplateProgram.java | 25 +-
.../processor/boilerplate/BoilerplateRemover.java | 104 +-
.../flink/processor/boilerplate/ExtractorMode.java | 10 +-
.../flink/processor/boilerplate/OutputMode.java | 6 +-
.../flink/processor/converter/FieldConverter.java | 39 +-
.../converter/FieldConverterController.java | 49 +-
.../processor/converter/FieldConverterProgram.java | 3 +-
.../flink/processor/hasher/FieldHasher.java | 10 +-
.../processor/hasher/FieldHasherController.java | 33 +-
.../processor/hasher/FieldHasherParameters.java | 37 +-
.../flink/processor/hasher/FieldHasherProgram.java | 31 +-
.../processor/hasher/algorithm/HashAlgorithm.java | 2 +-
.../hasher/algorithm/HashAlgorithmType.java | 20 +-
.../hasher/algorithm/Md5HashAlgorithm.java | 10 +-
.../hasher/algorithm/Sha1HashAlgorithm.java | 10 +-
.../hasher/algorithm/Sha2HashAlgorithm.java | 10 +-
.../flink/processor/mapper/FieldMapper.java | 6 +-
.../processor/mapper/FieldMapperController.java | 26 +-
.../flink/processor/mapper/FieldMapperProgram.java | 5 +-
.../MeasurementUnitConverterProgram.java | 42 -
.../MeasurementUnitConverter.java | 51 +-
.../MeasurementUnitConverterController.java | 73 +-
.../MeasurementUnitConverterParameters.java | 51 +-
.../MeasurementUnitConverterProgram.java} | 21 +-
.../flink/processor/rename/FieldRenamer.java | 5 +-
.../processor/rename/FieldRenamerController.java | 32 +-
.../processor/rename/FieldRenamerParameters.java | 52 +-
.../processor/rename/FieldRenamerProgram.java | 25 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../processor/converter/TestConverterProgram.java | 23 +-
.../flink/processor/hasher/TestFieldHasher.java | 10 +-
.../hasher/TestFieldHasherController.java | 3 +-
.../processor/hasher/TestFieldHasherProgram.java | 31 +-
.../processor/hasher/TestFieldHasherUtils.java | 4 +-
.../flink/processor/rename/TestRenameProgram.java | 23 +-
.../transformation/flink/utils/DummyCollector.java | 3 +-
.../pom.xml | 15 +-
.../transformation/jvm/TransformationJvmInit.java | 68 +-
.../jvm/processor/array/count/CountArray.java | 35 +-
.../array/count/CountArrayController.java | 29 +-
.../array/count/CountArrayParameters.java | 16 +-
.../jvm/processor/array/split/SplitArray.java | 25 +-
.../array/split/SplitArrayController.java | 44 +-
.../array/split/SplitArrayParameters.java | 26 +-
.../booloperator/counter/BooleanCounter.java | 55 +-
.../counter/BooleanCounterController.java | 39 +-
.../counter/BooleanCounterParameters.java | 38 +-
.../booloperator/edge/SignalEdgeFilter.java | 23 +-
.../edge/SignalEdgeFilterController.java | 41 +-
.../edge/SignalEdgeFilterParameters.java | 71 +-
.../booloperator/inverter/BooleanInverter.java | 5 +-
.../inverter/BooleanInverterController.java | 31 +-
.../inverter/BooleanInverterParameters.java | 16 +-
.../logical/BooleanOperationInputConfigs.java | 24 +-
.../logical/BooleanOperatorProcessor.java | 141 +-
.../logical/enums/BooleanOperatorType.java | 68 +-
.../logical/operations/ANDBoolOperation.java | 8 +-
.../logical/operations/IBoolOperation.java | 17 +-
.../logical/operations/NORBoolOperation.java | 8 +-
.../logical/operations/NOTBooleanOperation.java | 8 +-
.../logical/operations/ORBooleanOperation.java | 8 +-
.../logical/operations/XNORBoolOperation.java | 8 +-
.../logical/operations/XORBooleanOperation.java | 8 +-
.../operations/factory/BoolOperationFactory.java | 32 +-
.../booloperator/state/BooleanToState.java | 8 +-
.../state/BooleanToStateController.java | 58 +-
.../state/BooleanToStateParameters.java | 69 +-
.../timekeeping/BooleanTimekeeping.java | 96 +-
.../timekeeping/BooleanTimekeepingController.java | 61 +-
.../timekeeping/BooleanTimekeepingParameters.java | 37 +-
.../processor/booloperator/timer/BooleanTimer.java | 4 +-
.../booloperator/timer/BooleanTimerController.java | 44 +-
.../booloperator/timer/BooleanTimerParameters.java | 37 +-
.../csvmetadata/CsvMetadataEnrichment.java | 25 +-
.../CsvMetadataEnrichmentController.java | 94 +-
.../csvmetadata/CsvMetadataEnrichmentUtils.java | 17 +-
.../fieldrename/FiledRenameProcessor.java | 78 +-
.../jvm/processor/hasher/FieldHasherProcessor.java | 33 +-
.../processor/hasher/algorithm/HashAlgorithm.java | 2 +-
.../hasher/algorithm/HashAlgorithmType.java | 20 +-
.../hasher/algorithm/Md5HashAlgorithm.java | 10 +-
.../hasher/algorithm/Sha1HashAlgorithm.java | 10 +-
.../hasher/algorithm/Sha2HashAlgorithm.java | 10 +-
.../jvm/processor/mapper/FieldMapperProcessor.java | 27 +-
.../MeasurementUnitConverterProcessor.java | 68 +-
.../jvm/processor/state/StateUtils.java | 84 +-
.../jvm/processor/state/buffer/StateBuffer.java | 25 +-
.../state/buffer/StateBufferController.java | 61 +-
.../state/buffer/StateBufferParameters.java | 71 +-
.../jvm/processor/state/labeler/LabelerUtils.java | 35 +-
.../state/labeler/buffer/StateBufferLabeler.java | 22 +-
.../buffer/StateBufferLabelerController.java | 93 +-
.../buffer/StateBufferLabelerParameters.java | 176 +-
.../processor/state/labeler/model/Statement.java | 46 +-
.../state/labeler/model/StatementUtils.java | 203 +-
.../state/labeler/number/NumberLabeler.java | 14 +-
.../labeler/number/NumberLabelerController.java | 72 +-
.../labeler/number/NumberLabelerParameters.java | 104 +-
.../stringoperator/counter/StringCounter.java | 38 +-
.../counter/StringCounterController.java | 44 +-
.../counter/StringCounterParameters.java | 16 +-
.../stringoperator/state/StringToState.java | 4 +-
.../state/StringToStateController.java | 33 +-
.../state/StringToStateParameters.java | 22 +-
.../stringoperator/timer/StringTimer.java | 42 +-
.../timer/StringTimerController.java | 49 +-
.../timer/StringTimerParameters.java | 37 +-
.../jvm/processor/task/TaskDuration.java | 5 +-
.../jvm/processor/task/TaskDurationController.java | 49 +-
.../processor/timestampextractor/OutputFields.java | 38 +-
.../timestampextractor/TimestampExtractor.java | 126 +-
.../TimestampExtractorController.java | 67 +-
.../TimestampExtractorParameters.java | 26 +-
.../transformtoboolean/TransformToBoolean.java | 76 +-
.../TransformToBooleanController.java | 131 +-
.../TransformToBooleanParameters.java | 16 +-
.../value/change/ChangedValueDetection.java | 8 +-
.../change/ChangedValueDetectionController.java | 27 +-
.../change/ChangedValueDetectionParameters.java | 26 +-
.../value/duration/CalculateDuration.java | 10 +-
.../duration/CalculateDurationController.java | 39 +-
.../duration/CalculateDurationParameters.java | 64 +-
.../documentation.md | 12 +-
.../documentation.md | 2 +-
.../documentation.md | 2 +-
.../documentation.md | 8 +-
.../documentation.md | 8 +-
.../documentation.md | 5 +-
.../documentation.md | 2 +-
.../documentation.md | 11 +-
.../documentation.md | 2 +-
.../documentation.md | 9 +-
.../documentation.md | 5 +-
.../documentation.md | 9 +-
.../documentation.md | 2 +-
.../documentation.md | 11 +-
.../documentation.md | 9 +-
.../documentation.md | 14 +-
.../documentation.md | 10 +-
.../documentation.md | 2 +-
.../documentation.md | 2 +-
.../documentation.md | 2 +-
.../documentation.md | 5 +-
.../documentation.md | 12 +-
.../documentation.md | 11 +-
.../documentation.md | 5 +-
.../streampipes-sinks-brokers-jvm/pom.xml | 17 +-
.../sinks/brokers/jvm/BrokersJvmInit.java | 42 +-
.../sinks/brokers/jvm/bufferrest/BufferRest.java | 16 +-
.../jvm/bufferrest/BufferRestController.java | 61 +-
.../jvm/bufferrest/BufferRestParameters.java | 3 +-
.../jvm/bufferrest/buffer/BufferListener.java | 2 +-
.../jvm/bufferrest/buffer/MessageBuffer.java | 89 +-
.../sinks/brokers/jvm/jms/JmsController.java | 25 +-
.../sinks/brokers/jvm/jms/JmsPublisher.java | 8 +-
.../sinks/brokers/jvm/kafka/KafkaController.java | 47 +-
.../sinks/brokers/jvm/kafka/KafkaParameters.java | 13 +-
.../sinks/brokers/jvm/kafka/KafkaPublisher.java | 31 +-
.../sinks/brokers/jvm/mqtt/MqttClient.java | 252 +-
.../sinks/brokers/jvm/mqtt/MqttPublisherSink.java | 212 +-
.../sinks/brokers/jvm/mqtt/common/MqttOptions.java | 290 +-
.../sinks/brokers/jvm/mqtt/common/MqttUtils.java | 73 +-
.../sinks/brokers/jvm/nats/NatsController.java | 142 +-
.../sinks/brokers/jvm/nats/NatsParameters.java | 18 +-
.../sinks/brokers/jvm/nats/NatsPublisher.java | 77 +-
.../sinks/brokers/jvm/pulsar/PulsarParameters.java | 4 +-
.../brokers/jvm/pulsar/PulsarPublisherSink.java | 142 +-
.../brokers/jvm/rabbitmq/RabbitMqConsumer.java | 10 +-
.../brokers/jvm/rabbitmq/RabbitMqController.java | 3 +-
.../brokers/jvm/rabbitmq/RabbitMqPublisher.java | 1 -
.../sinks/brokers/jvm/rest/RestController.java | 23 +-
.../sinks/brokers/jvm/rest/RestPublisher.java | 17 +-
.../jvm/rocketmq/RocketMQPublisherSink.java | 144 +-
.../sinks/brokers/jvm/websocket/SocketServer.java | 68 +-
.../brokers/jvm/websocket/WebsocketServerSink.java | 70 +-
.../documentation.md | 2 +-
.../brokers/jvm/pulsar/TestPulsarParameters.java | 44 +-
.../jvm/pulsar/TestPulsarPublisherSink.java | 113 +-
.../jvm/rocketmq/TestRocketMQPublisherSink.java | 80 +-
.../streampipes-sinks-databases-flink/pom.xml | 31 +-
.../sinks/databases/flink/DatabasesFlinkInit.java | 40 +-
.../sinks/databases/flink/config/ConfigKeys.java | 12 +-
.../elasticsearch/ElasticSearchController.java | 23 +-
.../flink/elasticsearch/ElasticSearchProgram.java | 120 +-
.../ElasticsearchIndexRequestBuilder.java | 16 +-
.../elastic/ActionRequestFailureHandler.java | 60 +-
.../elastic/BulkProcessorIndexer.java | 38 +-
.../elastic/Elasticsearch6ApiCallBridge.java | 150 +-
.../elastic/ElasticsearchApiCallBridge.java | 37 +-
.../elasticsearch/elastic/ElasticsearchSink.java | 57 +-
.../elastic/ElasticsearchSinkBase.java | 769 ++--
.../elastic/ElasticsearchSinkFunction.java | 49 +-
.../elasticsearch/elastic/NoOpFailureHandler.java | 13 +-
.../elasticsearch/elastic/RequestIndexer.java | 12 +-
.../streampipes-sinks-databases-jvm/pom.xml | 15 +-
.../sinks/databases/jvm/DatabasesJvmInit.java | 36 +-
.../sinks/databases/jvm/couchdb/CouchDb.java | 21 +-
.../databases/jvm/couchdb/CouchDbController.java | 24 +-
.../databases/jvm/couchdb/CouchDbParameters.java | 3 +-
.../sinks/databases/jvm/ditto/Ditto.java | 26 +-
.../sinks/databases/jvm/ditto/DittoController.java | 28 +-
.../sinks/databases/jvm/influxdb/InfluxDb.java | 11 +-
.../databases/jvm/influxdb/InfluxDbClient.java | 126 +-
.../databases/jvm/influxdb/InfluxDbController.java | 54 +-
.../sinks/databases/jvm/iotdb/IotDb.java | 38 +-
.../sinks/databases/jvm/iotdb/IotDbController.java | 44 +-
.../sinks/databases/jvm/iotdb/IotDbParameters.java | 20 +-
.../sinks/databases/jvm/jdbcclient/JdbcClient.java | 468 +--
.../jvm/jdbcclient/model/DbDataTypeFactory.java | 362 +-
.../jvm/jdbcclient/model/DbDataTypes.java | 62 +-
.../jvm/jdbcclient/model/DbDescription.java | 86 +-
.../jdbcclient/model/JdbcConnectionParameters.java | 114 +-
.../jvm/jdbcclient/model/ParameterInformation.java | 24 +-
.../jvm/jdbcclient/model/StatementHandler.java | 275 +-
.../jvm/jdbcclient/model/SupportedDbEngines.java | 40 +-
.../jvm/jdbcclient/model/TableDescription.java | 235 +-
.../jvm/jdbcclient/utils/SQLStatementUtils.java | 122 +-
.../jvm/jdbcclient/utils/StatementUtils.java | 73 +-
.../sinks/databases/jvm/opcua/OpcUa.java | 333 +-
.../sinks/databases/jvm/opcua/UpcUaController.java | 34 +-
.../sinks/databases/jvm/postgresql/PostgreSql.java | 23 +-
.../jvm/postgresql/PostgreSqlController.java | 6 +-
.../jvm/postgresql/PostgreSqlParameters.java | 23 +-
.../sinks/databases/jvm/redis/Redis.java | 156 +-
.../sinks/databases/jvm/redis/RedisController.java | 120 +-
.../sinks/databases/jvm/redis/RedisParameters.java | 176 +-
.../streampipes-sinks-internal-jvm/pom.xml | 19 +-
.../sinks/internal/jvm/SinksInternalJvmInit.java | 30 +-
.../sinks/internal/jvm/datalake/DataLakeSink.java | 66 +-
.../jvm/notification/NotificationProducer.java | 24 +-
.../streampipes-sinks-notifications-jvm/pom.xml | 17 +-
.../jvm/SinksNotificationsJvmInit.java | 28 +-
.../sinks/notifications/jvm/config/ConfigKeys.java | 2 +-
.../notifications/jvm/email/EmailController.java | 27 +-
.../notifications/jvm/email/EmailParameters.java | 64 +-
.../notifications/jvm/email/EmailPublisher.java | 62 +-
.../jvm/onesignal/OneSignalController.java | 53 +-
.../jvm/onesignal/OneSignalParameters.java | 42 +-
.../jvm/onesignal/OneSignalProducer.java | 81 +-
.../notifications/jvm/slack/SlackNotification.java | 112 +-
.../jvm/slack/SlackNotificationController.java | 43 +-
.../jvm/slack/SlackNotificationParameters.java | 64 +-
.../jvm/telegram/TelegramController.java | 54 +-
.../jvm/telegram/TelegramParameters.java | 50 +-
.../jvm/telegram/TelegramPublisher.java | 104 +-
.../streampipes-sources-vehicle-simulator/pom.xml | 10 +-
.../vehicle/simulator/VehicleSimulatorInit.java | 8 +-
.../vehicle/simulator/config/ConfigKeys.java | 4 +-
.../simulator/simulator/VehicleDataSimulator.java | 29 +-
.../simulator/vehicle/streams/VehicleStream.java | 32 +-
.../pom.xml | 21 +-
.../simulator/WatertankSimulatorInit.java | 6 +-
.../watertank/simulator/config/ConfigKeys.java | 4 +-
.../simulator/utils/WatertankDataSimulator.java | 32 +-
.../simulator/vocabulary/WaterTankVocabulary.java | 2 +-
.../watertank/streams/FlowRate1Stream.java | 66 +-
.../watertank/streams/FlowRate2Stream.java | 102 +-
.../watertank/streams/PressureTankStream.java | 48 +-
.../watertank/streams/WaterLevel1Stream.java | 74 +-
.../watertank/streams/WaterLevel2Stream.java | 60 +-
streampipes-integration-tests/pom.xml | 27 +-
streampipes-logging/pom.xml | 2 +-
streampipes-mail/pom.xml | 6 +-
streampipes-maven-plugin/pom.xml | 2 +-
streampipes-measurement-units/pom.xml | 4 +-
streampipes-messaging-jms/pom.xml | 17 +-
streampipes-messaging-kafka/pom.xml | 19 +-
streampipes-messaging-mqtt/pom.xml | 17 +-
streampipes-messaging-nats/pom.xml | 21 +-
streampipes-messaging/pom.xml | 17 +-
streampipes-model-client/pom.xml | 6 +-
streampipes-model-shared/pom.xml | 2 +-
streampipes-model/pom.xml | 10 +-
streampipes-performance-tests/pom.xml | 10 +-
streampipes-pipeline-management/pom.xml | 42 +-
streampipes-platform-services/pom.xml | 12 +-
streampipes-resource-management/pom.xml | 8 +-
streampipes-rest-core-base/pom.xml | 10 +-
streampipes-rest-shared/pom.xml | 6 +-
streampipes-rest/pom.xml | 45 +-
streampipes-sdk-bundle/pom.xml | 22 +-
streampipes-sdk/pom.xml | 8 +-
streampipes-security-jwt/pom.xml | 4 +-
streampipes-serializers-json/pom.xml | 8 +-
streampipes-service-base/pom.xml | 22 +-
streampipes-service-discovery-api/pom.xml | 18 +-
streampipes-service-discovery-consul/pom.xml | 24 +-
streampipes-service-discovery/pom.xml | 22 +-
streampipes-service-extensions-base/pom.xml | 24 +-
streampipes-sources/pom.xml | 4 +-
streampipes-storage-api/pom.xml | 6 +-
streampipes-storage-couchdb/pom.xml | 12 +-
streampipes-storage-management/pom.xml | 6 +-
streampipes-test-utils/pom.xml | 4 +-
streampipes-user-management/pom.xml | 10 +-
streampipes-vocabulary/pom.xml | 2 +-
streampipes-wrapper-distributed/pom.xml | 10 +-
streampipes-wrapper-flink/pom.xml | 4 +-
streampipes-wrapper-kafka-streams/pom.xml | 4 +-
streampipes-wrapper-python/pom.xml | 2 +-
streampipes-wrapper-siddhi/pom.xml | 4 +-
streampipes-wrapper-standalone/pom.xml | 4 +-
streampipes-wrapper/pom.xml | 14 +-
tools/maven/suppressions.xml | 2 +
ui/deployment/rel/config.yml | 29 -
ui/deployment/rel/img/logo.png | Bin 14358 -> 0 bytes
ui/deployment/rel/img/sp-logo-right-white.png | Bin 21453 -> 0 bytes
ui/package.json | 3 +-
817 files changed, 21337 insertions(+), 20238 deletions(-)
delete mode 100644 streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/valueChange/ValueChangeProcessor.java
create mode 100644 streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/valuechange/ValueChangeProcessor.java
rename streampipes-extensions/streampipes-processors-enricher-jvm/src/main/resources/{org.apache.streampipes.processors.enricher.jvm.valueChange => org.apache.streampipes.processors.enricher.jvm.valuechange}/documentation.md (100%)
rename streampipes-extensions/streampipes-processors-enricher-jvm/src/main/resources/{org.apache.streampipes.processors.enricher.jvm.valueChange => org.apache.streampipes.processors.enricher.jvm.valuechange}/strings.en (90%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{latLngToGeo => latlngtogeo}/LatLngToGeo.java (77%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{latLngToGeo => latlngtogeo}/LatLngToGeoController.java (83%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{latLngToGeo => latlngtogeo}/LatLngToGeoParameter.java (99%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{setEPSG => setepsg}/SetEPSG.java (89%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{setEPSG => setepsg}/SetEpsgController.java (80%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{setEPSG => setepsg}/SetEpsgParameter.java (99%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/{org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo => org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtogeo}/documentation.md (100%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/{org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo => org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtogeo}/icon.png (100%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/{org.apache.streampipes.processors.geo.jvm.jts.processor.latLngToGeo => org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtogeo}/strings.en (79%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/{org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG => org.apache.streampipes.processors.geo.jvm.jts.processor.setepsg}/documentation.md (100%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/{org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG => org.apache.streampipes.processors.geo.jvm.jts.processor.setepsg}/icon.png (100%)
rename streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/{org.apache.streampipes.processors.geo.jvm.jts.processor.setEPSG => org.apache.streampipes.processors.geo.jvm.jts.processor.setepsg}/strings.en (87%)
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/measurementUnitConverter/MeasurementUnitConverterProgram.java
rename streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/{measurementUnitConverter => measurementunitonverter}/MeasurementUnitConverter.java (54%)
rename streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/{measurementUnitConverter => measurementunitonverter}/MeasurementUnitConverterController.java (66%)
rename streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/{measurementUnitConverter => measurementunitonverter}/MeasurementUnitConverterParameters.java (63%)
copy streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/{mapper/FieldMapperProgram.java => measurementunitonverter/MeasurementUnitConverterProgram.java} (66%)
rename streampipes-extensions/streampipes-processors-transformation-flink/src/main/resources/{org.apache.streampipes.processors.transformation.flink.measurement-unit-converter => org.apache.streampipes.processors.transformation.flink.measurementunitconverter}/documentation.md (100%)
rename streampipes-extensions/streampipes-processors-transformation-flink/src/main/resources/{org.apache.streampipes.processors.transformation.flink.measurement-unit-converter => org.apache.streampipes.processors.transformation.flink.measurementunitconverter}/icon.png (100%)
rename streampipes-extensions/streampipes-processors-transformation-flink/src/main/resources/{org.apache.streampipes.processors.transformation.flink.measurement-unit-converter => org.apache.streampipes.processors.transformation.flink.measurementunitconverter}/strings.en (84%)
delete mode 100644 ui/deployment/rel/config.yml
delete mode 100644 ui/deployment/rel/img/logo.png
delete mode 100644 ui/deployment/rel/img/sp-logo-right-white.png