You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2020/10/27 21:08:45 UTC
[incubator-streampipes-extensions] branch master updated (44b7dd1
-> d42552c)
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git.
from 44b7dd1 [maven-release-plugin] prepare release release/0.66.0
add a8d43a6 [maven-release-plugin] prepare for next development iteration
add 7ce7d61 Update streampipes core dependencies to next dev version 0.67.0-SNAPSHOT
add 32892bd Resolve dependency convergence problem in image-processing-jvm module
add 1756fe1 Resolve dependency convergence problem in image-processing-jvm module
add dc29746 Add description and icon to speed calculator
add a9f6def Update release settings in pom.xml
add 1472992 Update NOTICE file
add 436df47 StringTimer & StringCounter Processor
add e313c91 Merge pull request #11 from Madabaru/dev
add 613cdcf Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into dev
add fb947b9 Update pom.xml
add 5ca98c1 [STREAMPIPES-116]: Modify reverse geocoder
add 76a00f2 OpenNLP models can now be uploaded into processors
add 91d1963 Remove package connect adapter
add 937da21 Modify connect pom, add ASF snapshot repo to parent pom
add 4a424c6 Fix dependencies of new connect package structure
add 9e0f5e2 Fix connect docker files for arm
add 718cf4c Adapt github actions to new package structure
add b257374 Edit pom of connect adapters
add 88f5d65 Fix packaging in streampipes-connect-adapters pom
add 55b9448 [hotfix] fix typo in link
add 82ab1a5 [STREAMPIPES-121] Add data sink for Redis
add 100c00d Working on STREAMPIPES-118: Add file upload, update API
add af244fe STREAMPIPES-118 Add csv uplaod to configuration
add 1e633e5 STREAMPIPES-118: Fix S7 CSV upload
add afe94c3 Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into STREAMPIPES-121
add 8987e88 Merge pull request #12 from grainier/STREAMPIPES-121
add fd4572d change to ontology vocabulary, changed text and new icon
add f326c85 format fix
add 67f992b env
add 26e4684 changed from label.from to withID
add b6bfcb9 adding feature to dev and code formating
add d7f821d fix STREAMPIPES-123
add 0f81507 change to ontology vocabulary, changed text and new icon
add cd1fc3d format fix
add a71d887 env
add d7b5bbe changed from label.from to withID
add 370cdc6 format code
add cd0fc2a Merge remote-tracking branch 'origin/feature/latLngGeo' into feature/latLngGeo
add a2a8c0c fix merge
add e1fe029 added PE
add 156b8ca extended Geometry helper with WKT Reader
add 1ec0b51 changed javadoc
add c85b086 trajectory class misc changes (spelling javadoc)
add 6de2600 ontologie
add 4526f8c rewrite from labels.from to label.withID
add 9c7f951 format code
add 00bb22f fix error in extraction and output strategy
add 285c684 added PE
add f40542f extended Geometry helper with WKT Reader
add 0cfd6dc changed javadoc
add 225f3eb trajectory class misc changes (spelling javadoc)
add 3c2a94a ontologie
add 8baaf58 rewrite from labels.from to label.withID
add c80f858 format code
add 3ac10f4 Merge remote-tracking branch 'origin/feature/trajectory' into feature/trajectory
add 9e7a465 fix STREAMPIPES-123
add d6fa2b5 Merge branch 'feature/trajectory' into dev
add e4ad088 Add validation to Redis key field
add d41ff77 Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into STREAMPIPES-121
add 60347f4 Merge pull request #13 from grainier/STREAMPIPES-121
add de0b1ad Merge remote-tracking branch 'origin/dev' into dev
add adf89c1 Cleanup dependency management
add ab91a15 Merge pull request #14 from grainier/pom-cleanup
add 8003e94 Create adapter structure and zip file image iterator
add 06da435 Finished ImageStreamAdapter
add ceaf024 Implement ImageSetAdapter
add 24a4758 [STREAMPIPES-140] Add streampipes-maven-plugin
add c9f8021 [STREAMPIPES-135] Add JavaScript eval processor
add 5927fb7 Remove supported formats/protocols from controller
add 4161ebd Fix adding fields to output event
add 839ec03 Merge pull request #15 from grainier/STREAMPIPES-135
add bfe593c Add a default label field in data lake sink
add 1127d84 Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into dev
add 6f5f09d [STREAMPIPES-138] Update license header in some files
add e8b610d Add link to 3rd party NOTICE contents
add b09a7df [STREAMPIPES-141] Extract assets from adapter descriptions
add e1077c2 Add unreleased pipeline elements to .spignore
add 2aa7cc7 [STREAMPIPES-143] Numerical Filter in Siddhi not working
add 4d1e078 [STREAMPIPES-144] Add Telegram publisher to send notifications
add d37f242 Merge pull request #16 from grainier/STREAMPIPES-144
add 3a08494 Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into dev
add 16d3936 [STREAMPIPES-79] Modify serialization of data lake measurement generation
add a734d3f Added new processor to transform boolean values into a state
add 8b9ae52 PLC4X S7 Extension: Importing config from Excel files
add e08dde8 Merge pull request #17 from Madabaru/dev
add 2b5311d Add guava dependency to be used with time window scheduled service
add 50519a2 [STREAMPIPES-147] Add pipeline element to rate-limit events
add 849c145 Merge pull request #18 from grainier/STREAMPIPES-147
add ed93334 New MySQL Data Sink
add 2ee856e Merge branch 'dev' of https://github.com/Madabaru/incubator-streampipes-extensions into dev
add 4d781ce Working on SQL sink and adapters
add 15a81f9 Replace guava dependency with quartz
add c27476c Refactor window api and move scheduler to quartz
add 12ff934 Add cron window implementation
add 13d3668 Add cron window support with rate-limiting
add d4ea813 Update documentation with cron window config
add 8d00841 Merge pull request #20 from grainier/STREAMPIPES-151
add d29c984 Fix in ValidateTable for MySQL Sink
add e66169e Merge pull request #21 from Madabaru/dev
add a95d9af implement config file for Modbus protocol similar to s7
add 81fe8f6 implement adapater for Modbus protocol supporting reading of boolean and integer
add 4096479 add dependency for modbus driver
add 3e4a37e add dependency for modbus driver and update plc4x version to latest release
add 85b24e1 Merge pull request #22 from bossenti/extension_modbus_adapter
add bc1752e Working on state buffer
add c913f4d First simple version of state buffer
add f9a4ed7 Merge branch 'dev' into STREAMPIPES-149
add 7f7123a Finish state buffer
add 04f2068 [STREAMPIPES-149][STREAMPIPES-156] Add new processors for state processing
add 8c9a90e Merge branch 'STREAMPIPES-149' into dev
add a2b5d0d Added new processors to AllPipelineElementsInit
add ae45a23 Highlight the link for chron of rate limit processor
add a2949fd Fix [STREAMPIPES-155] SplitArray controller produces wrong output schema
add 4c957de Fix to SQL
add 85da37d Merge pull request #23 from Madabaru/dev
add 765c7e9 Final fixes for SQL sink and adapter
add 3614b2a Integrate modbus adapter
add 416201e [STREAMPIPES-159] Processor: Detect Signal Edge
add 2549ef7 Add signal edge detection to app pipeline elements
add 69f41fd Fix modbus adapter
add 39bdcbb [STREAMPIPES-161] Add PR template and contributing guide
add d4af0e4 Merge pull request #24 from grainier/STREAMPIPES-161
add 915d24e New Adapter for Flic Button
add e1a7984 Addded resources info for adapter
add 151bce0 Final modification
add ed0b3c2 Added Topic
add d0d1e89 [STREAMPIPES-156] Processor: Number Labeler
add fac8dfd Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into dev
add 9c49c44 Change image storage location
add 334ba40 Merge branch 'dev' into feature/adapter-flic-button
add a11c718 [STREAMPIPES-135] Add module nashorn to docker file
add 44f3c21 Change java version in docker file
add 1d2b521 Change docker tag version of enricher processors
add 506c4a6 Change java version in jvm-all container
add 9a5a6de [STREAMPIPES-165] S7 adpater does not work Change the URL string for the s7 plc4x adapter
add de376fb Mark dimension properties as tags in influx
add a723f09 Add property scope to label processors
add 96c0313 add possibility to specify the slave ID
add 1ffe8c3 add support for input register and discrete input
add 6ef941d check for duplicates in nodeId and runtimeName
add 9b8e5d1 Merge pull request #25 from bossenti/dev
add c73775a Update .gigignore
add 1212267 Update to .gitignore
add 18198f7 Add run configurations
add d21d3b2 Add more run configurations
add 8d8a80a Final Configuration
add 323d710 Fix AggregationFlinkInit
add 323d229 Remove break in modbus adapter
add 3d85ff8 Merge branch 'dev' into run-configurations
add db6ee69 [STREAMPIPES-167] Remove env file plugin from run configurations
add 94670e4 Fix data lake error with timestamp parsing
add 90ec263 Add node id to modbus strings
add e2b2012 Fix typo in run configuration
add 95a4ac2 [STREAMPIPES-170] Null pointer in JSEvaluator
add 7a7164f Fix problems of Modbus Adapter
add 61dff06 Update strings.en
add 6f0d121 Merge pull request #26 from bossenti/patch-1
add cba0efb [STREAMPIPES-171] move datalake influx config to container configs
add c2a46d7 change data lake hyperparameter, flush all data at pe termination
add 6a06c2c Improve file stream adapter configuration
add 284ca46 Fix schema guess in modbus adapter
add 731af55 Fix null pointer in modbus adapter
add c3f6adf fix modbus adapter
add 3001d81 fix modbus adapter
add e82532d fix modbus adapter
add 2cf3964 rename data type to object type
add 922b064 Merge pull request #27 from bossenti/dev
add d0948a3 [hotfix] fixed wrong name in run configuration
add ee8e92e [hotfix] some more fixes to wrong rung configurations
add 9fdfa6d [hotfix] commented not working siddhi processors, add custom output strategy to numerical filter in siddhi
add bca188d [STREAMPIPES-184] add annotation to bounding box
add dc5774f [STREAMPIPES-184] change stream requirements
add 81de24f [STREAMPIPES-184] fix round bug
add 262e6e3 Add exception content to plc adapter exception
add e79129f fix Modbus Adapter
add 2564308 Update strings.en
add 342c17d Merge pull request #28 from bossenti/dev
add 56cbb89 Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into dev
add d295ebc Merge remote-tracking branch 'origin/dev' into dev
add acd1ecb Change exception handling in PLC adapter
add be4d3df Remove old comment in code
add 1ba8aa1 Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into dev
add 9966791 fixed bug in OpcUaAdapter
add 339577d Merge pull request #29 from chrweiss/dev
add 86734b3 [STREAMPIPES-138] Use standard disclaimer, fix some licensing issues
add 1de365a [STREAMPIPES-216] add machine data simulator
add f047eb8 Remove nginx host from sinks internal jvm container
add 93dfc8b [STREAMPIPES-211] Add Polling interval for PLC4X S7 adapter
add a9b2766 Merge remote-tracking branch 'refs/remotes/origin/dev' into dev
add 2c3f163 [hotfix] remove unnecessary README in connect-adapters
add ace2d91 [hotfix] some minor edits including naming connect adapters as part of extensions, add installation section
add 2bb3f57 Improve number labeling component
add fe45266 Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into dev
add 6af8551 Update state buffer labeler
add 783072a Merge remote-tracking branch 'refs/remotes/origin/dev' into dev
add 0f6a6a5 [hotfix] use master repo as reference for installer
add 749226b [hotfix] use master repo
add 231bd8f [maven-release-plugin] prepare branch rel/0.67.0
add 1e2cc63 [hotfix] fix wrong build context path
add 9b6c8fe [hotfix] Fix dependency convergence problem
add ce45191 [hotfix] add license header
add 4c5c2ec [hotfix] fixed bug in siddhi trend test
add 54dc7ab [hotfix] remove import
add 672be46 [STREAMPIPES-232] Build and push Docker images on rel/** branches
add 931e872 [STREAMPIPES-232] fix branch name parsing
add 742846d [STREAMPIPES-167] place only needed IntelliJ run configs
add 52fdeea [STREAMPIPES-225] add pipeline-elements-all-flink to validation docker-compose.yml
add 1aadf07 [STREAMPIPES-225] add pipeline-elements-all-flink module
add c14b686 [hotfix] add fix docker network name for release validation
add c23c36f [hotfix] fix wrong build context
add 7c8fc7f [STREAMPIPES-227] Add missing label to Boolean counter
add 937808f [hotfix] add run config for all-pipeline-elements-flink
add 1b35446 [STREAMPIPES-217] Update SDK methods to reflect changes in file management
add 3f7e332 Add processor string to state
add c3737c1 [STREAMPIPES-236] Adjust telegram sink using html font format option for messages
add 6b61a81 [STREAMPIPES-240] add missing alpine pkgs to fix NullPointerException
add d73ed14 [STREAMPIPES-240] remove installs from non alpine base image
add 8216b3e Merge branch 'rel/0.67.0' of github.com:apache/incubator-streampipes-extensions into rel/0.67.0
add 60529a1 Fix string.en in label buffer processor
add 22cbc54 Merge branch 'rel/0.67.0' of github.com:apache/incubator-streampipes-extensions into rel/0.67.0
add c05e466 [hotfix] Modify jar file name in Dockerfile
add 43acc2b [hotfix] Use append output strategy for generic image classifier
add 7fdac0c Fix state processors
add 7b59e98 Merge branch 'rel/0.67.0' of github.com:apache/incubator-streampipes-extensions into rel/0.67.0
add 815ab0a Merge branch 'rel/0.67.0' of github.com:apache/incubator-streampipes-extensions into rel/0.67.0
add bb82ad4 [hotfix] Add property scope to aggregation output
add 9a407a4 [STREAMPIPES-244] JS Evaluator is not working in docker
add 23db112 [STREAMPIPES-231] Images are not shown in Data Explorer
add c54d299 Add release notes for upcoming version 0.67.0
add d1b817c Update streampipes version
add e195635 Remove version from connect worker
add cc4986a Add connect worker dependency to parent pom
add c5b7ede Change streampipes version in pipeline-elements-all-flink
add d47ac49 Add assembly xml to fix release build
add 0ebbb18 [maven-release-plugin] prepare release release/0.67.0
new d42552c Merge tag 'release/0.67.0'
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:
.github/PULL_REQUEST_TEMPLATE.md | 53 +++
.github/workflows/build.yml | 29 +-
.gitignore | 5 +-
.../all_pipeline_elements_flink.xml | 15 +
.../all_pipeline_elements_jvm.xml | 21 ++
.idea/runConfigurations/connect_adapters.xml | 17 +
.../processors_aggregation_flink.xml | 15 +
.../processors_enricher_flink.xml | 15 +
.../runConfigurations/processors_enricher_jvm.xml | 14 +
.idea/runConfigurations/processors_filters_jvm.xml | 14 +
.../processors_filters_siddhi.xml | 14 +
.idea/runConfigurations/processors_geo_flink.xml | 15 +
.idea/runConfigurations/processors_geo_jvm.xml | 14 +
.../processors_imageprocessing_jvm.xml | 14 +
.../processors_pattern_detection_flink.xml | 15 +
.../processors_statistics_flink.xml | 15 +
.../processors_textmining_flink.xml | 15 +
.../processors_textmining_jvm.xml | 14 +
.../processors_transformation_flink.xml | 15 +
.../processors_transformation_jvm.xml | 14 +
.idea/runConfigurations/sinks_brokers_jvm.xml | 14 +
.idea/runConfigurations/sinks_databases_flink.xml | 16 +
.idea/runConfigurations/sinks_databases_jvm.xml | 14 +
.idea/runConfigurations/sinks_internal_jvm.xml | 22 ++
.../runConfigurations/sinks_notifications_jvm.xml | 23 ++
.../sources_vehicle_simulator_jvm.xml | 16 +
.../sources_watertank_simulator_jvm.xml | 16 +
.spignore | 9 +-
.../documentation.md => CONTRIBUTING.md | 46 +--
DISCLAIMER | 5 +
DISCLAIMER-WIP | 8 -
NOTICE | 5 +-
README.md | 67 ++--
RELEASE_NOTES.md | 40 ++-
docker-compose.yml | 49 ++-
pom.xml | 305 +++++++++++++++-
.../{streampipes-connect-adapter => }/Dockerfile | 4 +-
streampipes-connect-adapters/README.md | 90 -----
.../aarch64.Dockerfile | 4 +-
.../arm.Dockerfile | 4 +-
streampipes-connect-adapters/pom.xml | 174 ++++-----
.../streampipes/connect/ConnectAdapterInit.java | 18 +-
.../streampipes/connect/adapters/PullAdapter.java | 0
.../connect/adapters/PullRestAdapter.java | 0
.../adapters/coindesk/CoindeskBitcoinAdapter.java | 14 +-
.../connect/adapters/coindesk/Currency.java | 0
.../connect/adapters/coindesk/model/Bpi.java | 0
.../adapters/coindesk/model/CoindeskRawModel.java | 0
.../connect/adapters/coindesk/model/EUR.java | 0
.../connect/adapters/coindesk/model/GBP.java | 0
.../connect/adapters/coindesk/model/Time.java | 0
.../connect/adapters/coindesk/model/USD.java | 0
.../connect/adapters/flic/FlicMQTTAdapter.java} | 49 +--
.../connect/adapters/flic/FlicOutput.java} | 48 ++-
.../connect/adapters/flic/FlicUtils.java | 74 ++++
.../connect/adapters/gdelt/GdeltAdapter.java | 10 +-
.../connect/adapters/iex/IexCloudAdapter.java | 7 +-
.../connect/adapters/iex/IexCloudNewsAdapter.java | 13 +-
.../connect/adapters/iex/IexCloudStockAdapter.java | 12 +-
.../connect/adapters/iex/model/IexNewsData.java | 0
.../connect/adapters/iex/model/IexStockData.java | 0
.../connect/adapters/image/ImageZipAdapter.java | 100 ++++++
.../connect/adapters/image/ImageZipUtils.java | 23 +-
.../adapters/image/ZipFileImageIterator.java | 103 ++++++
.../adapters/image/set/ImageSetAdapter.java | 99 ++++++
.../adapters/image/stream/ImageStreamAdapter.java | 97 +++++
.../connect/adapters/influxdb/InfluxDbClient.java | 0
.../adapters/influxdb/InfluxDbSetAdapter.java | 26 +-
.../adapters/influxdb/InfluxDbStreamAdapter.java | 28 +-
.../connect/adapters/iss/IssAdapter.java | 0
.../connect/adapters/iss/model/IssModel.java | 0
.../connect/adapters/iss/model/IssPosition.java | 0
.../streampipes/connect/adapters/mysql/Column.java | 16 +-
.../connect/adapters/mysql/MySqlAdapter.java | 20 +-
.../connect/adapters/mysql/MySqlClient.java | 19 +-
.../connect/adapters/mysql/MySqlSetAdapter.java | 24 +-
.../connect/adapters/mysql/MySqlStreamAdapter.java | 23 +-
.../connect/adapters/netio/NetioMQTTAdapter.java | 0
.../connect/adapters/netio/NetioRestAdapter.java | 0
.../connect/adapters/netio/NetioUtils.java | 30 +-
.../netio/model/NetioAllPowerOutputs.java} | 42 +--
.../adapters/netio/model/NetioGlobalMeasure.java | 30 +-
.../adapters/netio/model/NetioPowerOutput.java | 30 +-
.../trafficcamera/CameraDataHttpExecutor.java | 0
.../trafficcamera/CameraFeatureTransformer.java | 0
.../trafficcamera/CameraInfoHttpExecutor.java | 0
.../trafficcamera/NswTrafficCameraAdapter.java | 11 +-
.../trafficcamera/TrafficCameraSensorNames.java | 0
.../nswaustralia/trafficcamera/model/Feature.java | 0
.../trafficcamera/model/FeatureCollection.java | 0
.../nswaustralia/trafficcamera/model/Geometry.java | 0
.../trafficcamera/model/Properties.java | 0
.../nswaustralia/trafficcamera/model/Rights.java | 0
.../connect/adapters/opcua/OpcNode.java | 0
.../streampipes/connect/adapters/opcua/OpcUa.java | 0
.../connect/adapters/opcua/OpcUaAdapter.java | 44 ++-
.../connect/adapters/opcua/OpcUaTypes.java | 0
.../adapters/plc4x/modbus/ModbusConfigFile.java} | 85 ++---
.../adapters/plc4x/modbus/Plc4xModbusAdapter.java | 343 ++++++++++++++++++
.../plc4x/passive/Plc4xPassiveAdapter.java | 0
.../connect/adapters/plc4x/s7/Plc4xS7Adapter.java | 389 +++++++++++++++++++++
.../connect/adapters/plc4x/s7/S7ConfigFile.java | 65 ++++
.../connect/adapters/ros/RosBridgeAdapter.java | 0
.../adapters/sensemap/OpenSenseMapAdapter.java | 0
.../connect/adapters/sensemap/SensorNames.java | 0
.../adapters/sensemap/model/CurrentLocation.java | 0
.../connect/adapters/sensemap/model/Geometry.java | 0
.../adapters/sensemap/model/LastMeasurement.java | 0
.../connect/adapters/sensemap/model/Loc.java | 0
.../connect/adapters/sensemap/model/SenseBox.java | 0
.../connect/adapters/sensemap/model/Sensor.java | 0
.../simulator/machine/MachineDataSimulator.java | 155 ++++++++
.../machine/MachineDataSimulatorUtils.java | 152 ++++++++
.../machine/MachineDataStreamAdapter.java | 93 +++++
.../simulator/random}/RandomDataSetAdapter.java | 16 +-
.../simulator/random}/RandomDataSimulator.java | 2 +-
.../random}/RandomDataSimulatorUtils.java | 2 +-
.../simulator/random}/RandomDataStreamAdapter.java | 13 +-
.../connect/adapters/slack/SlackAdapter.java | 10 +-
.../connect/adapters/slack/SlackConsumer.java | 0
.../connect/adapters/ti/TISensorTag.java | 13 +-
.../adapters/wikipedia/WikipediaAdapter.java | 0
.../wikipedia/WikipediaEditedArticlesAdapter.java | 8 +-
.../wikipedia/WikipediaModelConverter.java | 0
.../wikipedia/WikipediaNewArticlesAdapter.java | 9 +-
.../adapters/wikipedia/WikipediaSseConsumer.java | 0
.../connect/adapters/wikipedia/model/Length.java | 0
.../connect/adapters/wikipedia/model/Meta.java | 0
.../connect/adapters/wikipedia/model/Revision.java | 0
.../adapters/wikipedia/model/WikipediaModel.java | 0
.../streampipes/connect/config/ConfigKeys.java | 0
.../connect/config/ConnectWorkerConfig.java | 0
.../connect/protocol/set/FileProtocol.java | 72 ++--
.../connect/protocol/set/HttpProtocol.java | 9 +-
.../connect/protocol/stream/BrokerProtocol.java | 0
.../protocol/stream/FileStreamProtocol.java | 93 +++--
.../connect/protocol/stream/HDFSProtocol.java | 0
.../protocol/stream/HttpStreamProtocol.java | 12 +-
.../connect/protocol/stream/KafkaProtocol.java | 23 +-
.../connect/protocol/stream/MqttConfig.java | 0
.../connect/protocol/stream/MqttConsumer.java | 0
.../connect/protocol/stream/MqttProtocol.java | 0
.../connect/protocol/stream/PullProtocol.java | 0
.../connect/protocol/stream/WebsocketClient.java | 0
.../connect/protocol/stream/WebsocketProtocol.java | 0
.../protocol/stream/pulsar/PulsarConsumer.java | 0
.../protocol/stream/pulsar/PulsarProtocol.java | 16 +-
.../protocol/stream/pulsar/PulsarUtils.java | 0
.../connect/utils/MqttConnectUtils.java | 30 +-
.../documentation.md | 20 +-
.../icon.png | Bin 0 -> 17868 bytes
.../strings.en | 6 +
.../documentation.md | 24 +-
.../icon.png | Bin 0 -> 24457 bytes
.../strings.en | 4 +-
.../documentation.md | 7 +-
.../icon.png | Bin 0 -> 33450 bytes
.../strings.en | 4 +
.../documentation.md | 20 +-
.../icon.png | Bin 0 -> 15675 bytes
.../strings.en | 8 +
.../documentation.md | 21 +-
.../icon.png | Bin 0 -> 15675 bytes
.../strings.en | 8 +
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 5332 bytes
.../strings.en | 8 +
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 5332 bytes
.../strings.en | 8 +
.../documentation.md | 8 +-
.../icon.png | Bin
.../strings.en | 23 ++
.../documentation.md | 8 +-
.../icon.png | Bin
.../strings.en | 26 ++
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 99909 bytes
.../strings.en | 23 ++
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 99909 bytes
.../strings.en | 24 ++
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 3016 bytes
.../strings.en | 6 +
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 5087 bytes
.../strings.en | 28 ++
.../documentation.md | 0
.../icon.png | Bin 0 -> 46022 bytes
.../strings.en | 45 +++
.../documentation.md | 0
.../icon.png | Bin 0 -> 46022 bytes
.../strings.en | 38 ++
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 13 +-
.../icon.png | Bin 0 -> 31009 bytes
.../strings.en | 8 +
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 13079 bytes
.../strings.en | 9 +
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 13079 bytes
.../strings.en | 6 +
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 17473 bytes
.../strings.en | 6 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 65221 bytes
.../strings.en | 3 +
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 65221 bytes
.../strings.en | 3 +
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 12881 bytes
.../strings.en | 12 +
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 17467 bytes
.../strings.en | 10 +
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 9110 bytes
.../strings.en | 13 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 5 +-
.../icon.png | Bin
.../strings.en | 13 +
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 12881 bytes
.../strings.en | 7 +
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 17467 bytes
.../strings.en | 7 +
.../connect/adapters/PullAdapterTest.java | 0
.../streampipes/connect/adapters/generic/Mock.java | 0
.../connect/adapters/generic/UtilTest.java | 0
.../generic/elements/AddTimestampTest.java | 0
.../generic/elements/DuplicateFilterTest.java | 0
.../generic/protocol/set/HttpProtocolTest.java | 0
.../generic/protocol/stream/HttpProtocolTest.java | 0
.../adapters/sensemap/OpenSenseMapAdapterTest.java | 0
.../connect/adapters/sensemap/SensorNamesTest.java | 0
.../connect/adapters/ti/TISensorTagTest.java | 35 +-
.../streampipes-connect-adapter/pom.xml | 165 ---------
.../adapters/netio/model/NetioAllPowerOutputs.java | 48 ---
.../connect/adapters/plc4x/s7/Plc4xS7Adapter.java | 289 ---------------
.../Dockerfile | 2 +-
.../aarch64.Dockerfile | 5 +-
.../arm.Dockerfile | 2 +-
.../development/env | 4 +-
.../pom.xml | 49 +--
.../pe/flink/AllFlinkPipelineElementsInit.java | 103 ++++++
.../apache/streampipes/pe/flink/config/Config.java | 60 ++--
.../streampipes/pe/flink/config/ConfigKeys.java | 15 +-
streampipes-pipeline-elements-all-jvm/Dockerfile | 7 +-
streampipes-pipeline-elements-all-jvm/pom.xml | 24 +-
.../pe/jvm/AllPipelineElementsInit.java | 26 ++
.../pom.xml | 2 +-
streampipes-pipeline-elements-shared/pom.xml | 2 +-
streampipes-processors-aggregation-flink/pom.xml | 3 +-
.../aggregation/AggregationController.java | 10 +-
streampipes-processors-enricher-flink/pom.xml | 2 +-
streampipes-processors-enricher-jvm/Dockerfile | 2 +-
streampipes-processors-enricher-jvm/pom.xml | 2 +-
.../processors/enricher/jvm/EnricherJvmInit.java | 33 +-
.../processors/enricher/jvm/config/ConfigKeys.java | 13 +-
.../enricher/jvm/config/EnricherJvmConfig.java | 14 +-
.../enricher/jvm/processor/jseval/JSEval.java | 76 ++++
.../jvm/processor/jseval/JSEvalController.java | 61 ++++
.../jvm/processor/jseval/JSEvalParameters.java | 16 +-
.../jvm/processor/sizemeasure/SizeMeasure.java | 29 +-
.../sizemeasure/SizeMeasureController.java | 29 +-
.../sizemeasure/SizeMeasureParameters.java | 29 +-
.../documentation.md | 35 +-
.../icon.png | Bin 0 -> 622 bytes
.../strings.en | 5 +
streampipes-processors-filters-jvm/pom.xml | 6 +-
.../processors/filters/jvm/FiltersJvmInit.java | 4 +-
.../filters/jvm/processor/limit/RateLimit.java | 75 ++++
.../jvm/processor/limit/RateLimitController.java | 108 ++++++
.../jvm/processor/limit/RateLimitParameters.java | 66 ++++
.../jvm/processor/limit/util/EventSelection.java | 9 +-
.../jvm/processor/limit/util/ProcessJob.java | 15 +-
.../jvm/processor/limit/util/SchedulerUtil.java | 58 +++
.../jvm/processor/limit/util/WindowFactory.java | 54 +++
.../jvm/processor/limit/util/WindowType.java | 9 +-
.../jvm/processor/limit/window/CronWindow.java | 46 +++
.../jvm/processor/limit/window/LengthWindow.java | 78 +++++
.../jvm/processor/limit/window/ScheduleWindow.java | 114 ++++++
.../jvm/processor/limit/window/TimeWindow.java | 46 +++
.../filters/jvm/processor/limit/window/Window.java | 15 +-
.../filters/jvm/processor/merge/StreamBuffer.java | 30 +-
.../documentation.md | 64 ++++
.../icon.png | Bin 0 -> 3534 bytes
.../strings.en | 32 ++
streampipes-processors-filters-siddhi/pom.xml | 2 +-
.../processors/siddhi/FiltersSiddhiInit.java | 10 +-
...{NumericalOperator.java => FilterOperator.java} | 4 +-
.../processors/siddhi/filter/NumericalFilter.java | 35 +-
.../siddhi/filter/NumericalFilterController.java | 11 +-
.../siddhi/filter/NumericalFilterParameters.java | 12 +-
.../processors/siddhi/stop/StreamStop.java | 5 +-
.../documentation.md | 23 +-
.../strings.en | 2 +-
.../siddhi/trend/TestTrendProcessor.java | 5 +
streampipes-processors-geo-flink/pom.xml | 2 +-
streampipes-processors-geo-jvm/development/env | 4 +-
streampipes-processors-geo-jvm/pom.xml | 2 +-
.../streampipes/processors/geo/jvm/GeoJvmInit.java | 20 +-
.../geo/jvm/jts/helper/SpGeometryBuilder.java | 73 ++--
.../geo/jvm/jts/helper/SpTrajectoryBuilder.java | 105 ++++++
.../jvm/jts/processor/latLngToGeo/LatLngToGeo.java | 60 ++--
.../latLngToGeo/LatLngToGeoController.java | 109 +++---
.../latLngToGeo/LatLngToGeoParameter.java | 36 +-
.../geo/jvm/jts/processor/setEPSG/SetEPSG.java | 33 +-
.../jts/processor/setEPSG/SetEpsgController.java | 73 ++--
.../jts/processor/setEPSG/SetEpsgParameter.java | 16 +-
.../trajectory/CreateTrajectoryFromPoints.java | 80 +++++
.../CreateTrajectoryFromPointsController.java | 116 ++++++
.../CreateTrajectoryFromPointsParameter.java} | 63 ++--
.../documentation.md | 12 +-
.../icon.png | Bin 19124 -> 20621 bytes
.../strings.en | 10 +-
.../icon.png | Bin 4831 -> 8710 bytes
.../strings.en | 9 +-
.../documentation.md | 77 ++++
.../icon.png | Bin 0 -> 9399 bytes
.../strings.en | 20 ++
.../Dockerfile | 5 +-
.../pom.xml | 2 +-
.../jvm/processor/commons/ImageTransformer.java | 18 +-
.../jvm/processor/commons/RequiredBoxStream.java | 1 +
.../GenericImageClassification.java | 7 +-
.../GenericImageClassificationController.java | 2 +-
.../processor/imageenrichment/BoxCoordinates.java | 28 ++
.../jvm/processor/imageenrichment/ColorUtil.java | 44 ++-
.../processor/imageenrichment/ImageEnricher.java | 29 +-
.../imageenrichment/ImageEnrichmentController.java | 3 +-
.../imageenrichment/ImageEnrichmentParameters.java | 22 +-
.../documentation.md | 5 +-
.../pom.xml | 2 +-
streampipes-processors-statistics-flink/pom.xml | 2 +-
streampipes-processors-text-mining-flink/pom.xml | 2 +-
streampipes-processors-text-mining-jvm/pom.xml | 2 +-
.../Dockerfile | 4 +-
.../aarch64.Dockerfile | 4 +-
.../arm.Dockerfile | 4 +-
.../development/env | 2 +-
.../pom.xml | 2 +-
.../flink/config/TransformationFlinkConfig.java | 2 +-
streampipes-processors-transformation-jvm/pom.xml | 2 +-
.../transformation/jvm/TransformationJvmInit.java | 18 +-
.../jvm/processor/array/split/SplitArray.java | 2 +-
.../array/split/SplitArrayController.java | 14 +-
.../booloperator/edge/SignalEdgeFilter.java | 121 +++++++
.../edge/SignalEdgeFilterController.java | 77 ++++
.../edge/SignalEdgeFilterParameters.java | 72 ++++
.../booloperator/state/BooleanToState.java | 66 ++++
.../state/BooleanToStateController.java | 44 +--
.../state/BooleanToStateParameters.java | 32 +-
.../CsvMetadataEnrichmentController.java | 11 +-
.../jvm/processor/state/buffer/StateBuffer.java | 94 +++++
.../state/buffer/StateBufferController.java | 87 +++++
.../state/buffer/StateBufferParameters.java | 61 ++++
.../state/labeler/buffer/StateBufferLabeler.java | 86 +++++
.../buffer/StateBufferLabelerController.java | 131 +++++++
.../buffer/StateBufferLabelerParameters.java | 109 ++++++
.../processor/state/labeler/model/Statement.java | 43 +--
.../state/labeler/model/StatementUtils.java | 146 ++++++++
.../state/labeler/number/NumberLabeler.java | 69 ++++
.../labeler/number/NumberLabelerController.java | 118 +++++++
.../labeler/number/NumberLabelerParameters.java | 73 ++++
.../stringoperator/counter/StringCounter.java | 79 +++++
.../counter/StringCounterController.java | 71 ++++
.../counter/StringCounterParameters.java | 17 +-
.../stringoperator/state/StringToState.java | 45 +--
.../state/StringToStateController.java | 40 +--
.../state/StringToStateParameters.java | 21 +-
.../stringoperator/timer/StringTimer.java | 72 ++++
.../timer/StringTimerController.java | 83 +++++
.../timer/StringTimerParameters.java | 23 +-
.../transformtoboolean/TransformToBoolean.java | 13 +-
.../TransformToBooleanController.java | 13 +-
.../TransformToBooleanParameters.java | 13 +-
.../documentation.md | 2 +-
.../strings.en | 3 +
.../documentation.md | 33 +-
.../icon.png | Bin 0 -> 7919 bytes
.../strings.en | 15 +
.../documentation.md | 31 +-
.../icon.png | Bin 0 -> 12518 bytes
.../strings.en | 14 +
.../documentation.md | 32 +-
.../icon.png | Bin 0 -> 9466 bytes
.../strings.en | 18 +
.../documentation.md | 63 ++++
.../icon.png | Bin 0 -> 10162 bytes
.../strings.en | 29 ++
.../documentation.md | 30 +-
.../icon.png | Bin 0 -> 8629 bytes
.../strings.en | 29 ++
.../documentation.md | 29 +-
.../icon.png | Bin 0 -> 12174 bytes
.../strings.en | 11 +
.../documentation.md | 33 +-
.../icon.png | Bin 0 -> 16458 bytes
.../strings.en | 16 +
.../documentation.md | 30 +-
.../icon.png | Bin 0 -> 14398 bytes
.../strings.en | 17 +
streampipes-sinks-brokers-jvm/pom.xml | 4 +-
streampipes-sinks-databases-flink/pom.xml | 2 +-
streampipes-sinks-databases-jvm/pom.xml | 21 +-
.../sinks/databases/jvm/DatabasesJvmInit.java | 6 +-
.../sinks/databases/jvm/jdbcclient/JdbcClient.java | 3 +-
.../sinks/databases/jvm/mysql/Column.java | 76 ++++
.../sinks/databases/jvm/mysql/Mysql.java | 269 ++++++++++++++
.../sinks/databases/jvm/mysql/MysqlController.java | 75 ++++
.../sinks/databases/jvm/mysql/MysqlParameters.java | 66 ++++
.../sinks/databases/jvm/opcua/OpcUa.java | 18 +-
.../sinks/databases/jvm/redis/Redis.java | 119 +++++++
.../sinks/databases/jvm/redis/RedisController.java | 103 ++++++
.../sinks/databases/jvm/redis/RedisParameters.java | 114 ++++++
.../documentation.md | 31 +-
.../icon.png | Bin 0 -> 6477 bytes
.../strings.en | 21 ++
.../documentation.md | 81 +++++
.../icon.png | Bin 0 -> 12905 bytes
.../strings.en | 38 ++
streampipes-sinks-internal-jvm/pom.xml | 2 +-
.../sinks/internal/jvm/config/ConfigKeys.java | 5 +-
.../jvm/config/SinksInternalJvmConfig.java | 32 +-
.../sinks/internal/jvm/datalake/DataLake.java | 27 +-
.../internal/jvm/datalake/DataLakeController.java | 10 +-
.../jvm/datalake/DataLakeInfluxDbClient.java | 33 +-
streampipes-sinks-notifications-jvm/pom.xml | 6 +-
.../jvm/SinksNotificationsJvmInit.java | 4 +-
.../jvm/telegram/TelegramController.java | 65 ++++
.../jvm/telegram/TelegramParameters.java | 58 ++-
.../jvm/telegram/TelegramPublisher.java | 94 +++++
.../documentation.md | 26 +-
.../icon.png | Bin 0 -> 6844 bytes
.../strings.en | 11 +
streampipes-sources-vehicle-simulator/pom.xml | 4 +-
streampipes-sources-watertank-simulator/pom.xml | 4 +-
tools/maven/assembly.xml | 82 +++++
461 files changed, 9251 insertions(+), 2354 deletions(-)
create mode 100644 .github/PULL_REQUEST_TEMPLATE.md
create mode 100644 .idea/runConfigurations/all_pipeline_elements_flink.xml
create mode 100644 .idea/runConfigurations/all_pipeline_elements_jvm.xml
create mode 100644 .idea/runConfigurations/connect_adapters.xml
create mode 100644 .idea/runConfigurations/processors_aggregation_flink.xml
create mode 100644 .idea/runConfigurations/processors_enricher_flink.xml
create mode 100644 .idea/runConfigurations/processors_enricher_jvm.xml
create mode 100644 .idea/runConfigurations/processors_filters_jvm.xml
create mode 100644 .idea/runConfigurations/processors_filters_siddhi.xml
create mode 100644 .idea/runConfigurations/processors_geo_flink.xml
create mode 100644 .idea/runConfigurations/processors_geo_jvm.xml
create mode 100644 .idea/runConfigurations/processors_imageprocessing_jvm.xml
create mode 100644 .idea/runConfigurations/processors_pattern_detection_flink.xml
create mode 100644 .idea/runConfigurations/processors_statistics_flink.xml
create mode 100644 .idea/runConfigurations/processors_textmining_flink.xml
create mode 100644 .idea/runConfigurations/processors_textmining_jvm.xml
create mode 100644 .idea/runConfigurations/processors_transformation_flink.xml
create mode 100644 .idea/runConfigurations/processors_transformation_jvm.xml
create mode 100644 .idea/runConfigurations/sinks_brokers_jvm.xml
create mode 100644 .idea/runConfigurations/sinks_databases_flink.xml
create mode 100644 .idea/runConfigurations/sinks_databases_jvm.xml
create mode 100644 .idea/runConfigurations/sinks_internal_jvm.xml
create mode 100644 .idea/runConfigurations/sinks_notifications_jvm.xml
create mode 100644 .idea/runConfigurations/sources_vehicle_simulator_jvm.xml
create mode 100644 .idea/runConfigurations/sources_watertank_simulator_jvm.xml
copy streampipes-connect-adapters/streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest/documentation.md => CONTRIBUTING.md (56%)
create mode 100644 DISCLAIMER
delete mode 100644 DISCLAIMER-WIP
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/Dockerfile (86%)
delete mode 100644 streampipes-connect-adapters/README.md
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/aarch64.Dockerfile (86%)
copy streampipes-connect-adapters/{streampipes-connect-adapter => }/arm.Dockerfile (90%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/ConnectAdapterInit.java (84%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/PullAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/PullRestAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/CoindeskBitcoinAdapter.java (90%)
copy streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/Currency.java (100%)
copy streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Bpi.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/CoindeskRawModel.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/EUR.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/GBP.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Time.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/USD.java (100%)
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioMQTTAdapter.java => src/main/java/org/apache/streampipes/connect/adapters/flic/FlicMQTTAdapter.java} (76%)
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Bpi.java => src/main/java/org/apache/streampipes/connect/adapters/flic/FlicOutput.java} (58%)
create mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicUtils.java
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/gdelt/GdeltAdapter.java (97%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudAdapter.java (89%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudNewsAdapter.java (93%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudStockAdapter.java (90%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iex/model/IexNewsData.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iex/model/IexStockData.java (100%)
create mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/image/ImageZipAdapter.java
copy streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/setEPSG/SetEpsgParameter.java => streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/image/ImageZipUtils.java (59%)
mode change 100755 => 100644
create mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/image/ZipFileImageIterator.java
create mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/image/set/ImageSetAdapter.java
create mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/image/stream/ImageStreamAdapter.java
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/influxdb/InfluxDbClient.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/influxdb/InfluxDbSetAdapter.java (84%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/influxdb/InfluxDbStreamAdapter.java (85%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iss/IssAdapter.java (100%)
copy streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iss/model/IssModel.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iss/model/IssPosition.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/mysql/Column.java (85%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/mysql/MySqlAdapter.java (94%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/mysql/MySqlClient.java (90%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/mysql/MySqlSetAdapter.java (87%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/mysql/MySqlStreamAdapter.java (87%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioMQTTAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioRestAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioUtils.java (90%)
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Bpi.java => src/main/java/org/apache/streampipes/connect/adapters/netio/model/NetioAllPowerOutputs.java} (60%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/netio/model/NetioGlobalMeasure.java (67%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/netio/model/NetioPowerOutput.java (70%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/CameraDataHttpExecutor.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/CameraFeatureTransformer.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/CameraInfoHttpExecutor.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/NswTrafficCameraAdapter.java (94%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/TrafficCameraSensorNames.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/Feature.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/FeatureCollection.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/Geometry.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/Properties.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/Rights.java (100%)
copy streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/opcua/OpcNode.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/opcua/OpcUa.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/opcua/OpcUaAdapter.java (89%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/opcua/OpcUaTypes.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Bpi.java => src/main/java/org/apache/streampipes/connect/adapters/plc4x/modbus/ModbusConfigFile.java} (50%)
create mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/plc4x/modbus/Plc4xModbusAdapter.java
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/plc4x/passive/Plc4xPassiveAdapter.java (100%)
create mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/plc4x/s7/Plc4xS7Adapter.java
create mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/plc4x/s7/S7ConfigFile.java
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/ros/RosBridgeAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/OpenSenseMapAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/SensorNames.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/CurrentLocation.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Geometry.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/LastMeasurement.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Loc.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/SenseBox.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Sensor.java (100%)
create mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/machine/MachineDataSimulator.java
create mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/machine/MachineDataSimulatorUtils.java
create mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/machine/MachineDataStreamAdapter.java
rename streampipes-connect-adapters/{streampipes-connect-adapter/src/main/java/org/apache/streampipes/connect/adapters/simulator => src/main/java/org/apache/streampipes/connect/adapters/simulator/random}/RandomDataSetAdapter.java (85%)
rename streampipes-connect-adapters/{streampipes-connect-adapter/src/main/java/org/apache/streampipes/connect/adapters/simulator => src/main/java/org/apache/streampipes/connect/adapters/simulator/random}/RandomDataSimulator.java (97%)
rename streampipes-connect-adapters/{streampipes-connect-adapter/src/main/java/org/apache/streampipes/connect/adapters/simulator => src/main/java/org/apache/streampipes/connect/adapters/simulator/random}/RandomDataSimulatorUtils.java (96%)
rename streampipes-connect-adapters/{streampipes-connect-adapter/src/main/java/org/apache/streampipes/connect/adapters/simulator => src/main/java/org/apache/streampipes/connect/adapters/simulator/random}/RandomDataStreamAdapter.java (88%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/slack/SlackAdapter.java (92%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/slack/SlackConsumer.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/ti/TISensorTag.java (94%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaEditedArticlesAdapter.java (88%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaModelConverter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaNewArticlesAdapter.java (88%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaSseConsumer.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Length.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Meta.java (100%)
copy streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Revision.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/WikipediaModel.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/config/ConfigKeys.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/config/ConnectWorkerConfig.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/set/FileProtocol.java (77%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/set/HttpProtocol.java (94%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/BrokerProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/FileStreamProtocol.java (72%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/HDFSProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/HttpStreamProtocol.java (93%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/KafkaProtocol.java (92%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/MqttConfig.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/MqttConsumer.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/MqttProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/PullProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/WebsocketClient.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/WebsocketProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/pulsar/PulsarConsumer.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/pulsar/PulsarProtocol.java (91%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/pulsar/PulsarUtils.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/utils/MqttConnectUtils.java (78%)
copy {streampipes-processors-filters-siddhi/src/main/resources/org.apache.streampipes.processors.siddhi.numericalfilter => streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.coindesk}/documentation.md (84%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.coindesk/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.coindesk/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.ti => src/main/resources/org.apache.streampipes.connect.adapters.flic.mqtt}/documentation.md (73%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.flic.mqtt/icon.png
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.ti => src/main/resources/org.apache.streampipes.connect.adapters.flic.mqtt}/strings.en (76%)
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.gdelt}/documentation.md (86%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.gdelt/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.gdelt/strings.en
copy {streampipes-processors-filters-siddhi/src/main/resources/org.apache.streampipes.processors.siddhi.numericalfilter => streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news}/documentation.md (76%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news/strings.en
copy {streampipes-processors-filters-siddhi/src/main/resources/org.apache.streampipes.processors.siddhi.numericalfilter => streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks}/documentation.md (76%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.image.set}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.image.set/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.image.set/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.image.stream}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.image.stream/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.image.stream/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.influxdb.set}/documentation.md (89%)
copy {streampipes-sinks-databases-jvm/src/main/resources/org.apache.streampipes.sinks.databases.jvm.influxdb => streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.influxdb.set}/icon.png (100%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.influxdb.set/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.influxdb.stream}/documentation.md (89%)
copy {streampipes-sinks-databases-jvm/src/main/resources/org.apache.streampipes.sinks.databases.jvm.influxdb => streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.influxdb.stream}/icon.png (100%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.influxdb.stream/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.iss/documentation.md (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.iss/icon.png (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.iss/strings.en (100%)
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.mysql.set}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.mysql.set/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.mysql.set/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.mysql.stream}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.mysql.stream/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.mysql.stream/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest => src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt}/documentation.md (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest => src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt}/icon.png (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt/strings.en (100%)
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt => src/main/resources/org.apache.streampipes.connect.adapters.netio.rest}/documentation.md (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt => src/main/resources/org.apache.streampipes.connect.adapters.netio.rest}/icon.png (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest/strings.en (100%)
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.opcua}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.opcua/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.opcua/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.plc4x.modbus}/documentation.md (100%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.plc4x.modbus/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.plc4x.modbus/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.plc4x.s7}/documentation.md (100%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.plc4x.s7/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.plc4x.s7/strings.en
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.ros/documentation.md (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.ros/icon.png (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.ros/strings.en (100%)
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.simulator.machine}/documentation.md (84%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.machine/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.machine/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.simulator.randomdataset}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.randomdataset/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.randomdataset/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.simulator.randomdatastream}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.randomdatastream/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.randomdatastream/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.slack}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.slack/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.slack/strings.en
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.ti/documentation.md (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.ti/icon.png (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.ti/strings.en (100%)
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.wikipedia.edit}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.wikipedia.edit/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.wikipedia.edit/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.adapters.wikipedia.new}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.wikipedia.new/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.wikipedia.new/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.protocol.stream.file}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.file/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.file/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.protocol.stream.http}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.http/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.http/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.protocol.stream.kafka}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.kafka/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.kafka/strings.en
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.protocol.stream.mqtt/documentation.md (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.protocol.stream.mqtt/icon.png (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.protocol.stream.mqtt/strings.en (100%)
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.connect.protocol.stream.pulsar}/documentation.md (89%)
copy {streampipes-sinks-brokers-jvm/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.pulsar => streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.pulsar}/icon.png (100%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.pulsar/strings.en
copy streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.protocol.set.file}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.protocol.set.file/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.protocol.set.file/strings.en
rename streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.iss => src/main/resources/org.apache.streampipes.protocol.set.http}/documentation.md (89%)
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.protocol.set.http/icon.png
create mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.protocol.set.http/strings.en
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/PullAdapterTest.java (100%)
copy streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/generic/Mock.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/generic/UtilTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/generic/elements/AddTimestampTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/generic/elements/DuplicateFilterTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/generic/protocol/set/HttpProtocolTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/generic/protocol/stream/HttpProtocolTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/sensemap/OpenSenseMapAdapterTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/sensemap/SensorNamesTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/ti/TISensorTagTest.java (66%)
delete mode 100644 streampipes-connect-adapters/streampipes-connect-adapter/pom.xml
delete mode 100644 streampipes-connect-adapters/streampipes-connect-adapter/src/main/java/org/apache/streampipes/connect/adapters/netio/model/NetioAllPowerOutputs.java
delete mode 100644 streampipes-connect-adapters/streampipes-connect-adapter/src/main/java/org/apache/streampipes/connect/adapters/plc4x/s7/Plc4xS7Adapter.java
copy {streampipes-processors-enricher-jvm => streampipes-pipeline-elements-all-flink}/Dockerfile (90%)
copy streampipes-processors-image-processing-jvm/Dockerfile => streampipes-pipeline-elements-all-flink/aarch64.Dockerfile (83%)
rename {streampipes-connect-adapters/streampipes-connect-adapter => streampipes-pipeline-elements-all-flink}/arm.Dockerfile (90%)
copy {streampipes-processors-transformation-flink => streampipes-pipeline-elements-all-flink}/development/env (96%)
copy {streampipes-processors-statistics-flink => streampipes-pipeline-elements-all-flink}/pom.xml (75%)
create mode 100644 streampipes-pipeline-elements-all-flink/src/main/java/org/apache/streampipes/pe/flink/AllFlinkPipelineElementsInit.java
copy streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/config/TransformationFlinkConfig.java => streampipes-pipeline-elements-all-flink/src/main/java/org/apache/streampipes/pe/flink/config/Config.java (52%)
rename streampipes-connect-adapters/streampipes-connect-adapter/src/main/java/org/apache/streampipes/connect/adapters/coindesk/Currency.java => streampipes-pipeline-elements-all-flink/src/main/java/org/apache/streampipes/pe/flink/config/ConfigKeys.java (68%)
create mode 100644 streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/jseval/JSEval.java
create mode 100644 streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/jseval/JSEvalController.java
copy streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/setEPSG/SetEpsgParameter.java => streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/jseval/JSEvalParameters.java (73%)
mode change 100755 => 100644
copy {streampipes-connect-adapters/streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt => streampipes-processors-enricher-jvm/src/main/resources/org.apache.streampipes.processors.enricher.jvm.jseval}/documentation.md (59%)
create mode 100644 streampipes-processors-enricher-jvm/src/main/resources/org.apache.streampipes.processors.enricher.jvm.jseval/icon.png
create mode 100644 streampipes-processors-enricher-jvm/src/main/resources/org.apache.streampipes.processors.enricher.jvm.jseval/strings.en
create mode 100644 streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/RateLimit.java
create mode 100644 streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/RateLimitController.java
create mode 100644 streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/RateLimitParameters.java
copy streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/filter/NumericalOperator.java => streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/util/EventSelection.java (85%)
copy streampipes-connect-adapters/streampipes-connect-adapter/src/test/java/org/apache/streampipes/connect/adapters/generic/Mock.java => streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/util/ProcessJob.java (60%)
create mode 100644 streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/util/SchedulerUtil.java
create mode 100644 streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/util/WindowFactory.java
copy streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/filter/NumericalOperator.java => streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/util/WindowType.java (85%)
create mode 100644 streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/window/CronWindow.java
create mode 100644 streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/window/LengthWindow.java
create mode 100644 streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/window/ScheduleWindow.java
create mode 100644 streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/window/TimeWindow.java
rename streampipes-connect-adapters/streampipes-connect-adapter/src/test/java/org/apache/streampipes/connect/adapters/generic/Mock.java => streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/window/Window.java (67%)
create mode 100644 streampipes-processors-filters-jvm/src/main/resources/org.apache.streampipes.processors.filters.jvm.limit/documentation.md
create mode 100644 streampipes-processors-filters-jvm/src/main/resources/org.apache.streampipes.processors.filters.jvm.limit/icon.png
create mode 100644 streampipes-processors-filters-jvm/src/main/resources/org.apache.streampipes.processors.filters.jvm.limit/strings.en
rename streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/filter/{NumericalOperator.java => FilterOperator.java} (94%)
create mode 100644 streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/helper/SpTrajectoryBuilder.java
create mode 100755 streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/CreateTrajectoryFromPoints.java
create mode 100755 streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/CreateTrajectoryFromPointsController.java
copy streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/{latLngToGeo/LatLngToGeoParameter.java => trajectory/CreateTrajectoryFromPointsParameter.java} (56%)
create mode 100644 streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory/documentation.md
create mode 100644 streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory/icon.png
create mode 100644 streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory/strings.en
rename streampipes-connect-adapters/streampipes-connect-adapter/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Revision.java => streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/imageenrichment/ColorUtil.java (54%)
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/edge/SignalEdgeFilter.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/edge/SignalEdgeFilterController.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/edge/SignalEdgeFilterParameters.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/state/BooleanToState.java
copy streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassificationController.java => streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/state/BooleanToStateController.java (51%)
copy streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/latLngToGeo/LatLngToGeoParameter.java => streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/state/BooleanToStateParameters.java (55%)
mode change 100755 => 100644
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/buffer/StateBuffer.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/buffer/StateBufferController.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/buffer/StateBufferParameters.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/buffer/StateBufferLabeler.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/buffer/StateBufferLabelerController.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/buffer/StateBufferLabelerParameters.java
rename streampipes-connect-adapters/streampipes-connect-adapter/src/main/java/org/apache/streampipes/connect/adapters/opcua/OpcNode.java => streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/model/Statement.java (57%)
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/model/StatementUtils.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/number/NumberLabeler.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/number/NumberLabelerController.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/number/NumberLabelerParameters.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/StringCounter.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/StringCounterController.java
copy streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/setEPSG/SetEpsgParameter.java => streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/StringCounterParameters.java (69%)
mode change 100755 => 100644
copy streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/setEPSG/SetEPSG.java => streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/StringToState.java (51%)
mode change 100755 => 100644
copy streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassificationController.java => streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/StringToStateController.java (53%)
copy streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/setEPSG/SetEpsgParameter.java => streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/StringToStateParameters.java (64%)
mode change 100755 => 100644
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/StringTimer.java
create mode 100644 streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/StringTimerController.java
copy streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/setEPSG/SetEpsgParameter.java => streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/StringTimerParameters.java (64%)
mode change 100755 => 100644
copy {streampipes-connect-adapters/streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest => streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.edge}/documentation.md (65%)
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.edge/icon.png
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.edge/strings.en
copy {streampipes-connect-adapters/streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest => streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.state}/documentation.md (64%)
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.state/icon.png
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.booloperator.state/strings.en
copy {streampipes-connect-adapters/streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest => streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.state.buffer}/documentation.md (64%)
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.state.buffer/icon.png
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.state.buffer/strings.en
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.buffer/documentation.md
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.buffer/icon.png
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.buffer/strings.en
copy {streampipes-connect-adapters/streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest => streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.number}/documentation.md (63%)
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.number/icon.png
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.number/strings.en
copy {streampipes-connect-adapters/streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt => streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.state}/documentation.md (71%)
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.state/icon.png
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.state/strings.en
copy {streampipes-connect-adapters/streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest => streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter}/documentation.md (56%)
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter/icon.png
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.stringoperator.counter/strings.en
copy {streampipes-connect-adapters/streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest => streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer}/documentation.md (63%)
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer/icon.png
create mode 100644 streampipes-processors-transformation-jvm/src/main/resources/org.apache.streampipes.processors.transformation.jvm.stringoperator.timer/strings.en
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/mysql/Column.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/mysql/Mysql.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/mysql/MysqlController.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/mysql/MysqlParameters.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/redis/Redis.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/redis/RedisController.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/redis/RedisParameters.java
rename {streampipes-connect-adapters/streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt => streampipes-sinks-databases-jvm/src/main/resources/org.apache.streampipes.sinks.databases.jvm.mysql}/documentation.md (72%)
create mode 100644 streampipes-sinks-databases-jvm/src/main/resources/org.apache.streampipes.sinks.databases.jvm.mysql/icon.png
create mode 100644 streampipes-sinks-databases-jvm/src/main/resources/org.apache.streampipes.sinks.databases.jvm.mysql/strings.en
create mode 100644 streampipes-sinks-databases-jvm/src/main/resources/org.apache.streampipes.sinks.databases.jvm.redis/documentation.md
create mode 100644 streampipes-sinks-databases-jvm/src/main/resources/org.apache.streampipes.sinks.databases.jvm.redis/icon.png
create mode 100644 streampipes-sinks-databases-jvm/src/main/resources/org.apache.streampipes.sinks.databases.jvm.redis/strings.en
create mode 100644 streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/telegram/TelegramController.java
rename streampipes-connect-adapters/streampipes-connect-adapter/src/main/java/org/apache/streampipes/connect/adapters/iss/model/IssModel.java => streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/telegram/TelegramParameters.java (50%)
create mode 100644 streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/telegram/TelegramPublisher.java
rename {streampipes-connect-adapters/streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest => streampipes-sinks-notifications-jvm/src/main/resources/org.apache.streampipes.sinks.notifications.jvm.telegram}/documentation.md (55%)
create mode 100644 streampipes-sinks-notifications-jvm/src/main/resources/org.apache.streampipes.sinks.notifications.jvm.telegram/icon.png
create mode 100644 streampipes-sinks-notifications-jvm/src/main/resources/org.apache.streampipes.sinks.notifications.jvm.telegram/strings.en
create mode 100644 tools/maven/assembly.xml
[incubator-streampipes-extensions] 01/01: Merge tag 'release/0.67.0'
Posted by ze...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
commit d42552c82824bf67c5e447fb4c18b6d7fac03b5a
Merge: 44b7dd1 0ebbb18
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Tue Oct 27 22:08:24 2020 +0100
Merge tag 'release/0.67.0'
[maven-release-plugin] copy for tag release/0.67.0
.github/PULL_REQUEST_TEMPLATE.md | 53 +++
.github/workflows/build.yml | 29 +-
.gitignore | 5 +-
.../all_pipeline_elements_flink.xml | 15 +
.../all_pipeline_elements_jvm.xml | 21 ++
.idea/runConfigurations/connect_adapters.xml | 17 +
.../processors_aggregation_flink.xml | 15 +
.../processors_enricher_flink.xml | 15 +
.../runConfigurations/processors_enricher_jvm.xml | 14 +
.idea/runConfigurations/processors_filters_jvm.xml | 14 +
.../processors_filters_siddhi.xml | 14 +
.idea/runConfigurations/processors_geo_flink.xml | 15 +
.idea/runConfigurations/processors_geo_jvm.xml | 14 +
.../processors_imageprocessing_jvm.xml | 14 +
.../processors_pattern_detection_flink.xml | 15 +
.../processors_statistics_flink.xml | 15 +
.../processors_textmining_flink.xml | 15 +
.../processors_textmining_jvm.xml | 14 +
.../processors_transformation_flink.xml | 15 +
.../processors_transformation_jvm.xml | 14 +
.idea/runConfigurations/sinks_brokers_jvm.xml | 14 +
.idea/runConfigurations/sinks_databases_flink.xml | 16 +
.idea/runConfigurations/sinks_databases_jvm.xml | 14 +
.idea/runConfigurations/sinks_internal_jvm.xml | 22 ++
.../runConfigurations/sinks_notifications_jvm.xml | 23 ++
.../sources_vehicle_simulator_jvm.xml | 16 +
.../sources_watertank_simulator_jvm.xml | 16 +
.spignore | 9 +-
.../documentation.md => CONTRIBUTING.md | 46 +--
DISCLAIMER | 5 +
DISCLAIMER-WIP | 8 -
NOTICE | 5 +-
README.md | 67 ++--
RELEASE_NOTES.md | 40 ++-
docker-compose.yml | 49 ++-
pom.xml | 305 +++++++++++++++-
.../{streampipes-connect-adapter => }/Dockerfile | 4 +-
streampipes-connect-adapters/README.md | 90 -----
.../aarch64.Dockerfile | 4 +-
.../arm.Dockerfile | 4 +-
streampipes-connect-adapters/pom.xml | 174 ++++-----
.../streampipes/connect/ConnectAdapterInit.java | 18 +-
.../streampipes/connect/adapters/PullAdapter.java | 0
.../connect/adapters/PullRestAdapter.java | 0
.../adapters/coindesk/CoindeskBitcoinAdapter.java | 14 +-
.../connect/adapters/coindesk/Currency.java | 0
.../connect/adapters/coindesk/model/Bpi.java | 0
.../adapters/coindesk/model/CoindeskRawModel.java | 0
.../connect/adapters/coindesk/model/EUR.java | 0
.../connect/adapters/coindesk/model/GBP.java | 0
.../connect/adapters/coindesk/model/Time.java | 0
.../connect/adapters/coindesk/model/USD.java | 0
.../connect/adapters/flic/FlicMQTTAdapter.java} | 49 +--
.../connect/adapters/flic/FlicOutput.java} | 48 ++-
.../connect/adapters/flic/FlicUtils.java | 74 ++++
.../connect/adapters/gdelt/GdeltAdapter.java | 10 +-
.../connect/adapters/iex/IexCloudAdapter.java | 7 +-
.../connect/adapters/iex/IexCloudNewsAdapter.java | 13 +-
.../connect/adapters/iex/IexCloudStockAdapter.java | 12 +-
.../connect/adapters/iex/model/IexNewsData.java | 0
.../connect/adapters/iex/model/IexStockData.java | 0
.../connect/adapters/image/ImageZipAdapter.java | 100 ++++++
.../connect/adapters/image/ImageZipUtils.java | 23 +-
.../adapters/image/ZipFileImageIterator.java | 103 ++++++
.../adapters/image/set/ImageSetAdapter.java | 99 ++++++
.../adapters/image/stream/ImageStreamAdapter.java | 97 +++++
.../connect/adapters/influxdb/InfluxDbClient.java | 0
.../adapters/influxdb/InfluxDbSetAdapter.java | 26 +-
.../adapters/influxdb/InfluxDbStreamAdapter.java | 28 +-
.../connect/adapters/iss/IssAdapter.java | 0
.../connect/adapters/iss/model/IssModel.java | 0
.../connect/adapters/iss/model/IssPosition.java | 0
.../streampipes/connect/adapters/mysql/Column.java | 16 +-
.../connect/adapters/mysql/MySqlAdapter.java | 20 +-
.../connect/adapters/mysql/MySqlClient.java | 19 +-
.../connect/adapters/mysql/MySqlSetAdapter.java | 24 +-
.../connect/adapters/mysql/MySqlStreamAdapter.java | 23 +-
.../connect/adapters/netio/NetioMQTTAdapter.java | 0
.../connect/adapters/netio/NetioRestAdapter.java | 0
.../connect/adapters/netio/NetioUtils.java | 30 +-
.../netio/model/NetioAllPowerOutputs.java} | 42 +--
.../adapters/netio/model/NetioGlobalMeasure.java | 30 +-
.../adapters/netio/model/NetioPowerOutput.java | 30 +-
.../trafficcamera/CameraDataHttpExecutor.java | 0
.../trafficcamera/CameraFeatureTransformer.java | 0
.../trafficcamera/CameraInfoHttpExecutor.java | 0
.../trafficcamera/NswTrafficCameraAdapter.java | 11 +-
.../trafficcamera/TrafficCameraSensorNames.java | 0
.../nswaustralia/trafficcamera/model/Feature.java | 0
.../trafficcamera/model/FeatureCollection.java | 0
.../nswaustralia/trafficcamera/model/Geometry.java | 0
.../trafficcamera/model/Properties.java | 0
.../nswaustralia/trafficcamera/model/Rights.java | 0
.../connect/adapters/opcua/OpcNode.java | 0
.../streampipes/connect/adapters/opcua/OpcUa.java | 0
.../connect/adapters/opcua/OpcUaAdapter.java | 44 ++-
.../connect/adapters/opcua/OpcUaTypes.java | 0
.../adapters/plc4x/modbus/ModbusConfigFile.java} | 85 ++---
.../adapters/plc4x/modbus/Plc4xModbusAdapter.java | 343 ++++++++++++++++++
.../plc4x/passive/Plc4xPassiveAdapter.java | 0
.../connect/adapters/plc4x/s7/Plc4xS7Adapter.java | 389 +++++++++++++++++++++
.../connect/adapters/plc4x/s7/S7ConfigFile.java | 65 ++++
.../connect/adapters/ros/RosBridgeAdapter.java | 0
.../adapters/sensemap/OpenSenseMapAdapter.java | 0
.../connect/adapters/sensemap/SensorNames.java | 0
.../adapters/sensemap/model/CurrentLocation.java | 0
.../connect/adapters/sensemap/model/Geometry.java | 0
.../adapters/sensemap/model/LastMeasurement.java | 0
.../connect/adapters/sensemap/model/Loc.java | 0
.../connect/adapters/sensemap/model/SenseBox.java | 0
.../connect/adapters/sensemap/model/Sensor.java | 0
.../simulator/machine/MachineDataSimulator.java | 155 ++++++++
.../machine/MachineDataSimulatorUtils.java | 152 ++++++++
.../machine/MachineDataStreamAdapter.java | 93 +++++
.../simulator/random}/RandomDataSetAdapter.java | 16 +-
.../simulator/random}/RandomDataSimulator.java | 2 +-
.../random}/RandomDataSimulatorUtils.java | 2 +-
.../simulator/random}/RandomDataStreamAdapter.java | 13 +-
.../connect/adapters/slack/SlackAdapter.java | 10 +-
.../connect/adapters/slack/SlackConsumer.java | 0
.../connect/adapters/ti/TISensorTag.java | 13 +-
.../adapters/wikipedia/WikipediaAdapter.java | 0
.../wikipedia/WikipediaEditedArticlesAdapter.java | 8 +-
.../wikipedia/WikipediaModelConverter.java | 0
.../wikipedia/WikipediaNewArticlesAdapter.java | 9 +-
.../adapters/wikipedia/WikipediaSseConsumer.java | 0
.../connect/adapters/wikipedia/model/Length.java | 0
.../connect/adapters/wikipedia/model/Meta.java | 0
.../connect/adapters/wikipedia/model/Revision.java | 0
.../adapters/wikipedia/model/WikipediaModel.java | 0
.../streampipes/connect/config/ConfigKeys.java | 0
.../connect/config/ConnectWorkerConfig.java | 0
.../connect/protocol/set/FileProtocol.java | 72 ++--
.../connect/protocol/set/HttpProtocol.java | 9 +-
.../connect/protocol/stream/BrokerProtocol.java | 0
.../protocol/stream/FileStreamProtocol.java | 93 +++--
.../connect/protocol/stream/HDFSProtocol.java | 0
.../protocol/stream/HttpStreamProtocol.java | 12 +-
.../connect/protocol/stream/KafkaProtocol.java | 23 +-
.../connect/protocol/stream/MqttConfig.java | 0
.../connect/protocol/stream/MqttConsumer.java | 0
.../connect/protocol/stream/MqttProtocol.java | 0
.../connect/protocol/stream/PullProtocol.java | 0
.../connect/protocol/stream/WebsocketClient.java | 0
.../connect/protocol/stream/WebsocketProtocol.java | 0
.../protocol/stream/pulsar/PulsarConsumer.java | 0
.../protocol/stream/pulsar/PulsarProtocol.java | 16 +-
.../protocol/stream/pulsar/PulsarUtils.java | 0
.../connect/utils/MqttConnectUtils.java | 30 +-
.../documentation.md | 20 +-
.../icon.png | Bin 0 -> 17868 bytes
.../strings.en | 6 +
.../documentation.md | 24 +-
.../icon.png | Bin 0 -> 24457 bytes
.../strings.en | 4 +-
.../documentation.md | 7 +-
.../icon.png | Bin 0 -> 33450 bytes
.../strings.en | 4 +
.../documentation.md | 20 +-
.../icon.png | Bin 0 -> 15675 bytes
.../strings.en | 8 +
.../documentation.md | 21 +-
.../icon.png | Bin 0 -> 15675 bytes
.../strings.en | 8 +
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 5332 bytes
.../strings.en | 8 +
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 5332 bytes
.../strings.en | 8 +
.../documentation.md | 8 +-
.../icon.png | Bin 0 -> 9982 bytes
.../strings.en | 23 ++
.../documentation.md | 8 +-
.../icon.png | Bin 0 -> 9982 bytes
.../strings.en | 26 ++
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 99909 bytes
.../strings.en | 23 ++
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 99909 bytes
.../strings.en | 24 ++
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 3016 bytes
.../strings.en | 6 +
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 5087 bytes
.../strings.en | 28 ++
.../documentation.md | 0
.../icon.png | Bin 0 -> 46022 bytes
.../strings.en | 45 +++
.../documentation.md | 0
.../icon.png | Bin 0 -> 46022 bytes
.../strings.en | 38 ++
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 13 +-
.../icon.png | Bin 0 -> 31009 bytes
.../strings.en | 8 +
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 13079 bytes
.../strings.en | 9 +
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 13079 bytes
.../strings.en | 6 +
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 17473 bytes
.../strings.en | 6 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 65221 bytes
.../strings.en | 3 +
.../documentation.md | 4 +-
.../icon.png | Bin 0 -> 65221 bytes
.../strings.en | 3 +
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 12881 bytes
.../strings.en | 12 +
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 17467 bytes
.../strings.en | 10 +
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 9110 bytes
.../strings.en | 13 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 22890 bytes
.../strings.en | 13 +
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 12881 bytes
.../strings.en | 7 +
.../documentation.md | 5 +-
.../icon.png | Bin 0 -> 17467 bytes
.../strings.en | 7 +
.../connect/adapters/PullAdapterTest.java | 0
.../streampipes/connect/adapters/generic/Mock.java | 0
.../connect/adapters/generic/UtilTest.java | 0
.../generic/elements/AddTimestampTest.java | 0
.../generic/elements/DuplicateFilterTest.java | 0
.../generic/protocol/set/HttpProtocolTest.java | 0
.../generic/protocol/stream/HttpProtocolTest.java | 0
.../adapters/sensemap/OpenSenseMapAdapterTest.java | 0
.../connect/adapters/sensemap/SensorNamesTest.java | 0
.../connect/adapters/ti/TISensorTagTest.java | 35 +-
.../streampipes-connect-adapter/pom.xml | 165 ---------
.../adapters/netio/model/NetioAllPowerOutputs.java | 48 ---
.../connect/adapters/plc4x/s7/Plc4xS7Adapter.java | 289 ---------------
.../Dockerfile | 2 +-
.../aarch64.Dockerfile | 5 +-
.../arm.Dockerfile | 2 +-
.../development/env | 4 +-
.../pom.xml | 49 +--
.../pe/flink/AllFlinkPipelineElementsInit.java | 103 ++++++
.../apache/streampipes/pe/flink/config/Config.java | 60 ++--
.../streampipes/pe/flink/config/ConfigKeys.java | 15 +-
streampipes-pipeline-elements-all-jvm/Dockerfile | 7 +-
streampipes-pipeline-elements-all-jvm/pom.xml | 24 +-
.../pe/jvm/AllPipelineElementsInit.java | 26 ++
.../pom.xml | 2 +-
streampipes-pipeline-elements-shared/pom.xml | 2 +-
streampipes-processors-aggregation-flink/pom.xml | 3 +-
.../aggregation/AggregationController.java | 10 +-
streampipes-processors-enricher-flink/pom.xml | 2 +-
streampipes-processors-enricher-jvm/Dockerfile | 2 +-
streampipes-processors-enricher-jvm/pom.xml | 2 +-
.../processors/enricher/jvm/EnricherJvmInit.java | 33 +-
.../processors/enricher/jvm/config/ConfigKeys.java | 13 +-
.../enricher/jvm/config/EnricherJvmConfig.java | 14 +-
.../enricher/jvm/processor/jseval/JSEval.java | 76 ++++
.../jvm/processor/jseval/JSEvalController.java | 61 ++++
.../jvm/processor/jseval/JSEvalParameters.java | 16 +-
.../jvm/processor/sizemeasure/SizeMeasure.java | 29 +-
.../sizemeasure/SizeMeasureController.java | 29 +-
.../sizemeasure/SizeMeasureParameters.java | 29 +-
.../documentation.md | 35 +-
.../icon.png | Bin 0 -> 622 bytes
.../strings.en | 5 +
streampipes-processors-filters-jvm/pom.xml | 6 +-
.../processors/filters/jvm/FiltersJvmInit.java | 4 +-
.../filters/jvm/processor/limit/RateLimit.java | 75 ++++
.../jvm/processor/limit/RateLimitController.java | 108 ++++++
.../jvm/processor/limit/RateLimitParameters.java | 66 ++++
.../jvm/processor/limit/util/EventSelection.java | 9 +-
.../jvm/processor/limit/util/ProcessJob.java | 15 +-
.../jvm/processor/limit/util/SchedulerUtil.java | 58 +++
.../jvm/processor/limit/util/WindowFactory.java | 54 +++
.../jvm/processor/limit/util/WindowType.java | 9 +-
.../jvm/processor/limit/window/CronWindow.java | 46 +++
.../jvm/processor/limit/window/LengthWindow.java | 78 +++++
.../jvm/processor/limit/window/ScheduleWindow.java | 114 ++++++
.../jvm/processor/limit/window/TimeWindow.java | 46 +++
.../filters/jvm/processor/limit/window/Window.java | 15 +-
.../filters/jvm/processor/merge/StreamBuffer.java | 30 +-
.../documentation.md | 64 ++++
.../icon.png | Bin 0 -> 3534 bytes
.../strings.en | 32 ++
streampipes-processors-filters-siddhi/pom.xml | 2 +-
.../processors/siddhi/FiltersSiddhiInit.java | 10 +-
...{NumericalOperator.java => FilterOperator.java} | 4 +-
.../processors/siddhi/filter/NumericalFilter.java | 35 +-
.../siddhi/filter/NumericalFilterController.java | 11 +-
.../siddhi/filter/NumericalFilterParameters.java | 12 +-
.../processors/siddhi/stop/StreamStop.java | 5 +-
.../documentation.md | 23 +-
.../strings.en | 2 +-
.../siddhi/trend/TestTrendProcessor.java | 5 +
streampipes-processors-geo-flink/pom.xml | 2 +-
streampipes-processors-geo-jvm/development/env | 4 +-
streampipes-processors-geo-jvm/pom.xml | 2 +-
.../streampipes/processors/geo/jvm/GeoJvmInit.java | 20 +-
.../geo/jvm/jts/helper/SpGeometryBuilder.java | 73 ++--
.../geo/jvm/jts/helper/SpTrajectoryBuilder.java | 105 ++++++
.../jvm/jts/processor/latLngToGeo/LatLngToGeo.java | 60 ++--
.../latLngToGeo/LatLngToGeoController.java | 109 +++---
.../latLngToGeo/LatLngToGeoParameter.java | 36 +-
.../geo/jvm/jts/processor/setEPSG/SetEPSG.java | 33 +-
.../jts/processor/setEPSG/SetEpsgController.java | 73 ++--
.../jts/processor/setEPSG/SetEpsgParameter.java | 16 +-
.../trajectory/CreateTrajectoryFromPoints.java | 80 +++++
.../CreateTrajectoryFromPointsController.java | 116 ++++++
.../CreateTrajectoryFromPointsParameter.java} | 63 ++--
.../documentation.md | 12 +-
.../icon.png | Bin 19124 -> 20621 bytes
.../strings.en | 10 +-
.../icon.png | Bin 4831 -> 8710 bytes
.../strings.en | 9 +-
.../documentation.md | 77 ++++
.../icon.png | Bin 0 -> 9399 bytes
.../strings.en | 20 ++
.../Dockerfile | 5 +-
.../pom.xml | 2 +-
.../jvm/processor/commons/ImageTransformer.java | 18 +-
.../jvm/processor/commons/RequiredBoxStream.java | 1 +
.../GenericImageClassification.java | 7 +-
.../GenericImageClassificationController.java | 2 +-
.../processor/imageenrichment/BoxCoordinates.java | 28 ++
.../jvm/processor/imageenrichment/ColorUtil.java | 44 ++-
.../processor/imageenrichment/ImageEnricher.java | 29 +-
.../imageenrichment/ImageEnrichmentController.java | 3 +-
.../imageenrichment/ImageEnrichmentParameters.java | 22 +-
.../documentation.md | 5 +-
.../pom.xml | 2 +-
streampipes-processors-statistics-flink/pom.xml | 2 +-
streampipes-processors-text-mining-flink/pom.xml | 2 +-
streampipes-processors-text-mining-jvm/pom.xml | 2 +-
.../Dockerfile | 4 +-
.../aarch64.Dockerfile | 4 +-
.../arm.Dockerfile | 4 +-
.../development/env | 2 +-
.../pom.xml | 2 +-
.../flink/config/TransformationFlinkConfig.java | 2 +-
streampipes-processors-transformation-jvm/pom.xml | 2 +-
.../transformation/jvm/TransformationJvmInit.java | 18 +-
.../jvm/processor/array/split/SplitArray.java | 2 +-
.../array/split/SplitArrayController.java | 14 +-
.../booloperator/edge/SignalEdgeFilter.java | 121 +++++++
.../edge/SignalEdgeFilterController.java | 77 ++++
.../edge/SignalEdgeFilterParameters.java | 72 ++++
.../booloperator/state/BooleanToState.java | 66 ++++
.../state/BooleanToStateController.java | 44 +--
.../state/BooleanToStateParameters.java | 32 +-
.../CsvMetadataEnrichmentController.java | 11 +-
.../jvm/processor/state/buffer/StateBuffer.java | 94 +++++
.../state/buffer/StateBufferController.java | 87 +++++
.../state/buffer/StateBufferParameters.java | 61 ++++
.../state/labeler/buffer/StateBufferLabeler.java | 86 +++++
.../buffer/StateBufferLabelerController.java | 131 +++++++
.../buffer/StateBufferLabelerParameters.java | 109 ++++++
.../processor/state/labeler/model/Statement.java | 43 +--
.../state/labeler/model/StatementUtils.java | 146 ++++++++
.../state/labeler/number/NumberLabeler.java | 69 ++++
.../labeler/number/NumberLabelerController.java | 118 +++++++
.../labeler/number/NumberLabelerParameters.java | 73 ++++
.../stringoperator/counter/StringCounter.java | 79 +++++
.../counter/StringCounterController.java | 71 ++++
.../counter/StringCounterParameters.java | 17 +-
.../stringoperator/state/StringToState.java | 45 +--
.../state/StringToStateController.java | 40 +--
.../state/StringToStateParameters.java | 21 +-
.../stringoperator/timer/StringTimer.java | 72 ++++
.../timer/StringTimerController.java | 83 +++++
.../timer/StringTimerParameters.java | 23 +-
.../transformtoboolean/TransformToBoolean.java | 13 +-
.../TransformToBooleanController.java | 13 +-
.../TransformToBooleanParameters.java | 13 +-
.../documentation.md | 2 +-
.../strings.en | 3 +
.../documentation.md | 33 +-
.../icon.png | Bin 0 -> 7919 bytes
.../strings.en | 15 +
.../documentation.md | 31 +-
.../icon.png | Bin 0 -> 12518 bytes
.../strings.en | 14 +
.../documentation.md | 32 +-
.../icon.png | Bin 0 -> 9466 bytes
.../strings.en | 18 +
.../documentation.md | 63 ++++
.../icon.png | Bin 0 -> 10162 bytes
.../strings.en | 29 ++
.../documentation.md | 30 +-
.../icon.png | Bin 0 -> 8629 bytes
.../strings.en | 29 ++
.../documentation.md | 29 +-
.../icon.png | Bin 0 -> 12174 bytes
.../strings.en | 11 +
.../documentation.md | 33 +-
.../icon.png | Bin 0 -> 16458 bytes
.../strings.en | 16 +
.../documentation.md | 30 +-
.../icon.png | Bin 0 -> 14398 bytes
.../strings.en | 17 +
streampipes-sinks-brokers-jvm/pom.xml | 4 +-
streampipes-sinks-databases-flink/pom.xml | 2 +-
streampipes-sinks-databases-jvm/pom.xml | 21 +-
.../sinks/databases/jvm/DatabasesJvmInit.java | 6 +-
.../sinks/databases/jvm/jdbcclient/JdbcClient.java | 3 +-
.../sinks/databases/jvm/mysql/Column.java | 76 ++++
.../sinks/databases/jvm/mysql/Mysql.java | 269 ++++++++++++++
.../sinks/databases/jvm/mysql/MysqlController.java | 75 ++++
.../sinks/databases/jvm/mysql/MysqlParameters.java | 66 ++++
.../sinks/databases/jvm/opcua/OpcUa.java | 18 +-
.../sinks/databases/jvm/redis/Redis.java | 119 +++++++
.../sinks/databases/jvm/redis/RedisController.java | 103 ++++++
.../sinks/databases/jvm/redis/RedisParameters.java | 114 ++++++
.../documentation.md | 31 +-
.../icon.png | Bin 0 -> 6477 bytes
.../strings.en | 21 ++
.../documentation.md | 81 +++++
.../icon.png | Bin 0 -> 12905 bytes
.../strings.en | 38 ++
streampipes-sinks-internal-jvm/pom.xml | 2 +-
.../sinks/internal/jvm/config/ConfigKeys.java | 5 +-
.../jvm/config/SinksInternalJvmConfig.java | 32 +-
.../sinks/internal/jvm/datalake/DataLake.java | 27 +-
.../internal/jvm/datalake/DataLakeController.java | 10 +-
.../jvm/datalake/DataLakeInfluxDbClient.java | 33 +-
streampipes-sinks-notifications-jvm/pom.xml | 6 +-
.../jvm/SinksNotificationsJvmInit.java | 4 +-
.../jvm/telegram/TelegramController.java | 65 ++++
.../jvm/telegram/TelegramParameters.java | 58 ++-
.../jvm/telegram/TelegramPublisher.java | 94 +++++
.../documentation.md | 26 +-
.../icon.png | Bin 0 -> 6844 bytes
.../strings.en | 11 +
streampipes-sources-vehicle-simulator/pom.xml | 4 +-
streampipes-sources-watertank-simulator/pom.xml | 4 +-
tools/maven/assembly.xml | 82 +++++
461 files changed, 9251 insertions(+), 2354 deletions(-)