This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch SP-1592
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 5468a1db4 Merge branch 'dev' into SP-1592
add eec594f78 Refactor structure of extensions-api, add supplier to
adapter interface (#1581)
add 92b694392 Rename AdapterInterface to StreamPipesAdapter (#1590)
add f065651ac [hotfix] Fix checkstyle issues
add bf873db59 Merge branch 'dev' into remove-set-adapters
add a3a84c670 Merge branch 'remove-set-adapters' of
github.com:apache/streampipes into remove-set-adapters
add 778edfcd5 [hotfix] Fix checkstyle issue
add 9077dcae9 [hotfix] Fix checkstyle issue
add f66c7daf6 [hotfix] Fix checkstyle
add 96857990a Migrate ISS adapter and Flic adapter (#1289)
add 8d3e1cc99 Migrate connect adapters to new model (#1289)
add 5970029a6 Properly apply configs to influx adapter (#1289)
add f7cf2600a [hotfix] Fix checkstyle
add b2839e0dc Merge branch 'dev' into remove-set-adapters
add a423a7429 Merge branch 'dev' into remove-set-adapters
add 73507256a fix: minor adaptions
add 2373299d9 Merge branch 'remove-set-adapters' of
github.com:apache/streampipes into remove-set-adapters
add b00c01c1c fix: remove data set artifacts
add 32b157b91 fix: minor fixes
add b9168d0f5 [hotfix] Regenerate typescript model
add 3253ec74a Refactor data processor and sink API (#1632) (#1633)
add 5e3f36753 chore: remove Plc4xPassiveAdapter
add 1cb22eb9d Add implementation for schema guessing from the example file
in the HTTP
new 2ceb7ac84 Merge branch 'remove-set-adapters' into SP-1592
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/pr-validation.yml | 2 +-
pom.xml | 24 +-
.../pom.xml | 36 +--
.../org/apache/streampipes/client/api/CRUDApi.java | 0
.../apache/streampipes/client/api/IAdminApi.java | 19 +-
.../streampipes/client/api/ICustomRequestApi.java | 17 +-
.../client/api/IDataLakeMeasureApi.java | 20 +-
.../streampipes/client/api/IDataProcessorApi.java | 67 +++++
.../streampipes/client/api/IDataSinkApi.java | 57 ++++
.../streampipes/client/api/IDataStreamApi.java | 52 ++++
.../apache/streampipes/client/api/IFileApi.java | 8 +-
.../streampipes/client/api/INotificationsApi.java | 6 +-
.../streampipes/client/api/IPipelineApi.java | 28 +-
.../client/api/IPipelineElementTemplateApi.java | 21 +-
.../streampipes/client/api/IStreamPipesClient.java | 59 ++++
.../client/api}/annotation/NotYetImplemented.java | 2 +-
.../config}/ClientConnectionConfigResolver.java | 2 +-
.../api/config}/ClientConnectionUrlResolver.java | 4 +-
.../api/config/IStreamPipesClientConfig.java | 19 +-
.../client/api/constants}/InputStreamIndex.java | 2 +-
.../api}/credentials/CredentialsProvider.java | 2 +-
.../client/api}/live/EventProcessor.java | 2 +-
.../streampipes/client/api/live/IKafkaConfig.java | 8 +-
streampipes-client/pom.xml | 7 +-
.../streampipes/client/StreamPipesClient.java | 43 +--
.../streampipes/client/StreamPipesCredentials.java | 2 +-
.../apache/streampipes/client/api/AdminApi.java | 6 +-
.../streampipes/client/api/CustomRequestApi.java | 5 +-
.../streampipes/client/api/DataLakeMeasureApi.java | 3 +-
.../streampipes/client/api/DataProcessorApi.java | 21 +-
.../apache/streampipes/client/api/DataSinkApi.java | 22 +-
.../streampipes/client/api/DataStreamApi.java | 19 +-
.../org/apache/streampipes/client/api/FileApi.java | 5 +-
.../streampipes/client/api/NotificationsApi.java | 3 +-
.../apache/streampipes/client/api/PipelineApi.java | 6 +-
.../client/api/PipelineElementTemplateApi.java | 2 +-
.../api/SupportsPipelineElementTemplateApi.java | 23 --
.../credentials/StreamPipesApiKeyCredentials.java | 1 +
.../credentials/StreamPipesTokenCredentials.java | 1 +
.../streampipes/client/http/HttpRequest.java | 2 +-
.../streampipes/client/live/KafkaConfig.java | 6 +-
.../client/live/SubscriptionManager.java | 6 +-
.../client/model/StreamPipesClientConfig.java | 8 +-
.../model/StreamPipesClientConnectionConfig.java | 3 +-
.../apache/streampipes/commons/constants/Envs.java | 10 +-
.../commons/environment/DefaultEnvironment.java | 15 +
.../commons/environment/Environment.java | 7 +
.../management/management/GuessManagement.java | 10 +-
.../dataexplorer/commons/DataExplorerUtils.java | 10 +-
.../dataexplorer/commons/TimeSeriesStore.java | 4 +-
.../export/resolver/AdapterResolver.java | 10 +-
streampipes-extensions-api/pom.xml | 12 +-
.../api/DataSetReplayFinishedNotifier.java | 23 --
.../extensions/api/config/IConfigExtractor.java | 9 +-
.../api/connect}/AdapterOutputCollector.java | 2 +-
.../api/connect/IAdapterConfiguration.java | 16 +-
.../extensions/api/connect}/IEventCollector.java | 2 +-
.../extensions/api/connect}/IParser.java | 6 +-
.../api/connect/IParserEventHandler.java | 6 +-
.../extensions/api/connect/StreamPipesAdapter.java | 15 +-
.../context/IAdapterGuessSchemaContext.java | 10 +-
.../connect}/context/IAdapterRuntimeContext.java | 4 +-
.../api/declarer/PipelineTemplateDeclarer.java | 25 --
.../api}/extractor/IAdapterParameterExtractor.java | 6 +-
.../IDataProcessorParameterExtractor.java} | 10 +-
.../api/extractor/IDataSinkParameterExtractor.java | 10 +-
.../api/extractor/IParameterExtractor.java | 119 ++++++++
.../IStaticPropertyExtractor.java} | 10 +-
.../api/monitoring/IPipelineElementLogger.java | 6 +-
.../api}/monitoring/SpMonitoringManager.java | 2 +-
.../api/pe/IStreamPipesDataProcessor.java | 29 +-
.../extensions/api/pe/IStreamPipesDataSink.java | 20 +-
.../IStreamPipesDataStream.java} | 7 +-
.../api/pe/IStreamPipesPipelineElement.java | 10 +-
.../api/pe/config/IDataProcessorConfiguration.java | 16 +-
.../config/IDataSinkConfiguration.java} | 8 +-
.../config/IDataStreamConfiguration.java} | 13 +-
.../config/IPipelineElementConfiguration.java} | 15 +-
.../pe/context/EventProcessorRuntimeContext.java | 7 +-
.../api/pe}/context/EventSinkRuntimeContext.java | 2 +-
.../api/pe/context/IContextGenerator.java | 10 +-
.../extensions/api/pe/context/RuntimeContext.java | 16 +-
.../api/pe/param/IDataProcessorParameters.java | 16 +-
.../param/IDataSinkParameters.java} | 8 +-
.../api/pe/param/IInternalRuntimeParameters.java | 11 +-
.../api/pe/param/IParameterGenerator.java | 13 +-
.../api/pe/param/IPipelineElementParameters.java | 48 +--
.../api/pe/param}/InputStreamParams.java | 17 +-
.../api/pe/param}/OutputStreamParams.java | 6 +-
.../api/pe}/routing/PipelineElementCollector.java | 2 +-
.../api/pe}/routing/RawDataProcessor.java | 2 +-
.../api/pe}/routing/SpInputCollector.java | 2 +-
.../api/pe}/routing/SpOutputCollector.java | 2 +-
.../runtime/IDataProcessorRuntime.java} | 7 +-
.../runtime/IDataSinkRuntime.java} | 7 +-
.../runtime/IStreamPipesRuntime.java} | 15 +-
.../runtime/IStreamPipesRuntimeProvider.java} | 9 +-
.../runtime/ResolvesContainerProvidedOptions.java | 4 +-
.../ResolvesContainerProvidedOutputStrategy.java | 4 +-
.../api/runtime/SupportsRuntimeConfig.java | 4 +-
...StreamPipesClientRuntimeConnectionResolver.java | 4 +-
.../management/config/ConfigExtractor.java | 6 +-
.../connect/AdapterWorkerManagement.java | 15 +-
.../connect/ConnectWorkerDescriptionProvider.java | 3 +-
.../management/connect/GuessManagement.java | 2 +-
.../management/connect/PullAdapterScheduler.java | 30 +-
.../management/connect/RuntimeResovable.java | 5 +-
.../connect/adapter/model/EventCollector.java | 2 +-
.../connect/adapter/parser/CsvParser.java | 8 +-
.../connect/adapter/parser/ImageParser.java | 6 +-
.../connect/adapter/parser/JsonParsers.java | 10 +-
.../management/connect/adapter/parser/Parsers.java | 2 +-
.../connect/adapter/parser/json/GeoJsonParser.java | 4 +-
.../adapter/parser/json/JsonArrayKeyParser.java | 4 +-
.../adapter/parser/json/JsonArrayParser.java | 4 +-
.../adapter/parser/json/JsonObjectParser.java | 4 +-
.../connect/adapter/parser/json/JsonParser.java | 4 +-
.../connect/adapter/parser/xml/XmlParser.java | 6 +-
.../elements/SendToBrokerAdapterSink.java | 2 +-
.../context/AdapterContextGenerator.java | 18 +-
.../context/SpAdapterGuessSchemaContext.java | 1 +
.../context/SpAdapterRuntimeContext.java | 3 +-
.../management/init/DeclarersSingleton.java | 120 ++++----
.../management/init/IDeclarersSingleton.java | 4 +-
.../management/init/RunningAdapterInstances.java | 10 +-
.../management/init/RunningInstances.java | 15 +-
.../management/model/SpServiceDefinition.java | 44 ++-
.../model/SpServiceDefinitionBuilder.java | 18 +-
.../management/util/RuntimeContextUtils.java | 31 +-
.../management/util/ServiceDefinitionUtil.java | 13 +-
.../connect/AdapterWorkerManagementTest.java | 2 +-
.../ConnectWorkerDescriptionProviderTest.java | 11 +-
.../connect/adapter/parser/CsvParserTest.java | 10 +-
.../connect/adapter/parser/XmlParserTest.java | 6 +-
.../adapter/parser/json/GeoJsonParserTest.java | 6 +-
.../parser/json/JsonArrayKeyParserTest.java | 8 +-
.../adapter/parser/json/JsonArrayParserTest.java | 6 +-
.../adapter/parser/json/JsonObjectParsersTest.java | 12 +-
.../management/init/DeclarersSingletonTest.java | 8 +-
.../model/SpServiceDefinitionBuilderTest.java | 16 +-
.../streampipes-connect-adapters-iiot/pom.xml | 5 +
.../connect/iiot/adapters/opcua/OpcUaAdapter.java | 26 +-
.../opcua/configuration/SpOpcUaConfigBuilder.java | 4 +-
.../iiot/adapters/opcua/utils/OpcUaUtil.java | 6 +-
.../adapters/plc4x/modbus/Plc4xModbusAdapter.java | 23 +-
.../plc4x/passive/Plc4xPassiveAdapter.java | 101 -------
.../iiot/adapters/plc4x/s7/Plc4xS7Adapter.java | 23 +-
.../iiot/adapters/ros/RosBridgeAdapter.java | 24 +-
.../simulator/machine/MachineDataSimulator.java | 2 +-
.../machine/MachineDataSimulatorAdapter.java | 19 +-
.../iiot/protocol/stream/BrokerEventProcessor.java | 4 +-
.../iiot/protocol/stream/FileReplayAdapter.java | 18 +-
.../iiot/protocol/stream/HttpServerProtocol.java | 55 ++--
.../iiot/protocol/stream/HttpStreamProtocol.java | 24 +-
.../iiot/protocol/stream/KafkaProtocol.java | 25 +-
.../connect/iiot/protocol/stream/MqttProtocol.java | 22 +-
.../connect/iiot/protocol/stream/NatsProtocol.java | 22 +-
.../iiot/protocol/stream/TubeMQProtocol.java | 27 +-
.../iiot/protocol/stream/pulsar/PulsarConfig.java | 4 +-
.../protocol/stream/pulsar/PulsarProtocol.java | 24 +-
.../protocol/stream/rocketmq/RocketMQProtocol.java | 22 +-
.../strings.en | 2 +
.../streampipes/connect/ConnectAdapterInit.java | 31 +-
.../streampipes/connect/adapters/PullAdapter.java | 90 ------
.../connect/adapters/PullRestAdapter.java | 67 -----
.../adapters/coindesk/CoindeskBitcoinAdapter.java | 218 ++++++++------
.../connect/adapters/flic/FlicMQTTAdapter.java | 196 ++++++-------
.../connect/adapters/image/ImageZipAdapter.java | 143 ++++-----
.../adapters/image/stream/ImageStreamAdapter.java | 118 ++++----
.../connect/adapters/iss/IssAdapter.java | 221 +++++++-------
.../connect/adapters/netio/NetioMQTTAdapter.java | 231 +++++++--------
.../connect/adapters/netio/NetioRestAdapter.java | 325 ++++++++++-----------
.../connect/adapters/slack/SlackAdapter.java | 145 ++++-----
.../connect/adapters/slack/SlackConsumer.java | 13 +-
.../connect/adapters/ti/TISensorTag.java | 325 ++++++++++-----------
.../adapters/wikipedia/WikipediaAdapter.java | 241 +++++++--------
.../wikipedia/WikipediaEditedArticlesAdapter.java | 58 ++--
.../wikipedia/WikipediaModelConverter.java | 82 ++++--
.../wikipedia/WikipediaNewArticlesAdapter.java | 59 ++--
.../adapters/wikipedia/WikipediaSseConsumer.java | 2 +-
.../streampipes/connect/config/ConfigKeys.java | 31 --
.../connect/config/ConnectWorkerConfig.java | 81 -----
.../influx/adapter/InfluxDbStreamAdapter.java | 28 +-
.../connectors/influx/shared/InfluxConfigs.java | 4 +-
.../connectors/influx/sink/InfluxDbSink.java | 6 +-
.../streampipes-extensions-all-jvm/pom.xml | 1 -
.../extensions/all/jvm/AllExtensionsInit.java | 3 +-
.../pe/jvm/AllPipelineElementsInit.java | 2 +
.../config/kafka/kafka/KafkaConnectUtils.java | 4 +-
.../pe/shared/config/mqtt/MqttConnectUtils.java | 6 +-
.../pe/shared/config/nats/NatsConfigUtils.java | 4 +-
.../flink/AbstractAggregationProgram.java | 49 ----
.../aggregation/AggregationController.java | 12 +-
.../aggregation/AggregationParameters.java | 4 +-
.../processor/aggregation/AggregationProgram.java | 47 ++-
.../flink/processor/count/CountController.java | 12 +-
.../flink/processor/count/CountParameters.java | 6 +-
.../flink/processor/count/CountProgram.java | 21 +-
.../processor/eventcount/EventCountController.java | 12 +-
.../processor/eventcount/EventCountParameters.java | 4 +-
.../processor/eventcount/EventCountProgram.java | 18 +-
.../flink/processor/rate/EventRate.java | 2 +-
.../flink/processor/rate/EventRateController.java | 12 +-
.../flink/processor/rate/EventRateParameter.java | 4 +-
.../flink/processor/rate/EventRateProgram.java | 16 +-
.../jvm/welford/WelfordChangeDetection.java | 6 +-
.../enricher/flink/AbstractEnricherProgram.java | 49 ----
.../enricher/flink/EnricherFlinkInit.java | 5 +-
.../processor/timestamp/TimestampController.java | 12 +-
.../processor/timestamp/TimestampParameters.java | 4 +-
.../processor/timestamp/TimestampProgram.java | 15 +-
.../UrlDereferencingController.java | 23 +-
.../UrlDereferencingParameter.java | 4 +-
.../urldereferencing/UrlDereferencingProgram.java | 14 +-
.../jvm/processor/jseval/JSEvalProcessor.java | 6 +-
.../jvm/processor/math/MathOpProcessor.java | 6 +-
.../math/staticmathop/StaticMathOpProcessor.java | 6 +-
.../sizemeasure/SizeMeasureProcessor.java | 6 +-
.../trigonometry/TrigonometryProcessor.java | 6 +-
.../valuechange/ValueChangeProcessor.java | 6 +-
.../booleanfilter/BooleanFilterProcessor.java | 6 +-
.../jvm/processor/compose/ComposeProcessor.java | 6 +-
.../processor/enrich/MergeByEnrichProcessor.java | 6 +-
.../jvm/processor/limit/RateLimitProcessor.java | 6 +-
.../jvm/processor/limit/util/WindowFactory.java | 2 +-
.../jvm/processor/limit/window/CronWindow.java | 2 +-
.../jvm/processor/limit/window/LengthWindow.java | 2 +-
.../jvm/processor/limit/window/ScheduleWindow.java | 2 +-
.../jvm/processor/limit/window/TimeWindow.java | 2 +-
.../jvm/processor/merge/MergeByTimeProcessor.java | 6 +-
.../movingaverage/MovingAverageProcessor.java | 8 +-
.../numericalfilter/NumericalFilterProcessor.java | 60 ++--
.../NumericalTextFilterProcessor.java | 6 +-
.../processor/projection/ProjectionProcessor.java | 6 +-
.../processor/schema/MergeBySchemaProcessor.java | 6 +-
.../processor/sdt/SwingingDoorTrendingFilter.java | 2 +-
.../sdt/SwingingDoorTrendingFilterProcessor.java | 6 +-
.../processor/textfilter/TextFilterProcessor.java | 8 +-
.../threshold/ThresholdDetectionProcessor.java | 6 +-
.../throughputmon/ThroughputMonitorProcessor.java | 6 +-
.../processors/siddhi/count/CountAggregation.java | 3 +-
.../filter/NumericalFilterSiddhiProcessor.java | 3 +-
.../siddhi/frequency/FrequencySiddhiProcessor.java | 5 +-
.../FrequencyChangeSiddhiProcessor.java | 7 +-
.../siddhi/listcollector/ListCollector.java | 3 +-
.../processors/siddhi/listfilter/ListFilter.java | 7 +-
.../siddhi/sequence/SequenceSiddhiProcessor.java | 7 +-
.../siddhi/stop/StreamStopSiddhiProcessor.java | 7 +-
.../streampipes/processors/siddhi/topk/TopK.java | 7 +-
.../processors/siddhi/trend/TrendProcessor.java | 7 +-
.../siddhi/trend/TestTrendProcessor.java | 6 +-
.../processor/geo/flink/AbstractGeoProgram.java | 47 ---
.../SpatialGridEnrichmentController.java | 12 +-
.../SpatialGridEnrichmentParameters.java | 4 +-
.../gridenricher/SpatialGridEnrichmentProgram.java | 14 +-
.../buffergeometry/BufferGeomProcessor.java | 6 +-
.../bufferpoint/BufferPointProcessor.java | 6 +-
.../geo/jvm/jts/processor/epsg/EpsgProcessor.java | 6 +-
.../LatLngToJtsPointProcessor.java | 6 +-
.../reprojection/ReprojectionProcessor.java | 6 +-
.../trajectory/TrajectoryFromPointsProcessor.java | 6 +-
.../complex/TopologyValidationProcessor.java | 8 +-
.../simple/GeometryValidationProcessor.java | 6 +-
.../HaversineDistanceCalculatorProcessor.java | 6 +-
...HaversineStaticDistanceCalculatorProcessor.java | 6 +-
.../googlemaps/GoogleMapsGeocoderProcessor.java | 6 +-
.../GoogleMapsStaticGeocoderProcessor.java | 6 +-
.../geocityname/GeoCityNameRevdecodeProcessor.java | 6 +-
.../speedcalculator/SpeedCalculatorProcessor.java | 6 +-
.../GenericImageClassificationProcessor.java | 6 +-
.../imagecropper/ImageCropperProcessor.java | 6 +-
.../imageenrichment/ImageEnrichmentProcessor.java | 6 +-
.../processor/qrreader/QrCodeReaderProcessor.java | 6 +-
.../flink/AbstractPatternDetectionProgram.java | 30 +-
.../flink/processor/absence/AbsenceController.java | 12 +-
.../flink/processor/absence/AbsenceParameters.java | 4 +-
.../flink/processor/absence/AbsenceProgram.java | 12 +-
.../flink/processor/and/AndController.java | 12 +-
.../flink/processor/and/AndParameters.java | 4 +-
.../detection/flink/processor/and/AndProgram.java | 8 +-
.../processor/peak/PeakDetectionController.java | 12 +-
.../processor/peak/PeakDetectionParameters.java | 4 +-
.../flink/processor/peak/PeakDetectionProgram.java | 10 +-
.../processor/sequence/SequenceController.java | 12 +-
.../processor/sequence/SequenceParameters.java | 4 +-
.../flink/processor/sequence/SequenceProgram.java | 17 +-
.../flink/AbstractStatisticsProgram.java | 49 ----
.../stat/summary/StatisticsSummaryController.java | 12 +-
.../stat/summary/StatisticsSummaryParameters.java | 4 +-
.../stat/summary/StatisticsSummaryProgram.java | 16 +-
.../window/StatisticsSummaryControllerWindow.java | 12 +-
.../window/StatisticsSummaryParametersWindow.java | 4 +-
.../window/StatisticsSummaryProgramWindow.java | 17 +-
.../pom.xml | 2 +-
.../flink/AbstractTextMiningProgram.java | 49 ----
.../language/LanguageDetectionController.java | 13 +-
.../language/LanguageDetectionParameters.java | 4 +-
.../language/LanguageDetectionProgram.java | 14 +-
.../processor/sentiment/SentimentDetection.java | 21 --
.../sentiment/SentimentDetectionController.java | 21 --
.../sentiment/SentimentDetectionParameters.java | 21 --
.../sentiment/SentimentDetectionProgram.java | 21 --
.../processor/wordcount/WordCountController.java | 13 +-
.../processor/wordcount/WordCountParameters.java | 4 +-
.../processor/wordcount/WordCountProgram.java | 16 +-
.../jvm/processor/chunker/ChunkerProcessor.java | 6 +-
.../language/LanguageDetectionProcessor.java | 6 +-
.../processor/namefinder/NameFinderProcessor.java | 6 +-
.../partofspeech/PartOfSpeechProcessor.java | 6 +-
.../SentenceDetectionProcessor.java | 6 +-
.../processor/tokenizer/TokenizerProcessor.java | 6 +-
.../flink/AbstractFlinkTransformationProgram.java | 32 +-
.../flink/TransformationFlinkInit.java | 4 -
.../boilerplate/BoilerplateController.java | 12 +-
.../boilerplate/BoilerplateParameters.java | 4 +-
.../processor/boilerplate/BoilerplateProgram.java | 10 +-
.../converter/FieldConverterController.java | 16 +-
.../converter/FieldConverterParameters.java | 4 +-
.../processor/converter/FieldConverterProgram.java | 10 +-
.../flink/processor/hasher/FieldHasher.java | 46 ---
.../processor/hasher/FieldHasherController.java | 74 -----
.../processor/hasher/FieldHasherParameters.java | 45 ---
.../flink/processor/hasher/FieldHasherProgram.java | 46 ---
.../hasher/algorithm/HashAlgorithmType.java | 33 ---
.../hasher/algorithm/Sha1HashAlgorithm.java | 32 --
.../hasher/algorithm/Sha2HashAlgorithm.java | 32 --
.../flink/processor/mapper/FieldMapper.java | 56 ----
.../processor/mapper/FieldMapperController.java | 93 ------
.../processor/mapper/FieldMapperParameters.java | 43 ---
.../flink/processor/mapper/FieldMapperProgram.java | 40 ---
.../MeasurementUnitConverterController.java | 16 +-
.../MeasurementUnitConverterParameters.java | 4 +-
.../MeasurementUnitConverterProgram.java | 10 +-
.../processor/rename/FieldRenamerController.java | 12 +-
.../processor/rename/FieldRenamerParameters.java | 4 +-
.../processor/rename/FieldRenamerProgram.java | 10 +-
.../transformation/jvm/TransformationJvmInit.java | 2 +
.../processor/array/count/CountArrayProcessor.java | 6 +-
.../processor/array/split/SplitArrayProcessor.java | 6 +-
.../counter/BooleanCounterProcessor.java | 63 ++--
.../edge/SignalEdgeFilterProcessor.java | 6 +-
.../inverter/BooleanInverterProcessor.java | 8 +-
.../logical/BooleanOperatorProcessor.java | 6 +-
.../state/BooleanToStateProcessor.java | 6 +-
.../timekeeping/BooleanTimekeepingProcessor.java | 6 +-
.../booloperator/timer/BooleanTimerProcessor.java | 6 +-
.../CsvMetadataEnrichmentProcessor.java | 14 +-
.../fieldrename/FiledRenameProcessor.java | 6 +-
.../jvm/processor/hasher/FieldHasherProcessor.java | 6 +-
.../jvm/processor/mapper/FieldMapperProcessor.java | 6 +-
.../MeasurementUnitConverterProcessor.java | 11 +-
.../state/buffer/StateBufferProcessor.java | 6 +-
.../buffer/StateBufferLabelerProcessor.java | 6 +-
.../labeler/number/NumberLabelerProcessor.java | 6 +-
.../counter/StringCounterProcessor.java | 6 +-
.../state/StringToStateProcessor.java | 6 +-
.../stringoperator/timer/StringTimerProcessor.java | 6 +-
.../jvm/processor/task/TaskDurationProcessor.java | 6 +-
.../TimestampExtractorProcessor.java | 6 +-
.../TransformToBooleanProcessor.java | 6 +-
.../change/ChangedValueDetectionProcessor.java | 6 +-
.../value/duration/CalculateDurationProcessor.java | 6 +-
.../counter/TestBooleanCounterProcessor.java | 10 +-
.../inverter/TestBooleanInverterProcessor.java | 6 +-
.../counter/TestStringCounterProcessor.java | 6 +-
.../state/TestStringToStateProcessor.java | 4 +-
.../timer/TestStringTimerProcessor.java | 4 +-
.../jvm/bufferrest/BufferRestPublisherSink.java | 4 +-
.../sinks/brokers/jvm/jms/JmsPublisherSink.java | 4 +-
.../sinks/brokers/jvm/kafka/KafkaParameters.java | 5 +-
.../sinks/brokers/jvm/kafka/KafkaPublishSink.java | 4 +-
.../sinks/brokers/jvm/mqtt/MqttClient.java | 2 +-
.../sinks/brokers/jvm/mqtt/MqttPublisherSink.java | 4 +-
.../sinks/brokers/jvm/mqtt/common/MqttOptions.java | 7 +-
.../sinks/brokers/jvm/nats/NatsController.java | 6 +-
.../sinks/brokers/jvm/pulsar/PulsarParameters.java | 5 +-
.../brokers/jvm/pulsar/PulsarPublisherSink.java | 4 +-
.../jvm/rabbitmq/RabbitMqPublisherSink.java | 4 +-
.../sinks/brokers/jvm/rest/RestSink.java | 4 +-
.../brokers/jvm/rocketmq/RocketMQParameters.java | 5 +-
.../jvm/rocketmq/RocketMQPublisherSink.java | 4 +-
.../sinks/brokers/jvm/tubemq/TubeMQParameters.java | 5 +-
.../brokers/jvm/tubemq/TubeMQPublisherSink.java | 4 +-
.../brokers/jvm/websocket/WebsocketServerSink.java | 4 +-
.../brokers/jvm/pulsar/TestPulsarParameters.java | 2 +-
.../jvm/pulsar/TestPulsarPublisherSink.java | 2 +-
.../jvm/rocketmq/TestRocketMQPublisherSink.java | 2 +-
.../elasticsearch/ElasticSearchController.java | 22 +-
.../elasticsearch/ElasticSearchParameters.java | 4 +-
.../flink/elasticsearch/ElasticSearchProgram.java | 34 +--
.../sinks/databases/jvm/couchdb/CouchDbSink.java | 4 +-
.../sinks/databases/jvm/ditto/DittoSink.java | 4 +-
.../sinks/databases/jvm/iotdb/IotDbSink.java | 4 +-
.../jdbcclient/model/JdbcConnectionParameters.java | 11 +-
.../sinks/databases/jvm/opcua/OpcUaSink.java | 4 +-
.../databases/jvm/postgresql/PostgreSqlSink.java | 7 +-
.../sinks/databases/jvm/redis/RedisSink.java | 7 +-
.../sinks/internal/jvm/datalake/DataLakeSink.java | 6 +-
.../jvm/notification/NotificationProducer.java | 12 +-
.../sinks/notifications/jvm/email/EmailSink.java | 8 +-
.../notifications/jvm/onesignal/OneSignalSink.java | 4 +-
.../jvm/slack/SlackNotificationSink.java | 4 +-
.../notifications/jvm/telegram/TelegramSink.java | 4 +-
.../watertank/streams/FlowRate2Stream.java | 1 -
.../integration/adapters/AdapterTesterBase.java | 14 +-
.../integration/adapters/MqttAdapterTester.java | 10 +-
.../integration/adapters/PulsarAdapterTester.java | 10 +-
.../connect/grounding/ProtocolDescription.java | 2 +-
.../model/message/DataSetModificationMessage.java | 51 ----
.../apache/streampipes/model/message/Message.java | 1 -
.../model/runtime/DataSetStatusMessage.java | 66 -----
.../model/template/PipelineTemplateInvocation.java | 12 +-
.../PipelineTemplateInvocationGenerator.java | 2 +-
.../PipelineTemplateInvocationHandler.java | 2 +-
.../AbstractPipelineElementResource.java | 12 +-
.../extensions/html/page/WelcomePageGenerator.java | 52 ++--
.../extensions/monitoring/MonitoringResource.java | 2 +-
.../pe/DataProcessorPipelineElementResource.java | 34 ++-
.../pe/DataSinkPipelineElementResource.java | 33 ++-
.../pe/DataStreamPipelineElementResource.java | 8 +-
.../pe/InvocablePipelineElementResource.java | 72 ++---
.../extensions/pe/PipelineTemplateResource.java | 35 ---
.../rest/impl/PipelineElementRuntimeInfo.java | 2 -
streampipes-sdk/pom.xml | 5 +
.../sdk/builder}/adapter/AdapterConfiguration.java | 37 ++-
.../adapter/AdapterConfigurationBuilder.java | 17 +-
.../processor/DataProcessorConfiguration.java | 52 ++++
.../sdk/builder/sink/DataSinkConfiguration.java | 52 ++++
.../builder/stream/DataStreamConfiguration.java | 52 ++++
.../sdk/extractor/AbstractParameterExtractor.java | 52 +++-
.../sdk/extractor/AdapterParameterExtractor.java | 3 +-
.../sdk/extractor/DataSinkParameterExtractor.java | 7 +-
.../ProcessingElementParameterExtractor.java | 6 +-
.../sdk/extractor/StaticPropertyExtractor.java | 4 +-
.../adapter/AdapterConfigurationBuilderTest.java | 14 +-
.../builder}/adapter/AdapterConfigurationTest.java | 8 +-
.../extractor/AdapterParameterExtractorTest.java | 6 +-
.../extensions/ExtensionsResourceConfig.java | 2 -
.../service/extensions/ServiceTagProvider.java | 9 +-
.../function/StreamPipesFunctionHandler.java | 14 +-
.../sources/AbstractAdapterIncludedStream.java | 17 +-
.../sources/AbstractAlreadyExistingStream.java | 25 +-
.../distributed/runtime/DistributedRuntime.java | 55 ++--
streampipes-wrapper-flink/pom.xml | 7 +-
.../flink/FlinkDataProcessorCompatProgram.java | 76 +++++
.../wrapper/flink/FlinkDataProcessorDeclarer.java | 46 ++-
...eclarer.java => FlinkDataProcessorProgram.java} | 11 +-
.../wrapper/flink/FlinkDataProcessorRuntime.java | 92 +++---
.../wrapper/flink/FlinkDataSinkCompatProgram.java | 20 +-
.../wrapper/flink/FlinkDataSinkDeclarer.java | 43 ++-
...SinkDeclarer.java => FlinkDataSinkProgram.java} | 11 +-
.../wrapper/flink/FlinkDataSinkRuntime.java | 55 ++--
.../streampipes/wrapper/flink/FlinkRuntime.java | 137 +++++----
.../wrapper/flink/FlinkRuntimeProvider.java | 20 +-
.../wrapper/flink/IDataProcessorProgram.java | 9 +-
.../wrapper/flink/IDataSinkProgram.java | 9 +-
...taProcessorDeclarer.java => IFlinkProgram.java} | 19 +-
.../flink/converter/MapToEventConverter.java | 15 +-
...clarer.java => KafkaStreamRuntimeProvider.java} | 19 +-
.../kafka/KafkaStreamsDataProcessorRuntime.java | 75 +++--
.../kafka/KafkaStreamsDataSinkDeclarer.java | 25 --
.../wrapper/kafka/KafkaStreamsDataSinkRuntime.java | 28 +-
.../wrapper/kafka/KafkaStreamsOutputCollector.java | 73 +++++
.../wrapper/kafka/KafkaStreamsRuntime.java | 78 +++--
.../wrapper/kafka/converter/MapToJsonFormat.java | 45 ---
.../wrapper/siddhi/engine/SiddhiEngine.java | 13 +-
.../wrapper/siddhi/engine/SiddhiEventEngine.java | 68 -----
.../siddhi/engine/SiddhiStatementGenerator.java | 6 +-
.../siddhi/engine/StreamPipesSiddhiProcessor.java | 36 ++-
.../callback/SiddhiOutputStreamCallback.java | 18 +-
.../engine/generator/EventTypeGenerator.java | 8 +-
.../engine/generator/InputStreamNameGenerator.java | 8 +-
.../engine/generator/SiddhiAppGenerator.java | 9 +-
.../generator/SiddhiInvocationConfigGenerator.java | 22 +-
.../siddhi/model/SiddhiProcessorParams.java | 10 +-
.../wrapper/siddhi/utils/SiddhiUtils.java | 8 +-
.../ConfiguredExternalEventProcessor.java | 33 ---
.../standalone/ConfiguredExternalEventSink.java | 32 --
.../wrapper/standalone/ProcessorParams.java | 36 ---
.../streampipes/wrapper/standalone/SinkParams.java | 36 ---
.../standalone/StreamPipesDataProcessor.java | 54 +++-
.../wrapper/standalone/StreamPipesDataSink.java | 50 +++-
.../StreamPipesExternalDataProcessor.java | 148 ----------
.../StandaloneEventProcessingDeclarer.java | 55 ----
.../StandaloneEventProcessorDeclarerSingleton.java | 60 ----
.../declarer/StandaloneEventSinkDeclarer.java | 55 ----
.../StandaloneEventSinkDeclarerSingleton.java | 54 ----
.../StandaloneExternalEventProcessingDeclarer.java | 55 ----
.../StandaloneExternalEventSinkDeclarer.java | 61 ----
.../standalone/function/FunctionContext.java | 4 +-
.../function/FunctionContextGenerator.java | 2 +-
.../standalone/function/StreamPipesFunction.java | 8 +-
.../standalone/routing/StandaloneSpCollector.java | 2 +-
.../routing/StandaloneSpInputCollector.java | 4 +-
.../routing/StandaloneSpOutputCollector.java | 4 +-
.../runtime/StandaloneEventProcessorRuntime.java | 89 +++---
.../runtime/StandaloneEventSinkRuntime.java | 68 ++---
.../StandaloneExternalEventProcessorRuntime.java | 69 -----
.../StandaloneExternalEventSinkRuntime.java | 69 -----
.../runtime/StandalonePipelineElementRuntime.java | 116 +++++---
.../StandaloneStreamPipesRuntimeProvider.java} | 22 +-
.../context/SpEventProcessorRuntimeContext.java | 28 +-
.../wrapper/context/SpEventSinkRuntimeContext.java | 12 +-
.../wrapper/context/SpRuntimeContext.java | 26 +-
.../generator/DataProcessorContextGenerator.java | 39 +++
.../generator/DataSinkContextGenerator.java | 25 +-
.../wrapper/declarer/EventProcessorDeclarer.java | 48 ---
.../wrapper/declarer/EventSinkDeclarer.java | 43 ---
.../wrapper/declarer/PipelineElementDeclarer.java | 75 -----
.../wrapper/params/DataProcessorParameters.java | 98 +++++++
...kBindingParams.java => DataSinkParameters.java} | 30 +-
.../InternalRuntimeParameters.java} | 21 +-
.../wrapper/params/PipelineElementParameters.java | 115 ++++++++
.../wrapper/params/binding/BindingParams.java | 72 -----
.../binding/EventProcessorBindingParams.java | 75 -----
.../wrapper/params/compat/ProcessorParams.java | 126 ++++++++
.../wrapper/params/compat/SinkParams.java | 97 ++++++
.../generator/DataProcessorParameterGenerator.java | 55 ++++
.../generator/DataSinkParameterGenerator.java | 51 ++++
.../PipelineElementParameterGenerator.java | 58 ++++
.../runtime/EventProcessorRuntimeParams.java | 54 ----
.../params/runtime/EventSinkRuntimeParams.java | 50 ----
.../wrapper/params/runtime/RuntimeParams.java | 112 -------
.../wrapper/runtime/EventProcessor.java | 38 ---
.../wrapper/runtime/ExternalEventProcessor.java | 31 --
.../wrapper/runtime/ExternalEventSink.java | 30 --
.../wrapper/runtime/PipelineElementRuntime.java | 63 +++-
ui/cypress/support/builder/AdapterBuilder.ts | 1 -
ui/cypress/support/utils/PipelineUtils.ts | 8 -
ui/deployment/modules.yml | 2 +-
.../src/lib/model/gen/streampipes-model.ts | 87 ++----
ui/src/app/editor/services/editor.service.ts | 1 -
532 files changed, 5459 insertions(+), 6757 deletions(-)
copy {streampipes-extensions-api => streampipes-client-api}/pom.xml (67%)
copy {streampipes-client =>
streampipes-client-api}/src/main/java/org/apache/streampipes/client/api/CRUDApi.java
(100%)
copy
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/extractor/IAdapterParameterExtractor.java
=>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IAdminApi.java
(66%)
copy
streampipes-client/src/main/java/org/apache/streampipes/client/api/CRUDApi.java
=>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/ICustomRequestApi.java
(76%)
copy
streampipes-client/src/main/java/org/apache/streampipes/client/api/CRUDApi.java
=>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataLakeMeasureApi.java
(70%)
create mode 100644
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataProcessorApi.java
create mode 100644
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataSinkApi.java
create mode 100644
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataStreamApi.java
rename
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsPipelineApi.java
=>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IFileApi.java
(82%)
rename
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsDataSinkApi.java
=>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/INotificationsApi.java
(87%)
copy
streampipes-client/src/main/java/org/apache/streampipes/client/api/CRUDApi.java
=>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IPipelineApi.java
(58%)
copy
streampipes-client/src/main/java/org/apache/streampipes/client/api/CRUDApi.java
=>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IPipelineElementTemplateApi.java
(67%)
create mode 100644
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IStreamPipesClient.java
rename {streampipes-client/src/main/java/org/apache/streampipes/client =>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api}/annotation/NotYetImplemented.java
(94%)
rename {streampipes-client/src/main/java/org/apache/streampipes/client/model
=>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/config}/ClientConnectionConfigResolver.java
(96%)
rename {streampipes-client/src/main/java/org/apache/streampipes/client/model
=>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/config}/ClientConnectionUrlResolver.java
(88%)
rename
streampipes-client/src/main/java/org/apache/streampipes/client/api/CRUDApi.java
=>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/config/IStreamPipesClientConfig.java
(66%)
rename {streampipes-client/src/main/java/org/apache/streampipes/client/model
=>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/constants}/InputStreamIndex.java
(94%)
copy {streampipes-client/src/main/java/org/apache/streampipes/client =>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api}/credentials/CredentialsProvider.java
(94%)
copy {streampipes-client/src/main/java/org/apache/streampipes/client =>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api}/live/EventProcessor.java
(95%)
rename
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsDataProcessorApi.java
=>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/live/IKafkaConfig.java
(85%)
delete mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsPipelineElementTemplateApi.java
delete mode 100644
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/DataSetReplayFinishedNotifier.java
rename
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/algorithm/HashAlgorithm.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/config/IConfigExtractor.java
(81%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/util
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/AdapterOutputCollector.java
(92%)
copy
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/extractor/IAdapterParameterExtractor.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/IAdapterConfiguration.java
(73%)
rename
{streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/IEventCollector.java
(94%)
rename
{streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/IParser.java
(90%)
rename
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/IEventHandler.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/IParserEventHandler.java
(87%)
rename
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterInterface.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/StreamPipesAdapter.java
(71%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/context/IAdapterGuessSchemaContext.java
(75%)
copy
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/context/IAdapterRuntimeContext.java
(86%)
delete mode 100644
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/PipelineTemplateDeclarer.java
rename {streampipes-sdk/src/main/java/org/apache/streampipes/sdk =>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/extractor/IAdapterParameterExtractor.java
(86%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/SemanticEventProcessingAgentDeclarer.java
=> extractor/IDataProcessorParameterExtractor.java} (77%)
copy
streampipes-client/src/main/java/org/apache/streampipes/client/credentials/CredentialsProvider.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/extractor/IDataSinkParameterExtractor.java
(79%)
create mode 100644
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/extractor/IParameterExtractor.java
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/Declarer.java
=> extractor/IStaticPropertyExtractor.java} (79%)
copy
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/routing/SpInputCollector.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/monitoring/IPipelineElementLogger.java
(85%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/monitoring/SpMonitoringManager.java
(98%)
copy
streampipes-extensions/streampipes-processors-aggregation-flink/src/main/java/org/apache/streampipes/processors/aggregation/flink/processor/rate/EventRate.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/IStreamPipesDataProcessor.java
(52%)
rename
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/runtime/EventSink.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/IStreamPipesDataSink.java
(58%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/DataStreamDeclarer.java
=> pe/IStreamPipesDataStream.java} (78%)
copy
streampipes-client/src/main/java/org/apache/streampipes/client/credentials/CredentialsProvider.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/IStreamPipesPipelineElement.java
(76%)
rename
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/algorithm/Md5HashAlgorithm.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/config/IDataProcessorConfiguration.java
(62%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/SemanticEventConsumerDeclarer.java
=> pe/config/IDataSinkConfiguration.java} (77%)
rename
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/DataStreamDeclarer.java
=> pe/config/IDataStreamConfiguration.java} (77%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/InvocableDeclarer.java
=> pe/config/IPipelineElementConfiguration.java} (67%)
rename
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsDataStreamApi.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/context/EventProcessorRuntimeContext.java
(86%)
rename {streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper =>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe}/context/EventSinkRuntimeContext.java
(93%)
rename
streampipes-client/src/main/java/org/apache/streampipes/client/credentials/CredentialsProvider.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/context/IContextGenerator.java
(75%)
rename
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/context/IAdapterRuntimeContext.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/context/RuntimeContext.java
(66%)
rename
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/context/EventProcessorRuntimeContext.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param/IDataProcessorParameters.java
(63%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/SemanticEventConsumerDeclarer.java
=> pe/param/IDataSinkParameters.java} (76%)
copy
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/routing/SpOutputCollector.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param/IInternalRuntimeParameters.java
(77%)
rename
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/runtime/PipelineElement.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param/IParameterGenerator.java
(71%)
rename
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/AbstractConfiguredPipelineElement.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param/IPipelineElementParameters.java
(52%)
rename
{streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/binding
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param}/InputStreamParams.java
(86%)
rename
{streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/binding
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param}/OutputStreamParams.java
(93%)
rename {streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper =>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe}/routing/PipelineElementCollector.java
(95%)
rename {streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper =>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe}/routing/RawDataProcessor.java
(94%)
rename {streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper =>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe}/routing/SpInputCollector.java
(93%)
copy {streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper =>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe}/routing/SpOutputCollector.java
(94%)
rename
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/SemanticEventProcessingAgentDeclarer.java
=> pe/runtime/IDataProcessorRuntime.java} (77%)
rename
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/SemanticEventConsumerDeclarer.java
=> pe/runtime/IDataSinkRuntime.java} (78%)
rename
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/InvocableDeclarer.java
=> pe/runtime/IStreamPipesRuntime.java} (66%)
rename
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/Declarer.java
=> pe/runtime/IStreamPipesRuntimeProvider.java} (76%)
rename
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/context/RuntimeContext.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/util/RuntimeContextUtils.java
(62%)
delete mode 100644
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/plc4x/passive/Plc4xPassiveAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/PullAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/PullRestAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/config/ConfigKeys.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/config/ConnectWorkerConfig.java
delete mode 100644
streampipes-extensions/streampipes-processors-aggregation-flink/src/main/java/org/apache/streampipes/processors/aggregation/flink/AbstractAggregationProgram.java
delete mode 100644
streampipes-extensions/streampipes-processors-enricher-flink/src/main/java/org/apache/streampipes/processors/enricher/flink/AbstractEnricherProgram.java
delete mode 100644
streampipes-extensions/streampipes-processors-geo-flink/src/main/java/org/apache/streampipes/processor/geo/flink/AbstractGeoProgram.java
delete mode 100644
streampipes-extensions/streampipes-processors-statistics-flink/src/main/java/org/apache/streampipes/processors/statistics/flink/AbstractStatisticsProgram.java
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-flink/src/main/java/org/apache/streampipes/processors/textmining/flink/AbstractTextMiningProgram.java
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-flink/src/main/java/org/apache/streampipes/processors/textmining/flink/processor/sentiment/SentimentDetection.java
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-flink/src/main/java/org/apache/streampipes/processors/textmining/flink/processor/sentiment/SentimentDetectionController.java
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-flink/src/main/java/org/apache/streampipes/processors/textmining/flink/processor/sentiment/SentimentDetectionParameters.java
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-flink/src/main/java/org/apache/streampipes/processors/textmining/flink/processor/sentiment/SentimentDetectionProgram.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/FieldHasher.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/FieldHasherController.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/FieldHasherParameters.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/FieldHasherProgram.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/algorithm/HashAlgorithmType.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/algorithm/Sha1HashAlgorithm.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/algorithm/Sha2HashAlgorithm.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/mapper/FieldMapper.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/mapper/FieldMapperController.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/mapper/FieldMapperParameters.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/mapper/FieldMapperProgram.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/message/DataSetModificationMessage.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/runtime/DataSetStatusMessage.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe/PipelineTemplateResource.java
rename {streampipes-model/src/main/java/org/apache/streampipes/model/connect
=>
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder}/adapter/AdapterConfiguration.java
(79%)
create mode 100644
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/processor/DataProcessorConfiguration.java
create mode 100644
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/sink/DataSinkConfiguration.java
create mode 100644
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/stream/DataStreamConfiguration.java
rename {streampipes-model/src/test/java/org/apache/streampipes/model/connect
=>
streampipes-sdk/src/test/java/org/apache/streampipes/sdk/builder}/adapter/AdapterConfigurationTest.java
(88%)
create mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataProcessorCompatProgram.java
copy
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/{FlinkDataSinkDeclarer.java
=> FlinkDataProcessorProgram.java} (75%)
copy
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/routing/SpOutputCollector.java
=>
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataSinkCompatProgram.java
(63%)
copy
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/{FlinkDataSinkDeclarer.java
=> FlinkDataSinkProgram.java} (75%)
rename
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/ConfiguredEventProcessor.java
=>
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkRuntimeProvider.java
(58%)
copy
streampipes-client/src/main/java/org/apache/streampipes/client/live/EventProcessor.java
=>
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/IDataProcessorProgram.java
(77%)
rename
streampipes-client/src/main/java/org/apache/streampipes/client/live/EventProcessor.java
=>
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/IDataSinkProgram.java
(79%)
copy
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/{FlinkDataProcessorDeclarer.java
=> IFlinkProgram.java} (59%)
rename
streampipes-wrapper-kafka-streams/src/main/java/org/apache/streampipes/wrapper/kafka/{KafkaStreamsDataProcessorDeclarer.java
=> KafkaStreamRuntimeProvider.java} (58%)
delete mode 100644
streampipes-wrapper-kafka-streams/src/main/java/org/apache/streampipes/wrapper/kafka/KafkaStreamsDataSinkDeclarer.java
create mode 100644
streampipes-wrapper-kafka-streams/src/main/java/org/apache/streampipes/wrapper/kafka/KafkaStreamsOutputCollector.java
delete mode 100644
streampipes-wrapper-kafka-streams/src/main/java/org/apache/streampipes/wrapper/kafka/converter/MapToJsonFormat.java
delete mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/SiddhiEventEngine.java
delete mode 100644
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/ConfiguredExternalEventProcessor.java
delete mode 100644
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/ConfiguredExternalEventSink.java
delete mode 100644
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/ProcessorParams.java
delete mode 100644
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/SinkParams.java
delete mode 100644
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesExternalDataProcessor.java
delete mode 100644
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/declarer/StandaloneEventProcessingDeclarer.java
delete mode 100644
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/declarer/StandaloneEventProcessorDeclarerSingleton.java
delete mode 100644
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/declarer/StandaloneEventSinkDeclarer.java
delete mode 100644
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/declarer/StandaloneEventSinkDeclarerSingleton.java
delete mode 100644
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/declarer/StandaloneExternalEventProcessingDeclarer.java
delete mode 100644
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/declarer/StandaloneExternalEventSinkDeclarer.java
delete mode 100644
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/runtime/StandaloneExternalEventProcessorRuntime.java
delete mode 100644
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/runtime/StandaloneExternalEventSinkRuntime.java
rename
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/{ConfiguredEventSink.java
=> runtime/StandaloneStreamPipesRuntimeProvider.java} (57%)
create mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/context/generator/DataProcessorContextGenerator.java
copy
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataSink.java
=>
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/context/generator/DataSinkContextGenerator.java
(50%)
delete mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/declarer/EventProcessorDeclarer.java
delete mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/declarer/EventSinkDeclarer.java
delete mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/declarer/PipelineElementDeclarer.java
create mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/DataProcessorParameters.java
rename
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/{binding/EventSinkBindingParams.java
=> DataSinkParameters.java} (51%)
rename
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/{routing/SpOutputCollector.java
=> params/InternalRuntimeParameters.java} (54%)
create mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/PipelineElementParameters.java
delete mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/binding/BindingParams.java
delete mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/binding/EventProcessorBindingParams.java
create mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/compat/ProcessorParams.java
create mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/compat/SinkParams.java
create mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/generator/DataProcessorParameterGenerator.java
create mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/generator/DataSinkParameterGenerator.java
create mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/generator/PipelineElementParameterGenerator.java
delete mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/runtime/EventProcessorRuntimeParams.java
delete mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/runtime/EventSinkRuntimeParams.java
delete mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/runtime/RuntimeParams.java
delete mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/runtime/EventProcessor.java
delete mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/runtime/ExternalEventProcessor.java
delete mode 100644
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/runtime/ExternalEventSink.java
