You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2022/08/17 20:12:04 UTC
[incubator-streampipes] 01/01: Merge pull request #104 from apache/STREAMPIPES-577
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 4f9958fcdda17911a1d8a292dc8cf98f0cf09ede
Merge: bb4d2fca4 7228f5b28
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Wed Aug 17 22:11:58 2022 +0200
Merge pull request #104 from apache/STREAMPIPES-577
Streampipes 577
.../exceptions/SpConfigurationException.java | 32 ++
.../apache/streampipes/connect/api/IParser.java | 9 +
.../connect/api/exception/ParseException.java | 6 +
.../master/management/GuessManagement.java | 19 +-
.../master/management/WorkerRestClient.java | 23 +-
.../worker/management/GuessManagement.java | 3 +-
.../container/worker/rest/GuessResource.java | 10 +-
.../worker/rest/RuntimeResolvableResource.java | 26 +-
.../streampipes/connect/adapter/Adapter.java | 112 +------
.../connect/adapter/AdapterPipelineGenerator.java | 150 ++++++++++
.../connect/adapter/format/csv/CsvParser.java | 39 +--
.../adapter/format/json/AbstractJsonFormat.java | 3 -
.../format/json/object/JsonObjectParser.java | 135 ++-------
.../adapter/format/util/JsonEventProperty.java | 6 +-
.../connect/adapter/guess/SchemaGuesser.java | 10 +-
.../pipeline/AdapterEventPreviewPipeline.java | 81 +++++
.../TransformValueAdapterPipelineElement.java | 14 +-
.../value/DatatypeTransformationRule.java | 52 ++++
.../transform/value/ValueEventTransformer.java | 46 +--
.../connect/adapter/util/DatatypeUtils.java | 108 +++++++
.../connect/adapter/util/PollingSettings.java | 1 +
.../api/InvocablePipelineElementResource.java | 27 +-
.../api/ResolvesContainerProvidedOptions.java | 3 +-
.../ResolvesContainerProvidedOutputStrategy.java | 4 +-
.../api/RuntimeResolvableRequestHandler.java | 5 +-
.../container/api/SupportsRuntimeConfig.java | 3 +-
.../opcua/MiloOpcUaConfigurationProvider.java | 8 +-
.../connect/iiot/adapters/opcua/OpcUaAdapter.java | 26 +-
.../iiot/adapters/opcua/OpcUaNodeBrowser.java | 10 +
.../connect/iiot/adapters/opcua/SpOpcUaClient.java | 8 +-
.../opcua/utils/ExceptionMessageExtractor.java | 25 +-
.../iiot/adapters/opcua/utils/OpcUaUtil.java | 327 ++++++++++++---------
.../iiot/adapters/plc4x/s7/Plc4xS7Adapter.java | 148 ++++++----
.../adapters/plc4x/s7/PlcReadResponseHandler.java | 13 +-
.../machine/MachineDataSimulatorUtils.java | 240 ++++++++-------
.../connect/iiot/protocol/set/FileProtocol.java | 11 +-
.../connect/iiot/protocol/set/HttpProtocol.java | 2 +-
.../iiot/protocol/stream/BrokerProtocol.java | 8 +-
.../iiot/protocol/stream/FileStreamProtocol.java | 11 +-
.../iiot/protocol/stream/HttpStreamProtocol.java | 2 +-
.../iiot/protocol/stream/KafkaProtocol.java | 41 ++-
.../org/apache/streampipes/model/MessageLd.java | 117 --------
.../apache/streampipes/model/NotificationLd.java | 95 ------
.../streampipes/model/StreamPipesErrorMessage.java | 103 +++++++
.../{GuessSchema.java => AdapterEventPreview.java} | 37 +--
.../{GuessSchema.java => AdapterGuessInfo.java} | 45 +--
.../model/connect/guess/FieldStatus.java | 7 +
.../model/connect/guess/FieldStatusInfo.java | 69 +++++
.../model/connect/guess/GuessSchema.java | 30 ++
.../guess/GuessTypeInfo.java} | 43 ++-
.../rules/TransformationRuleDescription.java | 1 +
...hangeDatatypeTransformationRuleDescription.java | 60 ++++
.../rest/impl/connect/GuessResource.java | 25 +-
.../impl/connect/RuntimeResolvableResource.java | 19 +-
.../sdk/builder/adapter/GuessSchemaBuilder.java | 14 +-
ui/package.json | 4 +-
.../src/lib/model/gen/streampipes-model.ts | 123 +++++++-
ui/projects/streampipes/shared-ui/package.json | 1 +
.../exception-details-dialog.component.html | 43 +++
.../exception-details-dialog.component.scss} | 39 ++-
.../exception-details-dialog.component.ts} | 26 +-
.../sp-exception-message.component.html | 38 +++
.../sp-exception-message.component.scss} | 12 +
.../sp-exception-message.component.ts | 56 ++++
.../shared-ui/src/lib/shared-ui.module.ts | 10 +-
.../streampipes/shared-ui/src/public-api.ts | 2 +
.../new-adapter/new-adapter.component.ts | 1 -
.../error-message/error-message.component.html | 18 +-
.../error-message/error-message.component.ts | 3 +-
.../event-property-row.component.html | 110 ++++---
.../event-property-row.component.scss | 66 ++++-
.../event-property-row.component.ts | 49 ++-
.../event-schema-preview.component.html | 24 +-
.../event-schema-preview.component.scss | 11 +
.../event-schema-preview.component.ts | 51 +++-
.../event-schema/event-schema.component.html | 49 +--
.../event-schema/event-schema.component.scss | 11 +-
.../event-schema/event-schema.component.ts | 48 ++-
.../schema-editor-header.component.ts | 6 +-
ui/src/app/connect/connect.module.ts | 5 +-
.../filter/json-pretty-print.pipe.ts} | 18 +-
ui/src/app/connect/services/rest.service.ts | 18 +-
.../services/transformation-rule.service.ts | 70 +++--
ui/src/app/core-model/base/UserErrorMessage.ts | 4 +-
.../static-property.component.html | 2 +
...tatic-runtime-resolvable-any-input.component.ts | 3 +
.../base-runtime-resolvable-input.ts | 13 +
...c-runtime-resolvable-oneof-input.component.html | 24 +-
...tic-runtime-resolvable-oneof-input.component.ts | 18 ++
.../static-tree-input.component.html | 3 +
.../static-tree-input.component.ts | 31 ++
.../widgets/base/base-ngx-line-charts-widget.ts | 3 +-
92 files changed, 2305 insertions(+), 1180 deletions(-)