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/01/02 15:47:53 UTC
[streampipes] branch SP-1013 updated (dc1007e66 -> fdc38a801)
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch SP-1013
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from dc1007e66 [#1013] Update java version to 17
add 9ac56a5ab Sp 959 (#1011)
add 15aef7a4a Use ExtensionsModelSubmitter over StandaloneModelSubmitter (#956)
add 2e714c08b Remove deprecated module streampipes-container-standalone (#956)
add 6385e50a2 Modify logging output (#956)
add d3fe1b30f Fix header formatting (#956)
add b83dc65f9 Fix license formatting (#956)
add 5dfc5b3c7 [hotfix] Exclude husky in rat config
add 9c510a08b Provide extensions resource classes from a single configuration
add dec2a3176 Extract rest interfaces from extensions services into new module streampipes-rest-extensions
add b7e7446c1 Remove connect-container-worker module and move code to streampipes-container (#569)
add ea6a3c8af Merge streampipes-connect module into streampipes-container module (#569)
add 2c7b6ca96 Merge branch 'dev' into SP-958
add 6cffa09ab Merge branch 'SP-958' of github.com:apache/streampipes into SP-958
add 5010abdd9 Merge branch 'dev' into SP-958
add fa8db1068 Rename streampipes-connect-container-master module to streampipes-connect-management (#569)
add 3108a8c50 Rename streampipes-container-extensions to streampipes-service-extensions (#958)
add f2f132e53 Rename streampipes-container to streamipes-extensions-management
add 77ad34f7a Rename streampipes-backend to streampipes-service-core (#569)
add f274185de Merge streampipes-service-extensions-base into streampipes-service-extensions (#569)
add 0d1a019bd Rename streampipes-connect-api to streampipes-extensions-api (#569)
add c34fe7c7d Modify validation docker-compose file (#526)
add 5bd68c26c Add missing dependency (#569)
add 22afacd06 Merge pull request #961 from apache/SP-958
new fdc38a801 Merge branch 'dev' into SP-1013
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/build.yml | 2 +-
.idea/runConfigurations/backend.xml | 7 +-
docker-compose.yml | 8 +-
pom.xml | 21 ++--
streampipes-connect-container-worker/pom.xml | 113 ---------------------
.../init/AdapterServiceResourceProvider.java | 44 --------
.../init/AdapterWorkerContainerResourceConfig.java | 38 -------
.../worker/init/ConnectWorkerTagProvider.java | 43 --------
.../pom.xml | 7 +-
.../management}/health/AdapterHealthCheck.java | 10 +-
.../management}/health/AdapterOperationLock.java | 2 +-
.../management/AdapterMasterManagement.java | 10 +-
.../management/DescriptionManagement.java | 8 +-
.../management}/management/GuessManagement.java | 10 +-
.../management}/management/SourcesManagement.java | 8 +-
.../management/UnitMasterManagement.java | 4 +-
.../management/WorkerAdministrationManagement.java | 6 +-
.../management}/management/WorkerRestClient.java | 6 +-
.../management}/management/WorkerUrlProvider.java | 2 +-
.../connect/management/util/GroundingUtils.java | 38 ++-----
.../connect/management}/util/WorkerPaths.java | 2 +-
.../management}/health/AdapterHealthCheckTest.java | 8 +-
.../management/AdapterMasterManagementTest.java | 4 +-
.../management/DescriptionManagementTest.java | 8 +-
.../management/SourcesManagementTest.java | 2 +-
.../management/UnitMasterManagementTest.java | 4 +-
.../management/WorkerRestClientTest.java | 6 +-
.../extensions/ExtensionsResourceConfig.java | 40 --------
.../src/main/resources/banner.txt | 6 --
streampipes-container/pom.xml | 109 --------------------
.../BaseExtensionsServiceResourceProvider.java | 34 -------
.../container/init/ExtensionsResourceProvider.java | 26 -----
.../PipelineElementServiceResourceProvider.java | 39 -------
.../container/model/ExtensionsConfig.java | 35 -------
.../container/util/StandardTransportFormat.java | 54 ----------
.../apache/streampipes/container/util/Util.java | 49 ---------
.../pom.xml | 7 +-
.../api}/DataSetReplayFinishedNotifier.java | 2 +-
.../streampipes/extensions/api}/PeConfig.java | 2 +-
.../extensions/api/connect}/Connector.java | 2 +-
.../extensions/api/connect}/EmitBinaryEvent.java | 2 +-
.../extensions/api/connect}/IAdapter.java | 6 +-
.../extensions/api/connect}/IAdapterPipeline.java | 2 +-
.../api/connect}/IAdapterPipelineElement.java | 2 +-
.../extensions/api/connect}/IFormat.java | 4 +-
.../extensions/api/connect}/IParser.java | 4 +-
.../extensions/api/connect}/IProtocol.java | 6 +-
.../api/connect}/exception/AdapterException.java | 2 +-
.../api/connect}/exception/ParseException.java | 2 +-
.../connect}/exception/WorkerAdapterException.java | 2 +-
.../extensions/api}/declarer/DataSetDeclarer.java | 4 +-
.../api}/declarer/DataStreamDeclarer.java | 2 +-
.../extensions/api}/declarer/Declarer.java | 2 +-
.../api}/declarer/EventStreamDeclarer.java | 2 +-
.../declarer/IStreamPipesFunctionDeclarer.java | 2 +-
.../api}/declarer/InvocableDeclarer.java | 2 +-
.../api}/declarer/PipelineTemplateDeclarer.java | 2 +-
.../declarer/SemanticEventConsumerDeclarer.java | 2 +-
.../SemanticEventProcessingAgentDeclarer.java | 2 +-
.../declarer/SemanticEventProducerDeclarer.java | 2 +-
.../runtime}/ResolvesContainerProvidedOptions.java | 2 +-
.../ResolvesContainerProvidedOutputStrategy.java | 2 +-
.../api/runtime}/SupportsRuntimeConfig.java | 2 +-
.../pom.xml | 92 ++++++-----------
.../api/RuntimeResolvableRequestHandler.java | 4 +-
.../management}/assets/AssetZipGenerator.java | 2 +-
.../client/StreamPipesClientResolver.java | 2 +-
...StreamPipesClientRuntimeConnectionResolver.java | 2 +-
.../management}/config/ConfigExtractor.java | 2 +-
.../management/connect}/AdapterUtils.java | 14 +--
.../connect}/AdapterWorkerManagement.java | 11 +-
.../connect}/ConnectWorkerDescriptionProvider.java | 10 +-
.../extensions/management}/connect/GetNEvents.java | 4 +-
.../management/connect}/GuessManagement.java | 9 +-
.../connect}/HttpServerAdapterManagement.java | 2 +-
.../management/connect}/RuntimeResovable.java | 18 ++--
.../management}/connect/SendToPipeline.java | 8 +-
.../management}/connect/adapter/Adapter.java | 16 +--
.../connect/adapter/AdapterPipelineGenerator.java | 42 ++++----
.../connect/adapter/AdapterRegistry.java | 34 +++----
.../connect/adapter/GroundingService.java | 47 +++++++++
.../connect/adapter/format/csv/CsvFormat.java | 8 +-
.../connect/adapter/format/csv/CsvParser.java | 12 +--
.../adapter/format/geojson/GeoJsonFormat.java | 8 +-
.../adapter/format/geojson/GeoJsonParser.java | 10 +-
.../connect/adapter/format/image/ImageFormat.java | 6 +-
.../connect/adapter/format/image/ImageParser.java | 8 +-
.../adapter/format/json/AbstractJsonFormat.java | 6 +-
.../adapter/format/json/arraykey/JsonFormat.java | 6 +-
.../adapter/format/json/arraykey/JsonParser.java | 31 +++---
.../format/json/arraynokey/JsonArrayFormat.java | 6 +-
.../format/json/arraynokey/JsonArrayParser.java | 26 ++---
.../format/json/object/JsonObjectFormat.java | 6 +-
.../format/json/object/JsonObjectParser.java | 10 +-
.../adapter/format/util/JsonEventProperty.java | 2 +-
.../connect/adapter/format/xml/XmlFormat.java | 8 +-
.../adapter/format/xml/XmlMapConverter.java | 2 +-
.../connect/adapter/format/xml/XmlParser.java | 12 +--
.../connect/adapter/guess/SchemaGuesser.java | 2 +-
.../adapter/model/generic/GenericAdapter.java | 18 ++--
.../model/generic/GenericDataSetAdapter.java | 6 +-
.../model/generic/GenericDataStreamAdapter.java | 6 +-
.../connect/adapter/model/generic/Parser.java | 8 +-
.../connect/adapter/model/generic/Protocol.java | 8 +-
.../pipeline/AdapterEventPreviewPipeline.java | 8 +-
.../adapter/model/pipeline/AdapterPipeline.java | 6 +-
.../adapter/model/specific/SpecificAdapter.java | 4 +-
.../model/specific/SpecificDataSetAdapter.java | 2 +-
.../model/specific/SpecificDataStreamAdapter.java | 2 +-
.../connect/adapter/preprocessing/Util.java | 2 +-
.../elements/AddTimestampPipelineElement.java | 4 +-
.../elements/AddValuePipelineElement.java | 4 +-
.../preprocessing/elements/DebugAdapterSink.java | 4 +-
.../elements/SendToBrokerAdapterSink.java | 8 +-
.../elements/SendToBrokerReplayAdapterSink.java | 6 +-
.../elements/SendToJmsAdapterSink.java | 4 +-
.../elements/SendToKafkaAdapterSink.java | 4 +-
.../elements/SendToMqttAdapterSink.java | 4 +-
.../elements/SendToNatsAdapterSink.java | 4 +-
.../TransformSchemaAdapterPipelineElement.java | 18 ++--
.../elements/TransformStreamAdapterElement.java | 10 +-
.../TransformValueAdapterPipelineElement.java | 20 ++--
.../transform/TransformationRule.java | 2 +-
.../schema/CreateNestedTransformationRule.java | 2 +-
.../transform/schema/DeleteTransformationRule.java | 2 +-
.../transform/schema/MoveTransformationRule.java | 2 +-
.../transform/schema/RenameTransformationRule.java | 2 +-
.../transform/schema/SchemaEventTransformer.java | 4 +-
.../transform/schema/SchemaTransformationRule.java | 4 +-
.../stream/DuplicateFilterPipelineElement.java | 4 +-
.../stream/EventRateTransformationRule.java | 2 +-
.../transform/stream/StreamEventTransformer.java | 4 +-
.../transform/stream/StreamTransformationRule.java | 4 +-
.../value/CorrectionValueTransformationRule.java | 2 +-
.../value/DatatypeTransformationRule.java | 4 +-
.../value/TimestampTranformationRule.java | 2 +-
.../value/TimestampTranformationRuleMode.java | 2 +-
.../transform/value/UnitTransformationRule.java | 2 +-
.../transform/value/ValueEventTransformer.java | 4 +-
.../transform/value/ValueTransformationRule.java | 4 +-
.../connect/adapter/sdk/ParameterExtractor.java | 2 +-
.../adapter/util/AdapterOutputCollector.java | 2 +-
.../connect/adapter/util/DatatypeUtils.java | 2 +-
.../connect/adapter/util/PollingSettings.java | 2 +-
.../adapter/util/TransportFormatGenerator.java | 2 +-
.../adapter/util/TransportFormatSelector.java | 2 +-
.../management}/init/DeclarersSingleton.java | 24 ++---
.../management/init}/RunningAdapterInstances.java | 4 +-
.../management}/init/RunningDatasetInstances.java | 6 +-
.../management}/init/RunningInstances.java | 6 +-
.../management}/locales/LabelGenerator.java | 4 +-
.../management}/model/SpServiceDefinition.java | 10 +-
.../model/SpServiceDefinitionBuilder.java | 12 +--
.../monitoring/SpMonitoringManager.java | 2 +-
.../extensions/management}/util/AssetsUtil.java | 2 +-
.../extensions/management}/util/ElementInfo.java | 2 +-
.../management}/util/GroundingDebugUtils.java | 2 +-
.../extensions/management}/util/LocalesUtil.java | 2 +-
.../management}/util/ServiceDefinitionUtil.java | 8 +-
.../connect}/AdapterWorkerManagementTest.java | 15 ++-
.../extensions/management/connect}/Mock.java | 2 +-
.../extensions/management/connect}/Utils.java | 2 +-
.../connect/adapter/GroundingServiceTest.java | 2 +-
.../management}/connect/adapter/TestUtils.java | 2 +-
.../format/json/arraykey/JsonParserTest.java | 16 ++-
.../json/arraynokey/JsonArrayParserTest.java | 13 ++-
.../adapter/format/json/geojson/GeoJsonTest.java | 6 +-
.../format/json/object/JsonObjectParserTest.java | 6 +-
.../connect/adapter/format/json/xml/XmlTest.java | 6 +-
.../schema/CreateNestedTransformationRuleTest.java | 6 +-
.../schema/DeleteTransformationRuleTest.java | 6 +-
.../schema/MoveTransformationRuleTest.java | 6 +-
.../schema/RenameTransformationRuleTest.java | 6 +-
.../schema/SchemaEventTransformerTest.java | 11 +-
.../value/TimestampTransformRuleTest.java | 2 +-
.../transform/value/UnitTransformRuleTest.java | 3 +-
.../transform/value/ValueEventTransformerTest.java | 7 +-
.../streampipes-connect-adapters-iiot/pom.xml | 2 +-
.../connect/iiot/ConnectAdapterIiotInit.java | 6 +-
.../connect/iiot/adapters/PullAdapter.java | 8 +-
.../connect/iiot/adapters/PullRestAdapter.java | 2 +-
.../iiot/adapters/influxdb/InfluxDbClient.java | 2 +-
.../iiot/adapters/influxdb/InfluxDbSetAdapter.java | 10 +-
.../adapters/influxdb/InfluxDbStreamAdapter.java | 10 +-
.../connect/iiot/adapters/opcua/OpcUaAdapter.java | 10 +-
.../iiot/adapters/opcua/utils/OpcUaUtil.java | 10 +-
.../adapters/plc4x/modbus/Plc4xModbusAdapter.java | 8 +-
.../plc4x/passive/Plc4xPassiveAdapter.java | 8 +-
.../iiot/adapters/plc4x/s7/Plc4xS7Adapter.java | 6 +-
.../iiot/adapters/ros/RosBridgeAdapter.java | 12 +--
.../simulator/machine/MachineDataSimulator.java | 4 +-
.../machine/MachineDataSimulatorUtils.java | 2 +-
.../machine/MachineDataStreamAdapter.java | 8 +-
.../connect/iiot/protocol/set/FileProtocol.java | 14 +--
.../connect/iiot/protocol/set/HttpProtocol.java | 16 +--
.../iiot/protocol/stream/BrokerEventProcessor.java | 6 +-
.../iiot/protocol/stream/BrokerProtocol.java | 10 +-
.../iiot/protocol/stream/FileStreamProtocol.java | 22 ++--
.../protocol/stream/HttpServerEventReceiver.java | 2 +-
.../iiot/protocol/stream/HttpServerProtocol.java | 14 +--
.../iiot/protocol/stream/HttpStreamProtocol.java | 12 +--
.../iiot/protocol/stream/KafkaProtocol.java | 14 +--
.../connect/iiot/protocol/stream/MqttProtocol.java | 12 +--
.../connect/iiot/protocol/stream/NatsProtocol.java | 14 +--
.../connect/iiot/protocol/stream/PullProtocol.java | 12 +--
.../protocol/stream/pulsar/PulsarProtocol.java | 16 +--
.../protocol/stream/rocketmq/RocketMQProtocol.java | 16 +--
.../connect/iiot/utils/FileProtocolUtils.java | 4 +-
.../streampipes-connect-adapters/pom.xml | 2 +-
.../streampipes/connect/ConnectAdapterInit.java | 6 +-
.../streampipes/connect/adapters/PullAdapter.java | 6 +-
.../connect/adapters/PullRestAdapter.java | 2 +-
.../adapters/coindesk/CoindeskBitcoinAdapter.java | 10 +-
.../connect/adapters/flic/FlicMQTTAdapter.java | 8 +-
.../connect/adapters/gdelt/GdeltAdapter.java | 6 +-
.../connect/adapters/iex/IexCloudAdapter.java | 2 +-
.../connect/adapters/iex/IexCloudNewsAdapter.java | 8 +-
.../connect/adapters/iex/IexCloudStockAdapter.java | 8 +-
.../connect/adapters/image/ImageZipAdapter.java | 4 +-
.../adapters/image/ZipFileImageIterator.java | 2 +-
.../adapters/image/set/ImageSetAdapter.java | 8 +-
.../adapters/image/stream/ImageStreamAdapter.java | 8 +-
.../connect/adapters/iss/IssAdapter.java | 8 +-
.../connect/adapters/netio/NetioMQTTAdapter.java | 8 +-
.../connect/adapters/netio/NetioRestAdapter.java | 8 +-
.../adapters/sensemap/OpenSenseMapAdapter.java | 6 +-
.../simulator/random/RandomDataSetAdapter.java | 10 +-
.../simulator/random/RandomDataSimulator.java | 2 +-
.../simulator/random/RandomDataStreamAdapter.java | 10 +-
.../connect/adapters/slack/SlackAdapter.java | 10 +-
.../connect/adapters/slack/SlackConsumer.java | 2 +-
.../connect/adapters/ti/TISensorTag.java | 8 +-
.../adapters/wikipedia/WikipediaAdapter.java | 6 +-
.../wikipedia/WikipediaEditedArticlesAdapter.java | 2 +-
.../wikipedia/WikipediaNewArticlesAdapter.java | 2 +-
.../adapters/wikipedia/WikipediaSseConsumer.java | 2 +-
.../connect/adapters/generic/UtilTest.java | 4 +-
.../generic/elements/AddTimestampTest.java | 2 +-
.../generic/elements/DuplicateFilterTest.java | 2 +-
.../streampipes-extensions-all-iiot/pom.xml | 2 +-
.../extensions/all/iiot/AllExtensionsIIoTInit.java | 6 +-
.../streampipes-extensions-all-jvm/pom.xml | 2 +-
.../extensions/all/jvm/AllExtensionsInit.java | 6 +-
.../pe/flink/AllFlinkPipelineElementsInit.java | 6 +-
.../pe/jvm/AllPipelineElementsInit.java | 6 +-
.../pe/jvm/config/AllPipelineElementsConfig.java | 2 +-
.../flink/AbstractAggregationProgram.java | 2 +-
.../aggregation/flink/AggregationFlinkInit.java | 6 +-
.../aggregation/AggregationController.java | 4 +-
.../processor/aggregation/AggregationProgram.java | 2 +-
.../flink/processor/count/CountController.java | 2 +-
.../flink/processor/count/CountProgram.java | 2 +-
.../processor/eventcount/EventCountController.java | 2 +-
.../processor/eventcount/EventCountProgram.java | 2 +-
.../flink/processor/rate/EventRateController.java | 2 +-
.../flink/processor/rate/EventRateProgram.java | 2 +-
.../aggregation/TestTimeAggregationProgram.java | 2 +-
.../flink/processor/count/TestCountProgram.java | 2 +-
.../flink/processor/rate/TestRateProgram.java | 2 +-
.../jvm/ChangeDetectionJvmInit.java | 6 +-
.../enricher/flink/AbstractEnricherProgram.java | 2 +-
.../enricher/flink/EnricherFlinkInit.java | 6 +-
.../processor/timestamp/TimestampController.java | 2 +-
.../processor/timestamp/TimestampProgram.java | 2 +-
.../UrlDereferencingController.java | 2 +-
.../urldereferencing/UrlDereferencingProgram.java | 2 +-
.../processors/enricher/jvm/EnricherJvmInit.java | 6 +-
.../processors/filters/jvm/FiltersJvmInit.java | 6 +-
.../processors/siddhi/FiltersSiddhiInit.java | 6 +-
.../siddhi/listcollector/ListCollector.java | 2 +-
.../processor/geo/flink/AbstractGeoProgram.java | 2 +-
.../processor/geo/flink/GeoFlinkInit.java | 6 +-
.../SpatialGridEnrichmentController.java | 2 +-
.../gridenricher/SpatialGridEnrichmentProgram.java | 2 +-
.../streampipes/processors/geo/jvm/GeoJvmInit.java | 6 +-
.../jvm/ImageProcessingJvmInit.java | 6 +-
.../flink/AbstractPatternDetectionProgram.java | 2 +-
.../detection/flink/PatternDetectionFlinkInit.java | 6 +-
.../flink/processor/absence/AbsenceController.java | 2 +-
.../flink/processor/absence/AbsenceProgram.java | 2 +-
.../flink/processor/and/AndController.java | 2 +-
.../detection/flink/processor/and/AndProgram.java | 2 +-
.../processor/peak/PeakDetectionController.java | 2 +-
.../flink/processor/peak/PeakDetectionProgram.java | 3 +-
.../processor/sequence/SequenceController.java | 2 +-
.../flink/processor/sequence/SequenceProgram.java | 2 +-
.../detection/processor/absence/TestAbsence.java | 2 +-
.../pattern/detection/processor/and/TestAnd.java | 2 +-
.../flink/AbstractStatisticsProgram.java | 2 +-
.../statistics/flink/StatisticsFlinkInit.java | 6 +-
.../stat/summary/StatisticsSummaryController.java | 4 +-
.../stat/summary/StatisticsSummaryProgram.java | 2 +-
.../window/StatisticsSummaryControllerWindow.java | 2 +-
.../window/StatisticsSummaryProgramWindow.java | 2 +-
.../flink/AbstractTextMiningProgram.java | 2 +-
.../textmining/flink/TextMiningFlinkInit.java | 6 +-
.../language/LanguageDetectionController.java | 2 +-
.../language/LanguageDetectionProgram.java | 2 +-
.../processor/wordcount/WordCountController.java | 2 +-
.../processor/wordcount/WordCountProgram.java | 2 +-
.../textmining/jvm/TextMiningJvmInit.java | 6 +-
.../jvm/processor/chunker/ChunkerController.java | 2 +-
.../language/LanguageDetectionController.java | 2 +-
.../processor/namefinder/NameFinderController.java | 2 +-
.../partofspeech/PartOfSpeechController.java | 2 +-
.../SentenceDetectionController.java | 2 +-
.../processor/tokenizer/TokenizerController.java | 2 +-
.../IgnoreBlocksAfterContentFromEndFilter.java | 6 +-
.../boilerpipe/sax/BoilerpipeHTMLParser.java | 7 +-
.../flink/AbstractFlinkTransformationProgram.java | 2 +-
.../flink/TransformationFlinkInit.java | 6 +-
.../boilerplate/BoilerplateController.java | 2 +-
.../processor/boilerplate/BoilerplateProgram.java | 2 +-
.../converter/FieldConverterController.java | 6 +-
.../processor/converter/FieldConverterProgram.java | 2 +-
.../processor/hasher/FieldHasherController.java | 2 +-
.../flink/processor/hasher/FieldHasherProgram.java | 2 +-
.../processor/mapper/FieldMapperController.java | 4 +-
.../flink/processor/mapper/FieldMapperProgram.java | 2 +-
.../MeasurementUnitConverterController.java | 4 +-
.../MeasurementUnitConverterProgram.java | 2 +-
.../processor/rename/FieldRenamerController.java | 2 +-
.../processor/rename/FieldRenamerProgram.java | 2 +-
.../processor/converter/TestConverterProgram.java | 3 +-
.../processor/hasher/TestFieldHasherProgram.java | 2 +-
.../flink/processor/rename/TestRenameProgram.java | 2 +-
.../transformation/jvm/TransformationJvmInit.java | 6 +-
.../array/split/SplitArrayController.java | 2 +-
.../CsvMetadataEnrichmentController.java | 6 +-
.../jvm/processor/mapper/FieldMapperProcessor.java | 2 +-
.../MeasurementUnitConverterProcessor.java | 2 +-
.../buffer/StateBufferLabelerController.java | 2 +-
.../labeler/number/NumberLabelerController.java | 2 +-
.../TimestampExtractorController.java | 2 +-
.../TransformToBooleanController.java | 2 +-
.../sinks/brokers/jvm/BrokersJvmInit.java | 6 +-
.../sinks/databases/flink/DatabasesFlinkInit.java | 6 +-
.../elasticsearch/ElasticSearchController.java | 2 +-
.../flink/elasticsearch/ElasticSearchProgram.java | 2 +-
.../sinks/databases/jvm/DatabasesJvmInit.java | 6 +-
.../sinks/internal/jvm/SinksInternalJvmInit.java | 6 +-
.../jvm/SinksNotificationsJvmInit.java | 6 +-
.../vehicle/simulator/VehicleSimulatorInit.java | 6 +-
.../simulator/simulator/VehicleDataSimulator.java | 4 +-
.../simulator/WatertankSimulatorInit.java | 6 +-
.../simulator/utils/WatertankDataSimulator.java | 4 +-
streampipes-integration-tests/pom.xml | 8 +-
.../integration/adapters/AdapterTesterBase.java | 10 +-
.../integration/adapters/PulsarAdapterTester.java | 4 +-
streampipes-pipeline-management/pom.xml | 2 +-
.../manager/endpoint/EndpointItemFetcher.java | 5 +-
.../manager/endpoint/EndpointItemParser.java | 5 +-
.../streampipes/manager/matching/v2/TestUtils.java | 6 +-
.../pom.xml | 46 ++++++---
.../extensions}/AbstractExtensionsResource.java | 2 +-
.../AbstractPipelineElementResource.java | 10 +-
.../streampipes/rest/extensions}/WelcomePage.java | 10 +-
.../extensions/connect}/AdapterAssetResource.java | 8 +-
.../extensions/connect}/AdapterWorkerResource.java | 6 +-
.../rest/extensions/connect}/GuessResource.java | 8 +-
.../connect}/HttpServerAdapterResource.java | 4 +-
.../connect}/RuntimeResolvableResource.java | 12 +--
.../rest/extensions}/html/HTMLGenerator.java | 6 +-
.../rest/extensions}/html/JSONGenerator.java | 6 +-
.../html/model/DataSourceDescriptionHtml.java | 2 +-
.../rest/extensions}/html/model/Description.java | 2 +-
.../html/page/WelcomePageGenerator.java | 18 ++--
.../extensions/monitoring}/MonitoringResource.java | 5 +-
.../pe}/DataProcessorPipelineElementResource.java | 8 +-
.../pe}/DataSinkPipelineElementResource.java | 8 +-
.../pe}/DataStreamPipelineElementResource.java | 13 +--
.../pe}/InvocablePipelineElementResource.java | 15 ++-
.../extensions/pe}/PipelineTemplateResource.java | 7 +-
streampipes-rest/pom.xml | 2 +-
.../apache/streampipes/rest/ResetManagement.java | 4 +-
.../rest/impl/connect/AdapterResource.java | 4 +-
.../rest/impl/connect/DescriptionResource.java | 6 +-
.../rest/impl/connect/GuessResource.java | 6 +-
.../impl/connect/RuntimeResolvableResource.java | 8 +-
.../rest/impl/connect/SourcesResource.java | 4 +-
.../rest/impl/connect/UnitResource.java | 4 +-
.../rest/impl/connect/WelcomePageMaster.java | 91 -----------------
.../impl/connect/WorkerAdministrationResource.java | 2 +-
streampipes-sdk-bundle/pom.xml | 2 +-
.../Dockerfile | 0
.../development/env | 0
.../pom.xml | 6 +-
.../core}/StreamPipesBackendApplication.java | 4 +-
.../service/core}/StreamPipesEnvChecker.java | 2 +-
.../service/core}/StreamPipesPasswordEncoder.java | 2 +-
.../service/core}/StreamPipesResourceConfig.java | 4 +-
.../service/core}/UnauthenticatedInterfaces.java | 2 +-
.../service/core}/WebSecurityConfig.java | 2 +-
.../service/core}/WelcomePageController.java | 2 +-
.../core}/migrations/AvailableMigrations.java | 10 +-
.../service/core}/migrations/Migration.java | 2 +-
.../core}/migrations/MigrationsHandler.java | 2 +-
.../v070/CreateAssetLinkTypeMigration.java | 4 +-
.../v070/CreateDefaultAssetMigration.java | 4 +-
.../v070/CreateFileAssetTypeMigration.java | 4 +-
.../v090/UpdateUsernameViewMigration.java | 4 +-
.../src/main/resources/application.properties | 0
.../src/main/resources/banner.txt | 0
.../src/main/resources/openapi.yaml | 0
.../src/main/resources/static/index.html | 0
.../pom.xml | 12 +--
.../extensions/ExtensionsModelSubmitter.java | 15 ++-
.../extensions/ExtensionsResourceConfig.java | 76 ++++++++++++++
.../ExtensionsServiceShutdownHandler.java | 4 +-
.../service}/extensions/ServiceTagProvider.java | 20 ++--
.../StreamPipesExtensionsServiceBase.java | 6 +-
.../extensions/connect/ConnectRestClient.java | 8 +-
.../connect}/ConnectWorkerRegistrationService.java | 8 +-
.../function/FunctionDeregistrationHandler.java | 2 +-
.../function/FunctionRegistrationHandler.java | 2 +-
.../extensions/function/RegistrationHandler.java | 4 +-
.../function/StreamPipesFunctionHandler.java | 6 +-
.../security/TokenAuthenticationFilter.java | 2 +-
.../security/UnauthenticatedInterfaces.java | 2 +-
.../extensions/security}/WebSecurityConfig.java | 4 +-
.../src/main/resources/application.properties | 0
.../src/main/resources/banner.txt | 2 +-
streampipes-sources/pom.xml | 4 +-
.../sources/AbstractAdapterIncludedStream.java | 6 +-
.../sources/AbstractAlreadyExistingStream.java | 6 +-
.../distributed/runtime/DistributedRuntime.java | 2 +-
.../wrapper/flink/FlinkDataProcessorRuntime.java | 2 +-
.../wrapper/flink/FlinkDataSinkRuntime.java | 2 +-
.../streampipes/wrapper/flink/FlinkRuntime.java | 2 +-
.../StandaloneEventProcessingDeclarer.java | 2 +-
.../StandaloneEventProcessorDeclarerSingleton.java | 2 +-
.../declarer/StandaloneEventSinkDeclarer.java | 2 +-
.../StandaloneEventSinkDeclarerSingleton.java | 2 +-
.../StandaloneExternalEventProcessingDeclarer.java | 2 +-
.../StandaloneExternalEventSinkDeclarer.java | 2 +-
.../standalone/function/FunctionContext.java | 4 +-
.../function/FunctionContextGenerator.java | 2 +-
.../standalone/function/StreamPipesFunction.java | 6 +-
.../routing/StandaloneSpOutputCollector.java | 2 +-
.../runtime/StandalonePipelineElementRuntime.java | 2 +-
streampipes-wrapper/pom.xml | 4 +-
.../wrapper/context/RuntimeContext.java | 4 +-
.../context/SpEventProcessorRuntimeContext.java | 4 +-
.../wrapper/context/SpEventSinkRuntimeContext.java | 4 +-
.../wrapper/context/SpRuntimeContext.java | 4 +-
.../wrapper/declarer/EventProcessorDeclarer.java | 2 +-
.../wrapper/declarer/EventSinkDeclarer.java | 2 +-
.../wrapper/declarer/PipelineElementDeclarer.java | 4 +-
.../runtime/EventProcessorRuntimeParams.java | 4 +-
.../params/runtime/EventSinkRuntimeParams.java | 4 +-
.../wrapper/params/runtime/RuntimeParams.java | 2 +-
451 files changed, 1340 insertions(+), 1958 deletions(-)
delete mode 100644 streampipes-connect-container-worker/pom.xml
delete mode 100644 streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/AdapterServiceResourceProvider.java
delete mode 100644 streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/AdapterWorkerContainerResourceConfig.java
delete mode 100644 streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/ConnectWorkerTagProvider.java
rename {streampipes-connect-container-master => streampipes-connect-management}/pom.xml (93%)
rename {streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management}/health/AdapterHealthCheck.java (93%)
rename {streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management}/health/AdapterOperationLock.java (94%)
rename {streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management}/management/AdapterMasterManagement.java (96%)
rename {streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management}/management/DescriptionManagement.java (91%)
rename {streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management}/management/GuessManagement.java (89%)
rename {streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management}/management/SourcesManagement.java (94%)
rename {streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management}/management/UnitMasterManagement.java (94%)
rename {streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management}/management/WorkerAdministrationManagement.java (93%)
rename {streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management}/management/WorkerRestClient.java (98%)
rename {streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management}/management/WorkerUrlProvider.java (95%)
rename streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/GroundingService.java => streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/util/GroundingUtils.java (81%)
rename {streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management}/util/WorkerPaths.java (97%)
rename {streampipes-connect-container-master/src/test/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management}/health/AdapterHealthCheckTest.java (95%)
rename {streampipes-connect-container-master/src/test/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management}/management/AdapterMasterManagementTest.java (96%)
rename {streampipes-connect-container-master/src/test/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management}/management/DescriptionManagementTest.java (87%)
rename {streampipes-connect-container-master/src/test/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management}/management/SourcesManagementTest.java (96%)
rename {streampipes-connect-container-master/src/test/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management}/management/UnitMasterManagementTest.java (97%)
rename {streampipes-connect-container-master/src/test/java/org/apache/streampipes/connect/container/master => streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management}/management/WorkerRestClientTest.java (96%)
delete mode 100644 streampipes-container-extensions/src/main/java/org/apache/streampipes/container/extensions/ExtensionsResourceConfig.java
delete mode 100644 streampipes-container-extensions/src/main/resources/banner.txt
delete mode 100644 streampipes-container/pom.xml
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/init/BaseExtensionsServiceResourceProvider.java
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/init/ExtensionsResourceProvider.java
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/init/PipelineElementServiceResourceProvider.java
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/model/ExtensionsConfig.java
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/util/StandardTransportFormat.java
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/util/Util.java
rename {streampipes-connect-api => streampipes-extensions-api}/pom.xml (88%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container/model => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/DataSetReplayFinishedNotifier.java (94%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container/model => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/PeConfig.java (95%)
rename {streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/Connector.java (93%)
rename {streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/EmitBinaryEvent.java (94%)
rename {streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/IAdapter.java (87%)
rename {streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/IAdapterPipeline.java (95%)
rename {streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/IAdapterPipelineElement.java (94%)
rename {streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/IFormat.java (91%)
rename {streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/IParser.java (92%)
rename {streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/IProtocol.java (88%)
rename {streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/exception/AdapterException.java (94%)
rename {streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/exception/ParseException.java (94%)
rename {streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect}/exception/WorkerAdapterException.java (95%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/declarer/DataSetDeclarer.java (89%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/declarer/DataStreamDeclarer.java (94%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/declarer/Declarer.java (94%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/declarer/EventStreamDeclarer.java (94%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/declarer/IStreamPipesFunctionDeclarer.java (95%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/declarer/InvocableDeclarer.java (95%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/declarer/PipelineTemplateDeclarer.java (94%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/declarer/SemanticEventConsumerDeclarer.java (94%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/declarer/SemanticEventProcessingAgentDeclarer.java (95%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/declarer/SemanticEventProducerDeclarer.java (94%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container/api => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/runtime}/ResolvesContainerProvidedOptions.java (96%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container/api => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/runtime}/ResolvesContainerProvidedOutputStrategy.java (96%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container/api => streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/runtime}/SupportsRuntimeConfig.java (95%)
rename {streampipes-connect => streampipes-extensions-management}/pom.xml (73%)
mode change 100755 => 100644
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/api/RuntimeResolvableRequestHandler.java (92%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/assets/AssetZipGenerator.java (97%)
rename {streampipes-service-extensions-base/src/main/java/org/apache/streampipes/service/extensions/base => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/client/StreamPipesClientResolver.java (94%)
rename {streampipes-service-extensions-base/src/main/java/org/apache/streampipes/service/extensions/base => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/client/StreamPipesClientRuntimeConnectionResolver.java (98%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/config/ConfigExtractor.java (95%)
rename {streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/utils => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect}/AdapterUtils.java (81%)
rename {streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect}/AdapterWorkerManagement.java (88%)
rename {streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect}/ConnectWorkerDescriptionProvider.java (93%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/GetNEvents.java (90%)
rename {streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect}/GuessManagement.java (87%)
rename {streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect}/HttpServerAdapterManagement.java (96%)
rename {streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect}/RuntimeResovable.java (76%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/SendToPipeline.java (83%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/Adapter.java (85%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/AdapterPipelineGenerator.java (76%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/AdapterRegistry.java (56%)
create mode 100644 streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/GroundingService.java
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/csv/CsvFormat.java (93%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/csv/CsvParser.java (91%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/geojson/GeoJsonFormat.java (93%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/geojson/GeoJsonParser.java (93%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/image/ImageFormat.java (89%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/image/ImageParser.java (84%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/json/AbstractJsonFormat.java (86%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/json/arraykey/JsonFormat.java (87%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/json/arraykey/JsonParser.java (84%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/json/arraynokey/JsonArrayFormat.java (86%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/json/arraynokey/JsonArrayParser.java (87%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/json/object/JsonObjectFormat.java (86%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/json/object/JsonObjectParser.java (89%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/util/JsonEventProperty.java (98%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/xml/XmlFormat.java (89%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/xml/XmlMapConverter.java (97%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/format/xml/XmlParser.java (89%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/guess/SchemaGuesser.java (94%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/model/generic/GenericAdapter.java (86%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/model/generic/GenericDataSetAdapter.java (91%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/model/generic/GenericDataStreamAdapter.java (91%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/model/generic/Parser.java (82%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/model/generic/Protocol.java (82%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/model/pipeline/AdapterEventPreviewPipeline.java (88%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/model/pipeline/AdapterPipeline.java (90%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/model/specific/SpecificAdapter.java (88%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/model/specific/SpecificDataSetAdapter.java (93%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/model/specific/SpecificDataStreamAdapter.java (94%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/Util.java (96%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/elements/AddTimestampPipelineElement.java (87%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/elements/AddValuePipelineElement.java (87%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/elements/DebugAdapterSink.java (90%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/elements/SendToBrokerAdapterSink.java (90%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/elements/SendToBrokerReplayAdapterSink.java (92%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/elements/SendToJmsAdapterSink.java (89%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/elements/SendToKafkaAdapterSink.java (89%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/elements/SendToMqttAdapterSink.java (89%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/elements/SendToNatsAdapterSink.java (89%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/elements/TransformSchemaAdapterPipelineElement.java (77%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/elements/TransformStreamAdapterElement.java (84%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/elements/TransformValueAdapterPipelineElement.java (77%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/TransformationRule.java (90%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/schema/CreateNestedTransformationRule.java (94%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/schema/DeleteTransformationRule.java (94%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/schema/MoveTransformationRule.java (97%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/schema/RenameTransformationRule.java (94%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/schema/SchemaEventTransformer.java (95%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/schema/SchemaTransformationRule.java (80%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/stream/DuplicateFilterPipelineElement.java (93%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/stream/EventRateTransformationRule.java (94%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/stream/StreamEventTransformer.java (90%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/stream/StreamTransformationRule.java (80%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/value/CorrectionValueTransformationRule.java (96%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/value/DatatypeTransformationRule.java (90%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/value/TimestampTranformationRule.java (96%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/value/TimestampTranformationRuleMode.java (89%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/value/UnitTransformationRule.java (96%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/value/ValueEventTransformer.java (92%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/preprocessing/transform/value/ValueTransformationRule.java (80%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/sdk/ParameterExtractor.java (98%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/util/AdapterOutputCollector.java (92%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/util/DatatypeUtils.java (98%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/util/PollingSettings.java (95%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/util/TransportFormatGenerator.java (96%)
rename {streampipes-connect/src/main/java/org/apache/streampipes => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/connect/adapter/util/TransportFormatSelector.java (97%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/init/DeclarersSingleton.java (93%)
rename {streampipes-connect/src/main/java/org/apache/streampipes/connect => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/init}/RunningAdapterInstances.java (93%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/init/RunningDatasetInstances.java (89%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/init/RunningInstances.java (92%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/locales/LabelGenerator.java (97%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/model/SpServiceDefinition.java (94%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/model/SpServiceDefinitionBuilder.java (93%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/monitoring/SpMonitoringManager.java (98%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/util/AssetsUtil.java (95%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/util/ElementInfo.java (95%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/util/GroundingDebugUtils.java (95%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/util/LocalesUtil.java (94%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/util/ServiceDefinitionUtil.java (91%)
rename {streampipes-connect-container-worker/src/test/java/org/apache/streampipes/connect/container/worker/management => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect}/AdapterWorkerManagementTest.java (87%)
rename {streampipes-connect-container-worker/src/test/java/org/apache/streampipes/connect/container/worker/management => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect}/Mock.java (93%)
rename {streampipes-connect-container-worker/src/test/java/org/apache/streampipes/connect/container/worker/utils => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect}/Utils.java (96%)
rename {streampipes-connect/src/test/java/org/apache/streampipes => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management}/connect/adapter/GroundingServiceTest.java (98%)
rename {streampipes-connect/src/test/java/org/apache/streampipes => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management}/connect/adapter/TestUtils.java (95%)
rename {streampipes-connect/src/test/java/org/apache/streampipes => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management}/connect/adapter/format/json/arraykey/JsonParserTest.java (82%)
rename {streampipes-connect/src/test/java/org/apache/streampipes => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management}/connect/adapter/format/json/arraynokey/JsonArrayParserTest.java (85%)
rename {streampipes-connect/src/test/java/org/apache/streampipes => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management}/connect/adapter/format/json/geojson/GeoJsonTest.java (98%)
rename {streampipes-connect/src/test/java/org/apache/streampipes => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management}/connect/adapter/format/json/object/JsonObjectParserTest.java (88%)
rename {streampipes-connect/src/test/java/org/apache/streampipes => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management}/connect/adapter/format/json/xml/XmlTest.java (99%)
rename {streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/preprocessing => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter}/transform/schema/CreateNestedTransformationRuleTest.java (90%)
rename {streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/preprocessing => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter}/transform/schema/DeleteTransformationRuleTest.java (89%)
rename {streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/preprocessing => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter}/transform/schema/MoveTransformationRuleTest.java (93%)
rename {streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/preprocessing => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter}/transform/schema/RenameTransformationRuleTest.java (91%)
rename {streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/preprocessing => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter}/transform/schema/SchemaEventTransformerTest.java (76%)
rename {streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/preprocessing => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter}/transform/value/TimestampTransformRuleTest.java (99%)
rename {streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/preprocessing => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter}/transform/value/UnitTransformRuleTest.java (96%)
rename {streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/preprocessing => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter}/transform/value/ValueEventTransformerTest.java (81%)
rename {streampipes-service-extensions-base => streampipes-rest-extensions}/pom.xml (59%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container/api => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions}/AbstractExtensionsResource.java (96%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container/api => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions}/AbstractPipelineElementResource.java (94%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container/api => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions}/WelcomePage.java (83%)
rename {streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/connect}/AdapterAssetResource.java (91%)
rename {streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/connect}/AdapterWorkerResource.java (95%)
rename {streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/connect}/GuessResource.java (88%)
rename {streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/connect}/HttpServerAdapterResource.java (89%)
rename {streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/connect}/RuntimeResolvableResource.java (86%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions}/html/HTMLGenerator.java (94%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions}/html/JSONGenerator.java (92%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions}/html/model/DataSourceDescriptionHtml.java (95%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions}/html/model/Description.java (98%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions}/html/page/WelcomePageGenerator.java (86%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container/api => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/monitoring}/MonitoringResource.java (85%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container/api => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe}/DataProcessorPipelineElementResource.java (88%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container/api => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe}/DataSinkPipelineElementResource.java (88%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container/api => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe}/DataStreamPipelineElementResource.java (88%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container/api => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe}/InvocablePipelineElementResource.java (90%)
rename {streampipes-container/src/main/java/org/apache/streampipes/container/api => streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe}/PipelineTemplateResource.java (80%)
delete mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/connect/WelcomePageMaster.java
rename {streampipes-backend => streampipes-service-core}/Dockerfile (100%)
rename {streampipes-backend => streampipes-service-core}/development/env (100%)
rename {streampipes-backend => streampipes-service-core}/pom.xml (96%)
rename {streampipes-backend/src/main/java/org/apache/streampipes/backend => streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/StreamPipesBackendApplication.java (98%)
rename {streampipes-backend/src/main/java/org/apache/streampipes/backend => streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/StreamPipesEnvChecker.java (98%)
rename {streampipes-backend/src/main/java/org/apache/streampipes/backend => streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/StreamPipesPasswordEncoder.java (96%)
rename {streampipes-backend/src/main/java/org/apache/streampipes/backend => streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/StreamPipesResourceConfig.java (98%)
rename {streampipes-backend/src/main/java/org/apache/streampipes/backend => streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/UnauthenticatedInterfaces.java (97%)
rename {streampipes-backend/src/main/java/org/apache/streampipes/backend => streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/WebSecurityConfig.java (98%)
rename {streampipes-backend/src/main/java/org/apache/streampipes/backend => streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/WelcomePageController.java (95%)
rename {streampipes-backend/src/main/java/org/apache/streampipes/backend => streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/migrations/AvailableMigrations.java (73%)
rename {streampipes-backend/src/main/java/org/apache/streampipes/backend => streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/migrations/Migration.java (94%)
rename {streampipes-backend/src/main/java/org/apache/streampipes/backend => streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/migrations/MigrationsHandler.java (96%)
rename {streampipes-backend/src/main/java/org/apache/streampipes/backend => streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/migrations/v070/CreateAssetLinkTypeMigration.java (92%)
rename {streampipes-backend/src/main/java/org/apache/streampipes/backend => streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/migrations/v070/CreateDefaultAssetMigration.java (92%)
rename {streampipes-backend/src/main/java/org/apache/streampipes/backend => streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/migrations/v070/CreateFileAssetTypeMigration.java (94%)
rename {streampipes-backend/src/main/java/org/apache/streampipes/backend => streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/migrations/v090/UpdateUsernameViewMigration.java (94%)
rename {streampipes-backend => streampipes-service-core}/src/main/resources/application.properties (100%)
rename {streampipes-backend => streampipes-service-core}/src/main/resources/banner.txt (100%)
rename {streampipes-backend => streampipes-service-core}/src/main/resources/openapi.yaml (100%)
rename {streampipes-backend => streampipes-service-core}/src/main/resources/static/index.html (100%)
rename {streampipes-container-extensions => streampipes-service-extensions}/pom.xml (86%)
rename {streampipes-container-extensions/src/main/java/org/apache/streampipes/container => streampipes-service-extensions/src/main/java/org/apache/streampipes/service}/extensions/ExtensionsModelSubmitter.java (80%)
create mode 100644 streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/ExtensionsResourceConfig.java
rename {streampipes-container-extensions/src/main/java/org/apache/streampipes/container => streampipes-service-extensions/src/main/java/org/apache/streampipes/service}/extensions/ExtensionsServiceShutdownHandler.java (92%)
rename {streampipes-container-extensions/src/main/java/org/apache/streampipes/container => streampipes-service-extensions/src/main/java/org/apache/streampipes/service}/extensions/ServiceTagProvider.java (66%)
rename {streampipes-service-extensions-base/src/main/java/org/apache/streampipes/service/extensions/base => streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions}/StreamPipesExtensionsServiceBase.java (94%)
rename streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management/MasterRestClient.java => streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/connect/ConnectRestClient.java (84%)
rename {streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init => streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/connect}/ConnectWorkerRegistrationService.java (84%)
rename {streampipes-container-extensions/src/main/java/org/apache/streampipes/container => streampipes-service-extensions/src/main/java/org/apache/streampipes/service}/extensions/function/FunctionDeregistrationHandler.java (96%)
rename {streampipes-container-extensions/src/main/java/org/apache/streampipes/container => streampipes-service-extensions/src/main/java/org/apache/streampipes/service}/extensions/function/FunctionRegistrationHandler.java (96%)
rename {streampipes-container-extensions/src/main/java/org/apache/streampipes/container => streampipes-service-extensions/src/main/java/org/apache/streampipes/service}/extensions/function/RegistrationHandler.java (93%)
rename {streampipes-container-extensions/src/main/java/org/apache/streampipes/container => streampipes-service-extensions/src/main/java/org/apache/streampipes/service}/extensions/function/StreamPipesFunctionHandler.java (91%)
rename {streampipes-service-extensions-base/src/main/java/org/apache/streampipes/service/extensions/base => streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions}/security/TokenAuthenticationFilter.java (98%)
rename {streampipes-service-extensions-base/src/main/java/org/apache/streampipes/service/extensions/base => streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions}/security/UnauthenticatedInterfaces.java (94%)
rename {streampipes-service-extensions-base/src/main/java/org/apache/streampipes/service/extensions/base => streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/security}/WebSecurityConfig.java (94%)
rename {streampipes-container-extensions => streampipes-service-extensions}/src/main/resources/application.properties (100%)
rename {streampipes-connect-container-worker => streampipes-service-extensions}/src/main/resources/banner.txt (89%)
[streampipes] 01/01: Merge branch 'dev' into SP-1013
Posted by ze...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch SP-1013
in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit fdc38a80181e72a33d1e7201a997edcaeaea1e7b
Merge: dc1007e66 22afacd06
Author: Philipp Zehnder <te...@users.noreply.github.com>
AuthorDate: Mon Jan 2 16:47:43 2023 +0100
Merge branch 'dev' into SP-1013
.github/workflows/build.yml | 2 +-
.idea/runConfigurations/backend.xml | 7 +-
docker-compose.yml | 8 +-
pom.xml | 21 ++--
streampipes-connect-container-worker/pom.xml | 113 ---------------------
.../init/AdapterServiceResourceProvider.java | 44 --------
.../init/AdapterWorkerContainerResourceConfig.java | 38 -------
.../worker/init/ConnectWorkerTagProvider.java | 43 --------
.../pom.xml | 7 +-
.../management}/health/AdapterHealthCheck.java | 10 +-
.../management}/health/AdapterOperationLock.java | 2 +-
.../management/AdapterMasterManagement.java | 10 +-
.../management/DescriptionManagement.java | 8 +-
.../management}/management/GuessManagement.java | 10 +-
.../management}/management/SourcesManagement.java | 8 +-
.../management/UnitMasterManagement.java | 4 +-
.../management/WorkerAdministrationManagement.java | 6 +-
.../management}/management/WorkerRestClient.java | 6 +-
.../management}/management/WorkerUrlProvider.java | 2 +-
.../connect/management/util/GroundingUtils.java | 38 ++-----
.../connect/management}/util/WorkerPaths.java | 2 +-
.../management}/health/AdapterHealthCheckTest.java | 8 +-
.../management/AdapterMasterManagementTest.java | 4 +-
.../management/DescriptionManagementTest.java | 8 +-
.../management/SourcesManagementTest.java | 2 +-
.../management/UnitMasterManagementTest.java | 4 +-
.../management/WorkerRestClientTest.java | 6 +-
.../extensions/ExtensionsResourceConfig.java | 40 --------
.../src/main/resources/banner.txt | 6 --
streampipes-container/pom.xml | 109 --------------------
.../BaseExtensionsServiceResourceProvider.java | 34 -------
.../container/init/ExtensionsResourceProvider.java | 26 -----
.../PipelineElementServiceResourceProvider.java | 39 -------
.../container/model/ExtensionsConfig.java | 35 -------
.../container/util/StandardTransportFormat.java | 54 ----------
.../apache/streampipes/container/util/Util.java | 49 ---------
.../pom.xml | 7 +-
.../api}/DataSetReplayFinishedNotifier.java | 2 +-
.../streampipes/extensions/api}/PeConfig.java | 2 +-
.../extensions/api/connect}/Connector.java | 2 +-
.../extensions/api/connect}/EmitBinaryEvent.java | 2 +-
.../extensions/api/connect}/IAdapter.java | 6 +-
.../extensions/api/connect}/IAdapterPipeline.java | 2 +-
.../api/connect}/IAdapterPipelineElement.java | 2 +-
.../extensions/api/connect}/IFormat.java | 4 +-
.../extensions/api/connect}/IParser.java | 4 +-
.../extensions/api/connect}/IProtocol.java | 6 +-
.../api/connect}/exception/AdapterException.java | 2 +-
.../api/connect}/exception/ParseException.java | 2 +-
.../connect}/exception/WorkerAdapterException.java | 2 +-
.../extensions/api}/declarer/DataSetDeclarer.java | 4 +-
.../api}/declarer/DataStreamDeclarer.java | 2 +-
.../extensions/api}/declarer/Declarer.java | 2 +-
.../api}/declarer/EventStreamDeclarer.java | 2 +-
.../declarer/IStreamPipesFunctionDeclarer.java | 2 +-
.../api}/declarer/InvocableDeclarer.java | 2 +-
.../api}/declarer/PipelineTemplateDeclarer.java | 2 +-
.../declarer/SemanticEventConsumerDeclarer.java | 2 +-
.../SemanticEventProcessingAgentDeclarer.java | 2 +-
.../declarer/SemanticEventProducerDeclarer.java | 2 +-
.../runtime}/ResolvesContainerProvidedOptions.java | 2 +-
.../ResolvesContainerProvidedOutputStrategy.java | 2 +-
.../api/runtime}/SupportsRuntimeConfig.java | 2 +-
.../pom.xml | 92 ++++++-----------
.../api/RuntimeResolvableRequestHandler.java | 4 +-
.../management}/assets/AssetZipGenerator.java | 2 +-
.../client/StreamPipesClientResolver.java | 2 +-
...StreamPipesClientRuntimeConnectionResolver.java | 2 +-
.../management}/config/ConfigExtractor.java | 2 +-
.../management/connect}/AdapterUtils.java | 14 +--
.../connect}/AdapterWorkerManagement.java | 11 +-
.../connect}/ConnectWorkerDescriptionProvider.java | 10 +-
.../extensions/management}/connect/GetNEvents.java | 4 +-
.../management/connect}/GuessManagement.java | 9 +-
.../connect}/HttpServerAdapterManagement.java | 2 +-
.../management/connect}/RuntimeResovable.java | 18 ++--
.../management}/connect/SendToPipeline.java | 8 +-
.../management}/connect/adapter/Adapter.java | 16 +--
.../connect/adapter/AdapterPipelineGenerator.java | 42 ++++----
.../connect/adapter/AdapterRegistry.java | 34 +++----
.../connect/adapter/GroundingService.java | 47 +++++++++
.../connect/adapter/format/csv/CsvFormat.java | 8 +-
.../connect/adapter/format/csv/CsvParser.java | 12 +--
.../adapter/format/geojson/GeoJsonFormat.java | 8 +-
.../adapter/format/geojson/GeoJsonParser.java | 10 +-
.../connect/adapter/format/image/ImageFormat.java | 6 +-
.../connect/adapter/format/image/ImageParser.java | 8 +-
.../adapter/format/json/AbstractJsonFormat.java | 6 +-
.../adapter/format/json/arraykey/JsonFormat.java | 6 +-
.../adapter/format/json/arraykey/JsonParser.java | 31 +++---
.../format/json/arraynokey/JsonArrayFormat.java | 6 +-
.../format/json/arraynokey/JsonArrayParser.java | 26 ++---
.../format/json/object/JsonObjectFormat.java | 6 +-
.../format/json/object/JsonObjectParser.java | 10 +-
.../adapter/format/util/JsonEventProperty.java | 2 +-
.../connect/adapter/format/xml/XmlFormat.java | 8 +-
.../adapter/format/xml/XmlMapConverter.java | 2 +-
.../connect/adapter/format/xml/XmlParser.java | 12 +--
.../connect/adapter/guess/SchemaGuesser.java | 2 +-
.../adapter/model/generic/GenericAdapter.java | 18 ++--
.../model/generic/GenericDataSetAdapter.java | 6 +-
.../model/generic/GenericDataStreamAdapter.java | 6 +-
.../connect/adapter/model/generic/Parser.java | 8 +-
.../connect/adapter/model/generic/Protocol.java | 8 +-
.../pipeline/AdapterEventPreviewPipeline.java | 8 +-
.../adapter/model/pipeline/AdapterPipeline.java | 6 +-
.../adapter/model/specific/SpecificAdapter.java | 4 +-
.../model/specific/SpecificDataSetAdapter.java | 2 +-
.../model/specific/SpecificDataStreamAdapter.java | 2 +-
.../connect/adapter/preprocessing/Util.java | 2 +-
.../elements/AddTimestampPipelineElement.java | 4 +-
.../elements/AddValuePipelineElement.java | 4 +-
.../preprocessing/elements/DebugAdapterSink.java | 4 +-
.../elements/SendToBrokerAdapterSink.java | 8 +-
.../elements/SendToBrokerReplayAdapterSink.java | 6 +-
.../elements/SendToJmsAdapterSink.java | 4 +-
.../elements/SendToKafkaAdapterSink.java | 4 +-
.../elements/SendToMqttAdapterSink.java | 4 +-
.../elements/SendToNatsAdapterSink.java | 4 +-
.../TransformSchemaAdapterPipelineElement.java | 18 ++--
.../elements/TransformStreamAdapterElement.java | 10 +-
.../TransformValueAdapterPipelineElement.java | 20 ++--
.../transform/TransformationRule.java | 2 +-
.../schema/CreateNestedTransformationRule.java | 2 +-
.../transform/schema/DeleteTransformationRule.java | 2 +-
.../transform/schema/MoveTransformationRule.java | 2 +-
.../transform/schema/RenameTransformationRule.java | 2 +-
.../transform/schema/SchemaEventTransformer.java | 4 +-
.../transform/schema/SchemaTransformationRule.java | 4 +-
.../stream/DuplicateFilterPipelineElement.java | 4 +-
.../stream/EventRateTransformationRule.java | 2 +-
.../transform/stream/StreamEventTransformer.java | 4 +-
.../transform/stream/StreamTransformationRule.java | 4 +-
.../value/CorrectionValueTransformationRule.java | 2 +-
.../value/DatatypeTransformationRule.java | 4 +-
.../value/TimestampTranformationRule.java | 2 +-
.../value/TimestampTranformationRuleMode.java | 2 +-
.../transform/value/UnitTransformationRule.java | 2 +-
.../transform/value/ValueEventTransformer.java | 4 +-
.../transform/value/ValueTransformationRule.java | 4 +-
.../connect/adapter/sdk/ParameterExtractor.java | 2 +-
.../adapter/util/AdapterOutputCollector.java | 2 +-
.../connect/adapter/util/DatatypeUtils.java | 2 +-
.../connect/adapter/util/PollingSettings.java | 2 +-
.../adapter/util/TransportFormatGenerator.java | 2 +-
.../adapter/util/TransportFormatSelector.java | 2 +-
.../management}/init/DeclarersSingleton.java | 24 ++---
.../management/init}/RunningAdapterInstances.java | 4 +-
.../management}/init/RunningDatasetInstances.java | 6 +-
.../management}/init/RunningInstances.java | 6 +-
.../management}/locales/LabelGenerator.java | 4 +-
.../management}/model/SpServiceDefinition.java | 10 +-
.../model/SpServiceDefinitionBuilder.java | 12 +--
.../monitoring/SpMonitoringManager.java | 2 +-
.../extensions/management}/util/AssetsUtil.java | 2 +-
.../extensions/management}/util/ElementInfo.java | 2 +-
.../management}/util/GroundingDebugUtils.java | 2 +-
.../extensions/management}/util/LocalesUtil.java | 2 +-
.../management}/util/ServiceDefinitionUtil.java | 8 +-
.../connect}/AdapterWorkerManagementTest.java | 15 ++-
.../extensions/management/connect}/Mock.java | 2 +-
.../extensions/management/connect}/Utils.java | 2 +-
.../connect/adapter/GroundingServiceTest.java | 2 +-
.../management}/connect/adapter/TestUtils.java | 2 +-
.../format/json/arraykey/JsonParserTest.java | 16 ++-
.../json/arraynokey/JsonArrayParserTest.java | 13 ++-
.../adapter/format/json/geojson/GeoJsonTest.java | 6 +-
.../format/json/object/JsonObjectParserTest.java | 6 +-
.../connect/adapter/format/json/xml/XmlTest.java | 6 +-
.../schema/CreateNestedTransformationRuleTest.java | 6 +-
.../schema/DeleteTransformationRuleTest.java | 6 +-
.../schema/MoveTransformationRuleTest.java | 6 +-
.../schema/RenameTransformationRuleTest.java | 6 +-
.../schema/SchemaEventTransformerTest.java | 11 +-
.../value/TimestampTransformRuleTest.java | 2 +-
.../transform/value/UnitTransformRuleTest.java | 3 +-
.../transform/value/ValueEventTransformerTest.java | 7 +-
.../streampipes-connect-adapters-iiot/pom.xml | 2 +-
.../connect/iiot/ConnectAdapterIiotInit.java | 6 +-
.../connect/iiot/adapters/PullAdapter.java | 8 +-
.../connect/iiot/adapters/PullRestAdapter.java | 2 +-
.../iiot/adapters/influxdb/InfluxDbClient.java | 2 +-
.../iiot/adapters/influxdb/InfluxDbSetAdapter.java | 10 +-
.../adapters/influxdb/InfluxDbStreamAdapter.java | 10 +-
.../connect/iiot/adapters/opcua/OpcUaAdapter.java | 10 +-
.../iiot/adapters/opcua/utils/OpcUaUtil.java | 10 +-
.../adapters/plc4x/modbus/Plc4xModbusAdapter.java | 8 +-
.../plc4x/passive/Plc4xPassiveAdapter.java | 8 +-
.../iiot/adapters/plc4x/s7/Plc4xS7Adapter.java | 6 +-
.../iiot/adapters/ros/RosBridgeAdapter.java | 12 +--
.../simulator/machine/MachineDataSimulator.java | 4 +-
.../machine/MachineDataSimulatorUtils.java | 2 +-
.../machine/MachineDataStreamAdapter.java | 8 +-
.../connect/iiot/protocol/set/FileProtocol.java | 14 +--
.../connect/iiot/protocol/set/HttpProtocol.java | 16 +--
.../iiot/protocol/stream/BrokerEventProcessor.java | 6 +-
.../iiot/protocol/stream/BrokerProtocol.java | 10 +-
.../iiot/protocol/stream/FileStreamProtocol.java | 22 ++--
.../protocol/stream/HttpServerEventReceiver.java | 2 +-
.../iiot/protocol/stream/HttpServerProtocol.java | 14 +--
.../iiot/protocol/stream/HttpStreamProtocol.java | 12 +--
.../iiot/protocol/stream/KafkaProtocol.java | 14 +--
.../connect/iiot/protocol/stream/MqttProtocol.java | 12 +--
.../connect/iiot/protocol/stream/NatsProtocol.java | 14 +--
.../connect/iiot/protocol/stream/PullProtocol.java | 12 +--
.../protocol/stream/pulsar/PulsarProtocol.java | 16 +--
.../protocol/stream/rocketmq/RocketMQProtocol.java | 16 +--
.../connect/iiot/utils/FileProtocolUtils.java | 4 +-
.../streampipes-connect-adapters/pom.xml | 2 +-
.../streampipes/connect/ConnectAdapterInit.java | 6 +-
.../streampipes/connect/adapters/PullAdapter.java | 6 +-
.../connect/adapters/PullRestAdapter.java | 2 +-
.../adapters/coindesk/CoindeskBitcoinAdapter.java | 10 +-
.../connect/adapters/flic/FlicMQTTAdapter.java | 8 +-
.../connect/adapters/gdelt/GdeltAdapter.java | 6 +-
.../connect/adapters/iex/IexCloudAdapter.java | 2 +-
.../connect/adapters/iex/IexCloudNewsAdapter.java | 8 +-
.../connect/adapters/iex/IexCloudStockAdapter.java | 8 +-
.../connect/adapters/image/ImageZipAdapter.java | 4 +-
.../adapters/image/ZipFileImageIterator.java | 2 +-
.../adapters/image/set/ImageSetAdapter.java | 8 +-
.../adapters/image/stream/ImageStreamAdapter.java | 8 +-
.../connect/adapters/iss/IssAdapter.java | 8 +-
.../connect/adapters/netio/NetioMQTTAdapter.java | 8 +-
.../connect/adapters/netio/NetioRestAdapter.java | 8 +-
.../adapters/sensemap/OpenSenseMapAdapter.java | 6 +-
.../simulator/random/RandomDataSetAdapter.java | 10 +-
.../simulator/random/RandomDataSimulator.java | 2 +-
.../simulator/random/RandomDataStreamAdapter.java | 10 +-
.../connect/adapters/slack/SlackAdapter.java | 10 +-
.../connect/adapters/slack/SlackConsumer.java | 2 +-
.../connect/adapters/ti/TISensorTag.java | 8 +-
.../adapters/wikipedia/WikipediaAdapter.java | 6 +-
.../wikipedia/WikipediaEditedArticlesAdapter.java | 2 +-
.../wikipedia/WikipediaNewArticlesAdapter.java | 2 +-
.../adapters/wikipedia/WikipediaSseConsumer.java | 2 +-
.../connect/adapters/generic/UtilTest.java | 4 +-
.../generic/elements/AddTimestampTest.java | 2 +-
.../generic/elements/DuplicateFilterTest.java | 2 +-
.../streampipes-extensions-all-iiot/pom.xml | 2 +-
.../extensions/all/iiot/AllExtensionsIIoTInit.java | 6 +-
.../streampipes-extensions-all-jvm/pom.xml | 2 +-
.../extensions/all/jvm/AllExtensionsInit.java | 6 +-
.../pe/flink/AllFlinkPipelineElementsInit.java | 6 +-
.../pe/jvm/AllPipelineElementsInit.java | 6 +-
.../pe/jvm/config/AllPipelineElementsConfig.java | 2 +-
.../flink/AbstractAggregationProgram.java | 2 +-
.../aggregation/flink/AggregationFlinkInit.java | 6 +-
.../aggregation/AggregationController.java | 4 +-
.../processor/aggregation/AggregationProgram.java | 2 +-
.../flink/processor/count/CountController.java | 2 +-
.../flink/processor/count/CountProgram.java | 2 +-
.../processor/eventcount/EventCountController.java | 2 +-
.../processor/eventcount/EventCountProgram.java | 2 +-
.../flink/processor/rate/EventRateController.java | 2 +-
.../flink/processor/rate/EventRateProgram.java | 2 +-
.../aggregation/TestTimeAggregationProgram.java | 2 +-
.../flink/processor/count/TestCountProgram.java | 2 +-
.../flink/processor/rate/TestRateProgram.java | 2 +-
.../jvm/ChangeDetectionJvmInit.java | 6 +-
.../enricher/flink/AbstractEnricherProgram.java | 2 +-
.../enricher/flink/EnricherFlinkInit.java | 6 +-
.../processor/timestamp/TimestampController.java | 2 +-
.../processor/timestamp/TimestampProgram.java | 2 +-
.../UrlDereferencingController.java | 2 +-
.../urldereferencing/UrlDereferencingProgram.java | 2 +-
.../processors/enricher/jvm/EnricherJvmInit.java | 6 +-
.../processors/filters/jvm/FiltersJvmInit.java | 6 +-
.../processors/siddhi/FiltersSiddhiInit.java | 6 +-
.../siddhi/listcollector/ListCollector.java | 2 +-
.../processor/geo/flink/AbstractGeoProgram.java | 2 +-
.../processor/geo/flink/GeoFlinkInit.java | 6 +-
.../SpatialGridEnrichmentController.java | 2 +-
.../gridenricher/SpatialGridEnrichmentProgram.java | 2 +-
.../streampipes/processors/geo/jvm/GeoJvmInit.java | 6 +-
.../jvm/ImageProcessingJvmInit.java | 6 +-
.../flink/AbstractPatternDetectionProgram.java | 2 +-
.../detection/flink/PatternDetectionFlinkInit.java | 6 +-
.../flink/processor/absence/AbsenceController.java | 2 +-
.../flink/processor/absence/AbsenceProgram.java | 2 +-
.../flink/processor/and/AndController.java | 2 +-
.../detection/flink/processor/and/AndProgram.java | 2 +-
.../processor/peak/PeakDetectionController.java | 2 +-
.../flink/processor/peak/PeakDetectionProgram.java | 3 +-
.../processor/sequence/SequenceController.java | 2 +-
.../flink/processor/sequence/SequenceProgram.java | 2 +-
.../detection/processor/absence/TestAbsence.java | 2 +-
.../pattern/detection/processor/and/TestAnd.java | 2 +-
.../flink/AbstractStatisticsProgram.java | 2 +-
.../statistics/flink/StatisticsFlinkInit.java | 6 +-
.../stat/summary/StatisticsSummaryController.java | 4 +-
.../stat/summary/StatisticsSummaryProgram.java | 2 +-
.../window/StatisticsSummaryControllerWindow.java | 2 +-
.../window/StatisticsSummaryProgramWindow.java | 2 +-
.../flink/AbstractTextMiningProgram.java | 2 +-
.../textmining/flink/TextMiningFlinkInit.java | 6 +-
.../language/LanguageDetectionController.java | 2 +-
.../language/LanguageDetectionProgram.java | 2 +-
.../processor/wordcount/WordCountController.java | 2 +-
.../processor/wordcount/WordCountProgram.java | 2 +-
.../textmining/jvm/TextMiningJvmInit.java | 6 +-
.../jvm/processor/chunker/ChunkerController.java | 2 +-
.../language/LanguageDetectionController.java | 2 +-
.../processor/namefinder/NameFinderController.java | 2 +-
.../partofspeech/PartOfSpeechController.java | 2 +-
.../SentenceDetectionController.java | 2 +-
.../processor/tokenizer/TokenizerController.java | 2 +-
.../IgnoreBlocksAfterContentFromEndFilter.java | 6 +-
.../boilerpipe/sax/BoilerpipeHTMLParser.java | 7 +-
.../flink/AbstractFlinkTransformationProgram.java | 2 +-
.../flink/TransformationFlinkInit.java | 6 +-
.../boilerplate/BoilerplateController.java | 2 +-
.../processor/boilerplate/BoilerplateProgram.java | 2 +-
.../converter/FieldConverterController.java | 6 +-
.../processor/converter/FieldConverterProgram.java | 2 +-
.../processor/hasher/FieldHasherController.java | 2 +-
.../flink/processor/hasher/FieldHasherProgram.java | 2 +-
.../processor/mapper/FieldMapperController.java | 4 +-
.../flink/processor/mapper/FieldMapperProgram.java | 2 +-
.../MeasurementUnitConverterController.java | 4 +-
.../MeasurementUnitConverterProgram.java | 2 +-
.../processor/rename/FieldRenamerController.java | 2 +-
.../processor/rename/FieldRenamerProgram.java | 2 +-
.../processor/converter/TestConverterProgram.java | 3 +-
.../processor/hasher/TestFieldHasherProgram.java | 2 +-
.../flink/processor/rename/TestRenameProgram.java | 2 +-
.../transformation/jvm/TransformationJvmInit.java | 6 +-
.../array/split/SplitArrayController.java | 2 +-
.../CsvMetadataEnrichmentController.java | 6 +-
.../jvm/processor/mapper/FieldMapperProcessor.java | 2 +-
.../MeasurementUnitConverterProcessor.java | 2 +-
.../buffer/StateBufferLabelerController.java | 2 +-
.../labeler/number/NumberLabelerController.java | 2 +-
.../TimestampExtractorController.java | 2 +-
.../TransformToBooleanController.java | 2 +-
.../sinks/brokers/jvm/BrokersJvmInit.java | 6 +-
.../sinks/databases/flink/DatabasesFlinkInit.java | 6 +-
.../elasticsearch/ElasticSearchController.java | 2 +-
.../flink/elasticsearch/ElasticSearchProgram.java | 2 +-
.../sinks/databases/jvm/DatabasesJvmInit.java | 6 +-
.../sinks/internal/jvm/SinksInternalJvmInit.java | 6 +-
.../jvm/SinksNotificationsJvmInit.java | 6 +-
.../vehicle/simulator/VehicleSimulatorInit.java | 6 +-
.../simulator/simulator/VehicleDataSimulator.java | 4 +-
.../simulator/WatertankSimulatorInit.java | 6 +-
.../simulator/utils/WatertankDataSimulator.java | 4 +-
streampipes-integration-tests/pom.xml | 8 +-
.../integration/adapters/AdapterTesterBase.java | 10 +-
.../integration/adapters/PulsarAdapterTester.java | 4 +-
streampipes-pipeline-management/pom.xml | 2 +-
.../manager/endpoint/EndpointItemFetcher.java | 5 +-
.../manager/endpoint/EndpointItemParser.java | 5 +-
.../streampipes/manager/matching/v2/TestUtils.java | 6 +-
.../pom.xml | 46 ++++++---
.../extensions}/AbstractExtensionsResource.java | 2 +-
.../AbstractPipelineElementResource.java | 10 +-
.../streampipes/rest/extensions}/WelcomePage.java | 10 +-
.../extensions/connect}/AdapterAssetResource.java | 8 +-
.../extensions/connect}/AdapterWorkerResource.java | 6 +-
.../rest/extensions/connect}/GuessResource.java | 8 +-
.../connect}/HttpServerAdapterResource.java | 4 +-
.../connect}/RuntimeResolvableResource.java | 12 +--
.../rest/extensions}/html/HTMLGenerator.java | 6 +-
.../rest/extensions}/html/JSONGenerator.java | 6 +-
.../html/model/DataSourceDescriptionHtml.java | 2 +-
.../rest/extensions}/html/model/Description.java | 2 +-
.../html/page/WelcomePageGenerator.java | 18 ++--
.../extensions/monitoring}/MonitoringResource.java | 5 +-
.../pe}/DataProcessorPipelineElementResource.java | 8 +-
.../pe}/DataSinkPipelineElementResource.java | 8 +-
.../pe}/DataStreamPipelineElementResource.java | 13 +--
.../pe}/InvocablePipelineElementResource.java | 15 ++-
.../extensions/pe}/PipelineTemplateResource.java | 7 +-
streampipes-rest/pom.xml | 2 +-
.../apache/streampipes/rest/ResetManagement.java | 4 +-
.../rest/impl/connect/AdapterResource.java | 4 +-
.../rest/impl/connect/DescriptionResource.java | 6 +-
.../rest/impl/connect/GuessResource.java | 6 +-
.../impl/connect/RuntimeResolvableResource.java | 8 +-
.../rest/impl/connect/SourcesResource.java | 4 +-
.../rest/impl/connect/UnitResource.java | 4 +-
.../rest/impl/connect/WelcomePageMaster.java | 91 -----------------
.../impl/connect/WorkerAdministrationResource.java | 2 +-
streampipes-sdk-bundle/pom.xml | 2 +-
.../Dockerfile | 0
.../development/env | 0
.../pom.xml | 6 +-
.../core}/StreamPipesBackendApplication.java | 4 +-
.../service/core}/StreamPipesEnvChecker.java | 2 +-
.../service/core}/StreamPipesPasswordEncoder.java | 2 +-
.../service/core}/StreamPipesResourceConfig.java | 4 +-
.../service/core}/UnauthenticatedInterfaces.java | 2 +-
.../service/core}/WebSecurityConfig.java | 2 +-
.../service/core}/WelcomePageController.java | 2 +-
.../core}/migrations/AvailableMigrations.java | 10 +-
.../service/core}/migrations/Migration.java | 2 +-
.../core}/migrations/MigrationsHandler.java | 2 +-
.../v070/CreateAssetLinkTypeMigration.java | 4 +-
.../v070/CreateDefaultAssetMigration.java | 4 +-
.../v070/CreateFileAssetTypeMigration.java | 4 +-
.../v090/UpdateUsernameViewMigration.java | 4 +-
.../src/main/resources/application.properties | 0
.../src/main/resources/banner.txt | 0
.../src/main/resources/openapi.yaml | 0
.../src/main/resources/static/index.html | 0
.../pom.xml | 12 +--
.../extensions/ExtensionsModelSubmitter.java | 15 ++-
.../extensions/ExtensionsResourceConfig.java | 76 ++++++++++++++
.../ExtensionsServiceShutdownHandler.java | 4 +-
.../service}/extensions/ServiceTagProvider.java | 20 ++--
.../StreamPipesExtensionsServiceBase.java | 6 +-
.../extensions/connect/ConnectRestClient.java | 8 +-
.../connect}/ConnectWorkerRegistrationService.java | 8 +-
.../function/FunctionDeregistrationHandler.java | 2 +-
.../function/FunctionRegistrationHandler.java | 2 +-
.../extensions/function/RegistrationHandler.java | 4 +-
.../function/StreamPipesFunctionHandler.java | 6 +-
.../security/TokenAuthenticationFilter.java | 2 +-
.../security/UnauthenticatedInterfaces.java | 2 +-
.../extensions/security}/WebSecurityConfig.java | 4 +-
.../src/main/resources/application.properties | 0
.../src/main/resources/banner.txt | 2 +-
streampipes-sources/pom.xml | 4 +-
.../sources/AbstractAdapterIncludedStream.java | 6 +-
.../sources/AbstractAlreadyExistingStream.java | 6 +-
.../distributed/runtime/DistributedRuntime.java | 2 +-
.../wrapper/flink/FlinkDataProcessorRuntime.java | 2 +-
.../wrapper/flink/FlinkDataSinkRuntime.java | 2 +-
.../streampipes/wrapper/flink/FlinkRuntime.java | 2 +-
.../StandaloneEventProcessingDeclarer.java | 2 +-
.../StandaloneEventProcessorDeclarerSingleton.java | 2 +-
.../declarer/StandaloneEventSinkDeclarer.java | 2 +-
.../StandaloneEventSinkDeclarerSingleton.java | 2 +-
.../StandaloneExternalEventProcessingDeclarer.java | 2 +-
.../StandaloneExternalEventSinkDeclarer.java | 2 +-
.../standalone/function/FunctionContext.java | 4 +-
.../function/FunctionContextGenerator.java | 2 +-
.../standalone/function/StreamPipesFunction.java | 6 +-
.../routing/StandaloneSpOutputCollector.java | 2 +-
.../runtime/StandalonePipelineElementRuntime.java | 2 +-
streampipes-wrapper/pom.xml | 4 +-
.../wrapper/context/RuntimeContext.java | 4 +-
.../context/SpEventProcessorRuntimeContext.java | 4 +-
.../wrapper/context/SpEventSinkRuntimeContext.java | 4 +-
.../wrapper/context/SpRuntimeContext.java | 4 +-
.../wrapper/declarer/EventProcessorDeclarer.java | 2 +-
.../wrapper/declarer/EventSinkDeclarer.java | 2 +-
.../wrapper/declarer/PipelineElementDeclarer.java | 4 +-
.../runtime/EventProcessorRuntimeParams.java | 4 +-
.../params/runtime/EventSinkRuntimeParams.java | 4 +-
.../wrapper/params/runtime/RuntimeParams.java | 2 +-
451 files changed, 1340 insertions(+), 1958 deletions(-)