This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch
4032-introducing-function-transformation-for-complex-data-handling-in-connect
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 24492be875 feat(#4032): Remove transformation rules
add 38e2da3af2 feat(#4032): Remove old guess schema classes in connect
worker
add df67698397 feat(#4032): Rename AdapterWorkerGuessManagement
add 46dd41d4b6 feat(#4032): Replace guess schema with get sample data
No new revisions were added by this update.
Summary of changes:
.../compact/generator/CompactAdapterGenerator.java | 8 +-
.../convert/ProvidesConversionResult.java | 29 ----
.../preprocessing/convert/SchemaConverter.java | 67 ---------
.../convert/ToOriginalSchemaConverter.java | 69 ---------
.../convert/ToTransformedSchemaConverter.java | 74 ----------
.../preprocessing/utils/ConversionUtils.java | 93 ------------
.../shared/preprocessing/convert/Helpers.java | 113 ---------------
.../convert/ToOriginalSchemaConverterTest.java | 122 ----------------
.../convert/ToTransformedSchemaConverterTest.java | 160 ---------------------
.../extensions/api/connect/StreamPipesAdapter.java | 38 +++--
...java => AdapterWorkerSampleDataManagement.java} | 67 +--------
.../management/connect/SchemaUpdateManagement.java | 116 ---------------
.../connect/AdapterWorkerGuessManagementTest.java | 51 -------
.../connect/iiot/adapters/oi4/Oi4Adapter.java | 12 +-
.../iiot/protocol/stream/FileReplayAdapter.java | 11 --
.../iiot/protocol/stream/HttpStreamProtocol.java | 8 +-
.../connectors/kafka/adapter/KafkaProtocol.java | 8 +-
.../connectors/mqtt/adapter/MqttProtocol.java | 8 +-
.../connectors/nats/adapter/NatsProtocol.java | 67 ++++++---
.../connectors/opcua/adapter/OpcUaAdapter.java | 8 +-
.../opcua/adapter/OpcUaSchemaProvider.java | 20 +--
.../plc/adapter/generic/GenericPlc4xAdapter.java | 18 ++-
.../connectors/plc/adapter/s7/Plc4xS7Adapter.java | 126 ++++++++++------
.../connectors/pulsar/adapter/PulsarProtocol.java | 8 +-
.../connectors/ros/adapter/RosBridgeAdapter.java | 13 +-
...e.java => AdapterWorkerSampleDataResource.java} | 59 +++-----
26 files changed, 231 insertions(+), 1142 deletions(-)
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/ProvidesConversionResult.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/SchemaConverter.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToOriginalSchemaConverter.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToTransformedSchemaConverter.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/utils/ConversionUtils.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/convert/Helpers.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToOriginalSchemaConverterTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToTransformedSchemaConverterTest.java
rename
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/{AdapterWorkerGuessManagement.java
=> AdapterWorkerSampleDataManagement.java} (53%)
delete mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/SchemaUpdateManagement.java
delete mode 100644
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerGuessManagementTest.java
rename
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/connect/{AdapterWorkerGuessResource.java
=> AdapterWorkerSampleDataResource.java} (57%)
