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 2023/03/31 21:08:05 UTC
[streampipes] branch remove-set-adapters updated (3c851b379 -> 9617649db)
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch remove-set-adapters
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 3c851b379 [#1289] Very first version for new adapter interface
add 9617649db [#1289] Started to migrate the API
No new revisions were added by this update.
Summary of changes:
.../management/connect/AdapterUtils.java | 56 +-
.../connect/AdapterWorkerManagement.java | 3 +-
.../connect/ConnectWorkerDescriptionProvider.java | 92 +--
.../management/connect/GuessManagement.java | 3 +-
.../adapter/model/generic/GenericAdapter.java | 99 ---
.../model/generic/GenericDataStreamAdapter.java | 68 --
.../adapter/model/specific/SpecificAdapter.java | 34 -
.../model/specific/SpecificDataStreamAdapter.java | 33 -
.../connect/adapter/preprocessing/Util.java | 10 -
.../connect/AdapterWorkerManagementTest.java | 93 ---
.../ConnectWorkerDescriptionProviderTest.java | 34 +-
.../extensions/management/connect/Utils.java | 37 -
.../connect/adapter/GroundingServiceTest.java | 3 +-
.../connect/iiot/adapters/PullAdapter.java | 170 +++--
.../connect/iiot/adapters/PullRestAdapter.java | 98 ++-
.../opcua/MiloOpcUaConfigurationProvider.java | 151 ++---
.../connect/iiot/adapters/opcua/OpcUaAdapter.java | 489 +++++++-------
.../iiot/adapters/opcua/OpcUaNodeBrowser.java | 205 +++---
.../connect/iiot/adapters/opcua/SpOpcUaClient.java | 306 ++++-----
.../opcua/configuration/SpOpcUaConfig.java | 403 ++++++-----
.../opcua/configuration/SpOpcUaConfigBuilder.java | 175 +++--
.../iiot/adapters/opcua/utils/OpcUaUtil.java | 438 ++++++------
.../adapters/plc4x/modbus/Plc4xModbusAdapter.java | 602 ++++++++---------
.../plc4x/passive/Plc4xPassiveAdapter.java | 178 +++--
.../iiot/adapters/plc4x/s7/Plc4xS7Adapter.java | 631 ++++++++----------
.../iiot/adapters/ros/RosBridgeAdapter.java | 439 ++++++------
.../machine/MachineDataStreamAdapter.java | 138 ++--
.../simulator/machine/v2/FileReplayAdapter.java | 38 +-
.../machine/v2/NewMachineDataSimulatorAdapter.java | 29 +-
.../streampipes/connect/ConnectAdapterInit.java | 42 +-
.../streampipes/connect/adapters/PullAdapter.java | 155 ++---
.../connect/adapters/PullRestAdapter.java | 98 ++-
.../adapters/coindesk/CoindeskBitcoinAdapter.java | 191 +++---
.../connect/adapters/flic/FlicMQTTAdapter.java | 243 +++----
.../connect/adapters/gdelt/GdeltAdapter.java | 398 ++++++-----
.../connect/adapters/iex/IexCloudAdapter.java | 71 +-
.../connect/adapters/iex/IexCloudNewsAdapter.java | 219 +++---
.../connect/adapters/iex/IexCloudStockAdapter.java | 165 ++---
.../connect/adapters/image/ImageZipAdapter.java | 149 ++---
.../adapters/image/stream/ImageStreamAdapter.java | 139 ++--
.../connect/adapters/iss/IssAdapter.java | 227 +++----
.../connect/adapters/netio/NetioMQTTAdapter.java | 286 ++++----
.../connect/adapters/netio/NetioRestAdapter.java | 372 +++++------
.../adapters/sensemap/OpenSenseMapAdapter.java | 741 ++++++++++-----------
.../simulator/random/RandomDataSimulator.java | 87 ---
.../simulator/random/RandomDataSimulatorUtils.java | 48 --
.../simulator/random/RandomDataStreamAdapter.java | 88 ---
.../connect/adapters/slack/SlackAdapter.java | 162 ++---
.../connect/adapters/ti/TISensorTag.java | 363 +++++-----
.../adapters/wikipedia/WikipediaAdapter.java | 245 ++++---
.../wikipedia/WikipediaEditedArticlesAdapter.java | 73 +-
.../wikipedia/WikipediaModelConverter.java | 82 +--
.../wikipedia/WikipediaNewArticlesAdapter.java | 75 +--
.../connectors/influx/InfluxConnectorsInit.java | 5 +-
.../influx/adapter/InfluxDbStreamAdapter.java | 351 +++++-----
.../model/connect/adapter/AdapterDescription.java | 6 -
.../connect/adapter/GenericAdapterDescription.java | 36 -
.../adapter/GenericAdapterStreamDescription.java | 76 ---
.../adapter/SpecificAdapterStreamDescription.java | 38 --
.../org/apache/streampipes/model/util/Cloner.java | 11 +-
.../connect/adapter/AdapterDescriptionTest.java | 2 +-
.../manager/template/AdapterTemplateHandler.java | 10 +-
.../resource/management/secret/SecretService.java | 7 +-
.../builder/adapter/AdapterDescriptionBuilder.java | 23 +-
.../adapter/GenericDataSetAdapterBuilder.java | 21 -
.../adapter/GenericDataStreamAdapterBuilder.java | 86 ---
.../adapter/SpecificDataStreamAdapterBuilder.java | 67 --
.../GenericDataStreamAdapterBuilderTest.java | 89 ---
.../extensions/ExtensionsModelSubmitter.java | 2 +-
.../connect/ConnectWorkerRegistrationService.java | 10 +-
.../storage/couchdb/serializer/GsonSerializer.java | 8 -
71 files changed, 4372 insertions(+), 6250 deletions(-)
delete mode 100644 streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/model/generic/GenericAdapter.java
delete mode 100644 streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/model/generic/GenericDataStreamAdapter.java
delete mode 100644 streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/model/specific/SpecificAdapter.java
delete mode 100644 streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/model/specific/SpecificDataStreamAdapter.java
delete mode 100644 streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerManagementTest.java
delete mode 100644 streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/Utils.java
delete mode 100644 streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/random/RandomDataSimulator.java
delete mode 100644 streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/random/RandomDataSimulatorUtils.java
delete mode 100644 streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/random/RandomDataStreamAdapter.java
delete mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/GenericAdapterDescription.java
delete mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/GenericAdapterStreamDescription.java
delete mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/SpecificAdapterStreamDescription.java
delete mode 100644 streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/GenericDataSetAdapterBuilder.java
delete mode 100644 streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/GenericDataStreamAdapterBuilder.java
delete mode 100644 streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/SpecificDataStreamAdapterBuilder.java
delete mode 100644 streampipes-sdk/src/test/java/org/apache/streampipes/sdk/builder/adapter/GenericDataStreamAdapterBuilderTest.java