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 15:34:36 UTC
[streampipes] branch remove-set-adapters updated (a608787a7 -> 3c851b379)
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 a608787a7 [hotfix] Remove class `AdapterDescription`
add 5000139e0 Bump error_prone_annotations from 2.2.0 to 2.18.0 (#1403)
add 3ca5f9b21 Bump @typescript-eslint/parser from 5.54.0 to 5.56.0 in /ui
add 792f2d108 Bump eslint from 8.36.0 to 8.37.0 in /ui
add c8fd621db Bump kafka.version from 3.3.1 to 3.4.0
add 45b27818e Bump black from 23.1.0 to 23.3.0 in /streampipes-client-python
add 004422938 Bump boofcv-core from 0.33 to 0.42
add 4f74f9428 [hotfix] Remove duplicate declaration of snakeyaml dependency version
add c33607da7 [hotfix] Fix configuration for pipeline element development (#1465)
add b1d459168 Merge branch 'dev' into remove-set-adapters
add 3c851b379 [#1289] Very first version for new adapter interface
No new revisions were added by this update.
Summary of changes:
installer/cli/environments/pipeline-element | 2 -
installer/cli/environments/pipeline-element-nats | 2 -
pom.xml | 11 +-
streampipes-client-python/setup.py | 2 +-
.../extensions/api/connect/Connector.java | 1 +
.../extensions/api/connect/EmitBinaryEvent.java | 1 +
.../extensions/api/connect/IAdapter.java | 1 +
.../extensions/api/connect/IFormat.java | 1 +
.../extensions/api/connect/IParser.java | 1 +
.../extensions/api/connect/IProtocol.java | 1 +
.../management/connect/AdapterInstance.java | 10 +-
.../management/connect/AdapterInterface.java | 58 +++++++
.../connect/ConnectWorkerDescriptionProvider.java | 22 +++
.../management/connect/IAdapterRuntimeContext.java | 97 +++++++++++
.../management/init/DeclarersSingleton.java | 40 ++---
.../management/model/SpServiceDefinition.java | 14 ++
.../model/SpServiceDefinitionBuilder.java | 9 +
.../ConnectWorkerDescriptionProviderTest.java | 59 +++++++
.../model/SpServiceDefinitionBuilderTest.java | 69 ++++++++
.../streampipes-connect-adapters-iiot/pom.xml | 4 -
.../connect/iiot/ConnectAdapterIiotInit.java | 44 ++---
.../simulator/machine/MachineDataSimulator.java | 9 +
.../machine/MachineDataSimulatorUtils.java | 6 +
.../simulator/machine/v2/FileReplayAdapter.java | 107 ++++++++++++
.../machine/v2/NewMachineDataSimulatorAdapter.java | 104 ++++++++++++
.../streampipes-connect-adapters/pom.xml | 4 -
.../connect/adapter/AdapterConfiguration.java | 71 ++++++++
.../model/connect/adapter/AdapterDescription.java | 9 +-
.../connect/adapter/GenericAdapterDescription.java | 1 +
.../adapter/GenericAdapterStreamDescription.java | 1 +
...StreamDescription.java => IEventCollector.java} | 35 ++--
.../streampipes/model/connect/adapter/Parser.java | 15 +-
.../adapter/SpecificAdapterStreamDescription.java | 1 +
.../model/connect/grounding/FormatDescription.java | 1 +
.../connect/grounding/ProtocolDescription.java | 1 +
.../adapter/AdapterConfigurationBuilder.java | 56 +++++++
.../streampipes/sdk/builder/adapter/CsvParser.java | 44 +++++
.../sdk/builder/adapter/JsonParser.java | 43 +++++
...tractor.java => AdapterParameterExtractor.java} | 15 +-
.../adapter/AdapterConfigurationBuilderTest.java | 91 ++++++++++
.../connect/ConnectWorkerRegistrationService.java | 6 +-
...meContext.java => SpAdapterRuntimeContext.java} | 40 ++++-
ui/package-lock.json | 183 +++++++++++----------
ui/package.json | 4 +-
44 files changed, 1081 insertions(+), 215 deletions(-)
copy streampipes-client/src/main/java/org/apache/streampipes/client/credentials/CredentialsProvider.java => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterInstance.java (80%)
create mode 100644 streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterInterface.java
create mode 100644 streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/IAdapterRuntimeContext.java
create mode 100644 streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/ConnectWorkerDescriptionProviderTest.java
create mode 100644 streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/model/SpServiceDefinitionBuilderTest.java
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/simulator/machine/v2/FileReplayAdapter.java
create mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/simulator/machine/v2/NewMachineDataSimulatorAdapter.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterConfiguration.java
copy streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/{SpecificAdapterStreamDescription.java => IEventCollector.java} (50%)
copy streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IImageStorage.java => streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/Parser.java (72%)
create mode 100644 streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfigurationBuilder.java
create mode 100644 streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/CsvParser.java
create mode 100644 streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/JsonParser.java
copy streampipes-sdk/src/main/java/org/apache/streampipes/sdk/extractor/{DataSinkParameterExtractor.java => AdapterParameterExtractor.java} (69%)
create mode 100644 streampipes-sdk/src/test/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfigurationBuilderTest.java
copy streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/context/{SpEventSinkRuntimeContext.java => SpAdapterRuntimeContext.java} (64%)