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/01/13 20:50:09 UTC
[incubator-streampipes] 02/02: Merge branch 'dev' into STREAMPIPES-494
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch STREAMPIPES-494
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 3e84f20526478a9d36cb196d05108ac941ed5cbd
Merge: 9b84b05 c3bb575
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Thu Jan 13 21:49:47 2022 +0100
Merge branch 'dev' into STREAMPIPES-494
.../constants/GlobalStreamPipesConstants.java | 2 +
.../worker/management/RuntimeResovable.java | 25 +-
.../worker/rest/RuntimeResolvableResource.java | 26 +-
.../api/InvocablePipelineElementResource.java | 33 +-
.../api/ResolvesContainerProvidedOptions.java | 7 +-
.../api/RuntimeResolvableRequestHandler.java | 68 +++
...idedOptions.java => SupportsRuntimeConfig.java} | 9 +-
streampipes-extensions/pom.xml | 2 +-
.../opcua/MiloOpcUaConfigurationProvider.java | 100 ++++
.../connect/iiot/adapters/opcua/OpcNode.java | 9 +
.../connect/iiot/adapters/opcua/OpcUa.java | 572 ---------------------
.../connect/iiot/adapters/opcua/OpcUaAdapter.java | 64 ++-
.../iiot/adapters/opcua/OpcUaNodeBrowser.java | 117 +++++
.../connect/iiot/adapters/opcua/SpOpcUaClient.java | 167 ++++++
.../opcua/configuration/SpOpcUaConfig.java | 215 ++++++++
.../opcua/configuration/SpOpcUaConfigBuilder.java | 99 ++++
.../adapters/opcua/utils/OpcUaNodeVariants.java | 2 +-
.../iiot/adapters/opcua/utils/OpcUaUtil.java | 48 +-
.../iiot/protocol/stream/KafkaProtocol.java | 10 +
.../strings.en | 5 +-
.../pe/shared/config/kafka/KafkaConnectUtils.java | 9 +
.../changedetection/jvm/cusum/CusumController.java | 6 +-
.../valueChange/ValueChangeProcessor.java | 2 +-
.../processors/filters/jvm/FiltersJvmInit.java | 2 +
.../throughputmon/ThroughputMonitorProcessor.java | 115 +++++
.../documentation.md | 49 +-
.../strings.en | 21 +
.../processors/siddhi/count/CountAggregation.java | 2 +-
.../siddhi/listcollector/ListCollector.java | 2 +-
.../processors/siddhi/listfilter/ListFilter.java | 2 +-
.../streampipes/processors/siddhi/topk/TopK.java | 2 +-
.../logical/BooleanOperatorProcessor.java | 2 +-
.../sinks/internal/jvm/datalake/DataLake.java | 40 +-
.../internal/jvm/datalake/DataLakeController.java | 8 +-
.../jvm/datalake/DataLakeInfluxDbClient.java | 75 +--
.../sinks/internal/jvm/datalake/DataLakeUtils.java | 36 +-
.../jvm/datalake/InfluxDbConnectionSettings.java | 82 +++
.../jvm/datalake/InfluxDbReservedKeywords.java | 102 ++++
.../messaging/jms/ActiveMQPublisher.java | 6 +-
.../messaging/kafka/SpKafkaProducer.java | 66 ++-
.../messaging/mqtt/AbstractMqttConnector.java | 2 +-
.../streampipes/messaging/mqtt/MqttPublisher.java | 2 +-
.../streampipes/messaging/EventProducer.java | 2 +-
.../model/graph/DataProcessorInvocation.java | 28 +-
.../model/graph/DataSinkInvocation.java | 26 +-
.../model/runtime/RuntimeOptionsResponse.java | 21 +-
.../RuntimeResolvableTreeInputStaticProperty.java | 70 +++
.../staticproperty/SlideToggleStaticProperty.java | 65 +++
.../model/staticproperty/StaticProperty.java | 2 +
.../model/staticproperty/StaticPropertyType.java | 5 +-
.../staticproperty/StaticPropertyVisitor.java | 4 +
.../model/staticproperty/TreeInputNode.java | 93 ++++
.../org/apache/streampipes/model/util/Cloner.java | 4 +
.../endpoint/ExtensionsServiceEndpointUtils.java | 11 +-
.../manager/execution/http/HttpRequestBuilder.java | 6 +-
.../manager/matching/FormatSelector.java | 23 +-
.../template/PipelineElementTemplateVisitor.java | 16 +
.../streampipes/manager/util/TopicGenerator.java | 7 +-
.../resource/management/secret/SecretVisitor.java | 10 +
.../apache/streampipes/sdk/StaticProperties.java | 12 +
...AbstractConfigurablePipelineElementBuilder.java | 27 +
.../sdk/extractor/AbstractParameterExtractor.java | 61 ++-
.../api/IPipelineElementDescriptionStorage.java | 4 +
.../couchdb/impl/DataProcessorStorageImpl.java | 3 +-
.../PipelineElementDescriptionStorageImpl.java | 21 +
.../support/builder/SpecificAdapterBuilder.ts | 7 +-
ui/cypress/support/model/AdapterInput.ts | 1 +
ui/cypress/support/model/UserInput.ts | 2 +-
ui/cypress/support/utils/ConnectUtils.ts | 4 +
ui/cypress/support/utils/DataLakeUtils.ts | 46 +-
ui/cypress/support/utils/ParameterUtils.ts | 8 +
ui/cypress/support/utils/StaticPropertyUtils.ts | 8 +-
.../adapter/machineDataSimulator.smoke.spec.ts | 2 -
ui/cypress/tests/adapter/opcAdapter.ts | 75 +++
.../datalake/widgetDataConfiguration.smoke.spec.ts | 35 +-
.../datalake-configuration.component.ts | 15 +-
.../event-schema/event-schema.component.html | 2 +-
ui/src/app/core-model/gen/streampipes-model.ts | 87 +++-
.../datalake/DatalakeQueryParameterBuilder.ts | 18 +-
ui/src/app/core-ui/core-ui.module.ts | 12 +-
.../static-property.component.html | 32 +-
.../static-properties/static-property.component.ts | 12 +-
...tic-runtime-resolvable-any-input.component.html | 4 +-
...tatic-runtime-resolvable-any-input.component.ts | 13 +-
.../base-runtime-resolvable-input.ts | 42 +-
.../base-runtime-resolvable-selection-input.ts | 40 +-
...c-runtime-resolvable-oneof-input.component.html | 5 +-
...tic-runtime-resolvable-oneof-input.component.ts | 13 +-
.../static-tree-input.component.html | 57 ++
.../static-tree-input.component.scss | 20 +-
.../static-tree-input.component.ts | 96 ++++
.../static-slide-toggle.component.html} | 16 +-
.../static-slide-toggle.component.ts | 52 ++
...data-explorer-widget-data-settings.component.ts | 10 +-
.../group-selection-panel.component.ts | 8 +-
.../data-explorer-dashboard-widget.component.html | 26 +-
.../correlation-chart-widget.component.ts | 2 +-
.../widgets/heatmap/heatmap-widget.component.ts | 67 ++-
.../time-series-chart-widget-config.component.ts | 1 -
.../time-series-chart-widget.component.ts | 19 +-
.../select-color-properties.component.html | 26 +-
.../app/data-explorer/data-explorer.component.html | 15 +-
.../pipeline-element.component.html | 4 +-
.../pipeline-element/pipeline-element.component.ts | 42 +-
ui/src/app/editor/editor.module.ts | 101 ++--
.../delete-pipeline-dialog.component.html | 2 +-
.../pipeline-notifications.component.html | 2 +-
.../start-all-pipelines-dialog.component.html | 4 +-
ui/src/app/services/image-checker.service.ts | 57 --
109 files changed, 2626 insertions(+), 1218 deletions(-)
diff --cc ui/src/app/core-model/gen/streampipes-model.ts
index 2f6062a,3c66804..ac57f56
--- a/ui/src/app/core-model/gen/streampipes-model.ts
+++ b/ui/src/app/core-model/gen/streampipes-model.ts
@@@ -18,10 -18,10 +18,10 @@@
/* tslint:disable */
/* eslint-disable */
// @ts-nocheck
- // Generated using typescript-generator version 2.27.744 on 2022-01-05 10:45:36.
-// Generated using typescript-generator version 2.27.744 on 2022-01-07 22:58:50.
++// Generated using typescript-generator version 2.27.744 on 2022-01-13 21:47:46.
export class AbstractStreamPipesEntity {
- "@class": "org.apache.streampipes.model.base.AbstractStreamPipesEntity" | "org.apache.streampipes.model.base.NamedStreamPipesEntity" | "org.apache.streampipes.model.connect.adapter.AdapterDescription" | "org.apache.streampipes.model.connect.adapter.AdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.AdapterStrea [...]
+ "@class": "org.apache.streampipes.model.base.AbstractStreamPipesEntity" | "org.apache.streampipes.model.base.NamedStreamPipesEntity" | "org.apache.streampipes.model.connect.adapter.AdapterDescription" | "org.apache.streampipes.model.connect.adapter.AdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.AdapterStrea [...]
elementId: string;
static fromData(data: AbstractStreamPipesEntity, target?: AbstractStreamPipesEntity): AbstractStreamPipesEntity {
@@@ -192,9 -192,9 +192,9 @@@ export class AdapterDescription extend
instance.selectedEndpointUrl = data.selectedEndpointUrl;
instance.correspondingServiceGroup = data.correspondingServiceGroup;
instance.correspondingDataStreamElementId = data.correspondingDataStreamElementId;
++ instance.valueRules = __getCopyArrayFn(__identity<any>())(data.valueRules);
instance.streamRules = __getCopyArrayFn(__identity<any>())(data.streamRules);
instance.schemaRules = __getCopyArrayFn(__identity<any>())(data.schemaRules);
-- instance.valueRules = __getCopyArrayFn(__identity<any>())(data.valueRules);
return instance;
}
@@@ -1662,9 -1651,9 +1666,9 @@@ export class GenericAdapterSetDescripti
}
const instance = target || new GenericAdapterSetDescription();
super.fromData(data, instance);
+ instance.eventSchema = EventSchema.fromData(data.eventSchema);
- instance.formatDescription = FormatDescription.fromData(data.formatDescription);
instance.protocolDescription = ProtocolDescription.fromData(data.protocolDescription);
+ instance.formatDescription = FormatDescription.fromData(data.formatDescription);
- instance.eventSchema = EventSchema.fromData(data.eventSchema);
return instance;
}
}
@@@ -1681,9 -1670,9 +1685,9 @@@ export class GenericAdapterStreamDescri
}
const instance = target || new GenericAdapterStreamDescription();
super.fromData(data, instance);
+ instance.eventSchema = EventSchema.fromData(data.eventSchema);
- instance.formatDescription = FormatDescription.fromData(data.formatDescription);
instance.protocolDescription = ProtocolDescription.fromData(data.protocolDescription);
+ instance.formatDescription = FormatDescription.fromData(data.formatDescription);
- instance.eventSchema = EventSchema.fromData(data.eventSchema);
return instance;
}
}