This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a change to branch 1103-support-python-311-in-python-client
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from ff3032277 Fix deprecated asyncio code
add d8a788585 Bump mypy from 1.3.0 to 1.4.0 in /streampipes-client-python
(#1707)
add 0ae6f0a5c Use UTF_8 as the encoding when generating the label (#1701)
add 87940b25c [hotfix] Update release notes
add 6a174ec37 Maven housekeeping (#1695)
add c48d135a1 Bump autoflake from 2.1.0 to 2.2.0 in
/streampipes-client-python (#1712)
add bea143804 Bump pytest from 7.3.0 to 7.4.0 in
/streampipes-client-python (#1711)
add 1b1166757 Bump formatter-maven-plugin from 2.21.0 to 2.23.0 (#1710)
add 58d219491 fix: kafka consumer data loss promble (#1629)
add 27839afdf Harmonize OPC-UA adapter and sink, add timestamp to metadata
(#899) (#1682)
add 117af967b Support migration of adapters in data import (#1683)
add f3fd3802e Add creation of attachments for CouchDB (#1716)
add fb7493076 [hotfix] Use latest offset setting as kafka consumer default
(#1720)
add 7ed91b539 add Kafka integration test (#1719)
add 929f8c0a8 Bump okio from 1.16.0 to 3.3.0 (#1715)
add b92069016 Improve handling of messaging protocols, extend broker
support in cli… (#1718)
add 027249044 [#1713] Fix NullPointer in OPC UA browsing (#1714)
add 7eb2a318c [hotfix] Fix Kafka test after refactoring of messaging module
add a17e642fd Bump tubemq-client from 1.6.0 to 1.7.0 (#1721)
add 2d72d427e Bump jboss-logging from 3.4.0.Final to 3.5.2.Final (#1723)
add f165024b0 [hotfix] Fix environment variable in prebuild script (#1724)
add 98849e675 [hotfix] Make storage sizes in helm charts configurable
(#1722)
add ca0128eea Update Maven archetypes (#1726) (#1727)
add 93aab005f monthly update of vulnerability report (#1725)
add eac2ddf18 Bump pyupgrade from 3.7.0 to 3.8.0 in
/streampipes-client-python (#1728)
add ef967e810 Bump javassist from 3.25.0-GA to 3.29.2-GA (#1730)
add 1632f22bd Bump angular-plotly.js from 4.0.4 to 5.0.0 in /ui (#1702)
add 73aaadcac Bump spring-security-core from 6.0.3 to 6.1.1 & spring to
6.0.10 (#1704)
add 0cdba67d0 Bump shepherd.js from 11.0.1 to 11.1.1 in /ui (#1734)
add 7450ee494 Bump graalvm.js.version from 22.3.1 to 23.0.0 (#1739)
add 9171065f1 Bump jakarta.activation-api from 1.2.2 to 2.1.2 (#1735)
add 6dae125be feature: introduce admonitions to warn about dependency
issue in docs (#1733)
add 7113e6656 [hotfix] Keep pipelineIds when importing pipelines, reduce
logging in Networking (#1743)
add 80215334c [hotfix] Do not deploy extensions-all-iiot fat jar to Maven
add 2980bd8dc Bump blacken-docs from 1.14.0 to 1.15.0 in
/streampipes-client-python (#1749)
add f6884f613 Bump jquery from 3.6.3 to 3.7.0 in /ui (#1746)
add 72b447a92 [hotfix] Disable prebuild run on postinstall (#1744)
add a536e6148 Bump extra-enforcer-rules from 1.6.1 to 1.7.0 (#1748)
add 82176b512 [hotfix] Return 404 instead of 400 when requesting resources
over client (#1745)
add 5422fe133 [hotfix] limit python related PRs created by the renovatebot
add 971d9d96b [hotfix] Improve handling of data lake measures in API
(#1758)
add cfaa4b490 Bump amqp-client from 5.17.0 to 5.18.0 (#1759)
add 7c4fe5230 Bump cypress from 12.8.1 to 12.17.0 in /ui (#1761)
add e021c3305 [hotfix] improve python dependency pinning
add bac9e9a32 #1374: Convenient columns query parameter for data lake
measure (#1737)
add 979f9b7c3 Bump pyupgrade from 3.8.0 to 3.9.0 in
/streampipes-client-python (#1763)
add 43bab2405 Bump checkstyle from 10.6.0 to 10.12.1 (#1765)
add e85c398d7 Bump black from 23.3.0 to 23.7.0 in
/streampipes-client-python (#1764)
add 04200fce5 Support pulsar messasging layer (#1576)
add 7130732f5 Set latest version in bug report template
add d71d13152 remove dependency scala-xml_2.11 (#1767)
add 8e4ef3d32 Fix Helm Chart Upgrade Failure (#1546) (#1775)
add a3112950d Use java 17 Docker base image in archetypes (#1770) (#1773)
add 5babc62d3 Register protocols during startup of core (#1771) (#1772)
add e13951a26 [hotfix] Add Nats image, modify Dockerfile base image
add 8f8f9fb26 Bump Angular version to 15, refactor Material components to
mdc (#1341)
add acf177688 Bump word-wrap from 1.2.3 to 1.2.4 in /ui (#1780)
add c28d9223e Bump semver from 5.7.1 to 5.7.2 in /ui (#1766)
add 641aecfa2 1777 add api endpoint to get available users (#1778)
add 2a1411d5b [hotfix] Fix e2e tests
add 9bc9eb544 [hotfix] Fix some layout bugs after mdc migration
add 9c7df4fb6 Fix status widget in dashboard (#1741)
add 58f28e2d0 Bump @typescript-eslint/parser from 5.59.11 to 5.62.0 in /ui
(#1784)
add 31c7096e9 Replace forbidden keywords in data lake measure (#1769)
(#1774)
add 780a65911 Fix assignment of default time range in data download dialog
(#1642) (#1783)
add 1a7a1004a [hotfix] Fix layout issue in label configuration
add 329f56c8d Delete pipeline-related notifications upon pipeline deletion
(#1533) (#1785)
add fcbf54fac Bump @jsplumb/browser-ui from 6.1.1 to 6.2.10 in /ui (#1790)
add aab2d786e Bump com.opencsv:opencsv from 5.7.1 to 5.8 (#1789)
add 8419dd075 add probes to Streampipes' kubernetes deployment ( #1781 )
(#1786)
add 6ea881fe7 Improve monitoring of adapters and pipelines (#1787) (#1788)
add 2a49d0227 Merge branch 'dev' of github.com:apache/streampipes into dev
add 1fda6fc1f [#1791] Add classNamePrefix variable to object creation.
fixes #1791
add 0b3c23136 Bump ngx-quill from 20.0.1 to 21.0.0 in /ui (#1793)
add db32ee8f5 Bump org.scala-lang.modules:scala-parser-combinators_2.11
(#1792)
add 97b94400a [hotfix] Fix typo in code
add a5276b250 Fix width of aggregation box in data explorer (#1794) (#1797)
add 1085f1b46 tmp (#1800)
add 465f351fe Bump mkdocs from 1.4.2 to 1.5.1 in
/streampipes-client-python (#1801)
add e91036458 Bump org.boofcv:boofcv-core from 0.42 to 0.43.1 (#1802)
add be7ef1ee4 Bump pyupgrade from 3.9.0 to 3.10.1 in
/streampipes-client-python (#1805)
add 913339992 monthly update of vulnerability report (#1807)
add 71e39cef7 [hotfix] Fix layout of label configuration component
add 4c11c4d8d Bump flake8 from 6.0.0 to 6.1.0 in
/streampipes-client-python (#1804)
add b3759764b chore: remove repository title from notification settings
(#1808)
add f63901757 Refactor required streams for python functions (#1806)
add e7b997e43 Bump @types/node from 18.14.0 to 20.4.6 in /ui (#1810)
add ba90ca794 Merge remote-tracking branch 'origin/dev' into
1103-support-python-311-in-python-client
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 34 +-
.github/ISSUE_TEMPLATE/bug_report.yml | 2 +-
.github/dependabot.yml | 1 +
.github/workflows/build.yml | 8 +
.idea/runConfigurations/core.xml | 3 +-
RELEASE_NOTES.md | 131 +
VULNERABILITY.md | 17 +-
.../main/resources/archetype-resources/Dockerfile | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../archetype-resources/src/main/java/Init.java | 10 +-
.../__classNamePrefix__DataProcessor.java | 52 +-
.../__classNamePrefix__DataSink.java | 41 +-
.../__classNamePrefix__GenericAdapter.java | 101 +
.../__classNamePrefix__SpecificAdapter.java | 95 +
.../documentation.md | 32 +-
.../icon.png | Bin
.../strings.en} | 10 +-
.../documentation.md | 32 +-
.../icon.png | Bin
.../strings.en} | 10 +-
.../main/resources/archetype-resources/Dockerfile | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../archetype-resources/src/main/java/Init.java | 4 +-
.../main/resources/archetype-resources/Dockerfile | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../archetype-resources/src/main/java/Init.java | 4 +-
installer/cli/.env | 4 +-
.../cli/deploy/standalone/opcua/docker-compose.yml | 1 +
.../standalone/pulsar/docker-compose.dev.yml | 13 +-
.../deploy/standalone/pulsar/docker-compose.yml | 113 +
.../cli/environments/backend-pulsar | 11 +-
.../cli/environments/basic-pulsar | 10 +-
.../cli/environments/lite-pulsar | 13 +-
.../cli/environments/pipeline-element-pulsar | 12 +-
installer/compose/docker-compose.pulsar.yml | 141 +
.../k8s/templates/core/backend-deployment.yaml | 22 +
installer/k8s/templates/core/backend-pvc.yaml | 2 +-
installer/k8s/templates/core/ui-configmap.yaml | 2 +-
installer/k8s/templates/core/ui-deployment.yaml | 22 +
.../extensions-all-iiot-deployment.yaml | 21 +-
.../external/consul/consul-deployment.yaml | 26 +-
.../templates/external/consul/consul-pv-pvc.yaml | 2 +-
.../external/couchdb/couchdb-deployment.yaml | 24 +-
.../templates/external/couchdb/couchdb-pv-pvc.yaml | 2 +-
.../external/influxdb/influxdb-deployment.yaml | 28 +-
.../templates/external/influxdb/influxdb-pvc.yaml | 2 +-
.../templates/external/influxdb/influxdb2-pvc.yaml | 2 +-
.../templates/external/kafka/kafka-deployment.yaml | 29 +-
.../templates/external/nats/nats-deployment.yaml | 21 +-
.../external/zookeeper/zookeeper-deployment.yaml | 30 +-
installer/k8s/values.yaml | 36 +-
pom.xml | 78 +-
.../streampipes/client/api/IDataProcessorApi.java | 29 +-
.../streampipes/client/api/IDataSinkApi.java | 15 +-
.../streampipes/client/api/IDataStreamApi.java | 18 +-
.../streampipes/client/api/IStreamPipesClient.java | 3 +
.../api/config/IStreamPipesClientConfig.java | 5 +-
.../client/api/live/IBrokerConfigOverride.java | 11 +-
...kaConfig.java => IConfiguredEventProducer.java} | 13 +-
.../live/{IKafkaConfig.java => ISubscription.java} | 5 +-
streampipes-client-python/docs/index.md | 28 +-
...ive-data-from-the-streampipes-data-stream.ipynb | 27 +-
streampipes-client-python/setup.py | 30 +-
.../streampipes/endpoint/api/data_lake_measure.py | 37 +-
.../streampipes/function_zoo/river_function.py | 19 +-
.../streampipes/functions/streampipes_function.py | 3 +-
.../model/container/resource_container.py | 2 +-
.../tests/endpoint/test_data_lake_measure.py | 110 +-
.../tests/functions/test_function_handler.py | 40 +-
streampipes-client/pom.xml | 6 +-
.../streampipes/client/StreamPipesClient.java | 6 +
.../streampipes/client/api/DataProcessorApi.java | 54 +-
.../apache/streampipes/client/api/DataSinkApi.java | 26 +-
.../streampipes/client/api/DataStreamApi.java | 28 +-
.../client/live/ConfiguredEventProducer.java | 53 +
.../streampipes/client/live/ProducerManager.java | 62 +
.../streampipes/client/live/Subscription.java | 19 +-
.../client/live/SubscriptionManager.java | 117 +-
.../client/model/StreamPipesClientConfig.java | 18 +-
streampipes-commons/pom.xml | 10 +
.../java/org/apache/streampipes/commons/Utils.java | 6 -
.../streampipes/commons/networking/Networking.java | 15 +-
.../streampipes/commons/resources/Resources.java | 27 +-
.../src/test/java/TestResources.java | 22 +-
streampipes-commons/src/test/resources/test.txt | 1 +
streampipes-config/pom.xml | 6 -
.../streampipes/config/backend/BackendConfig.java | 7 +-
.../config/backend/BackendConfigKeys.java | 1 +
.../config/backend/DefaultMessagingSettings.java | 22 +-
streampipes-connect-management/pom.xml | 10 +
.../management}/AdapterEventPreviewPipeline.java | 32 +-
.../management/management/GuessManagement.java | 7 +-
.../connect/management/util/GroundingUtils.java | 15 +-
.../management}/util/TransportFormatGenerator.java | 2 +-
.../pom.xml | 19 +-
.../shared/AdapterPipelineGeneratorBase.java | 110 +
.../streampipes/connect/shared}/DatatypeUtils.java | 2 +-
.../connect/shared}/preprocessing/Util.java | 2 +-
.../elements/AddTimestampPipelineElement.java | 2 +-
.../elements/AddValuePipelineElement.java | 2 +-
.../TransformSchemaAdapterPipelineElement.java | 16 +-
.../elements/TransformStreamAdapterElement.java | 8 +-
.../TransformValueAdapterPipelineElement.java | 18 +-
.../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 | 2 +-
.../stream/EventRateTransformationRule.java | 2 +-
.../transform/stream/StreamEventTransformer.java | 4 +-
.../transform/stream/StreamTransformationRule.java | 4 +-
.../value/CorrectionValueTransformationRule.java | 2 +-
.../value/DatatypeTransformationRule.java | 5 +-
.../value/TimestampTranformationRule.java | 2 +-
.../value/TimestampTranformationRuleMode.java | 2 +-
.../transform/value/UnitTransformationRule.java | 2 +-
.../transform/value/ValueEventTransformer.java | 4 +-
.../transform/value/ValueTransformationRule.java | 4 +-
.../transform}/DatatypeUtilsTest.java | 5 +-
.../schema/CreateNestedTransformationRuleTest.java | 4 +-
.../schema/DeleteTransformationRuleTest.java | 4 +-
.../schema/MoveTransformationRuleTest.java | 4 +-
.../schema/RenameTransformationRuleTest.java | 4 +-
.../schema/SchemaEventTransformerTest.java | 11 +-
.../transform/value/CorrectionValueTest.java | 3 +-
.../transform/value/UnitTransformRuleTest.java | 3 +-
.../transform/value/ValueEventTransformerTest.java | 5 +-
streampipes-data-explorer-commons/pom.xml | 6 +
.../dataexplorer/commons/DataExplorerUtils.java | 4 +
.../commons/sanitizer/MeasureNameSanitizer.java | 23 +-
.../sanitizer/MeasureNameSanitizerTest.java | 53 +
.../param/model/SelectClauseParams.java | 6 +-
.../writer/TestConfiguredCsvOutputWriter.java | 4 +-
.../writer/TestConfiguredJsonOutputWriter.java | 4 +-
.../export/dataimport/PerformImportGenerator.java | 4 +-
.../export/dataimport/PreviewImportGenerator.java | 18 +-
.../export/utils/EventGroundingProcessor.java | 14 +-
.../export/utils/ImportAdapterMigrationUtils.java | 55 +
.../connect/context/IAdapterRuntimeContext.java | 4 +-
...pelineElementLogger.java => FixedSizeList.java} | 42 +-
...neElementLogger.java => IExtensionsLogger.java} | 17 +-
.../api/monitoring/SpMonitoringManager.java | 33 +-
.../extensions/api/pe/context/RuntimeContext.java | 4 +-
streampipes-extensions-management/pom.xml | 10 +
.../connect/AdapterWorkerManagement.java | 17 +-
.../management/connect/PullAdapterScheduler.java | 4 +-
.../connect/adapter/AdapterPipelineGenerator.java | 98 +-
.../connect/adapter/parser/CsvParser.java | 2 +-
.../connect/adapter/parser/json/GeoJsonParser.java | 32 +-
.../elements/SendToBrokerAdapterSink.java | 28 +-
.../elements/SendToJmsAdapterSink.java | 8 +-
.../elements/SendToKafkaAdapterSink.java | 8 +-
.../elements/SendToMqttAdapterSink.java | 8 +-
.../elements/SendToNatsAdapterSink.java | 8 +-
...apterSink.java => SendToPulsarAdapterSink.java} | 20 +-
.../context/AdapterContextGenerator.java | 9 +-
.../context/SpAdapterRuntimeContext.java | 12 +-
.../management/locales/LabelGenerator.java | 4 +-
.../management/monitoring/ExtensionsLogger.java | 63 +
.../connect/AdapterWorkerManagementTest.java | 2 +-
streampipes-extensions/pom.xml | 3 +
.../iiot/adapters/iolink/IfmAlMqttAdapter.java | 6 +-
.../iiot/adapters/plc4x/s7/Plc4xS7Adapter.java | 20 +-
.../simulator/machine/MachineDataSimulator.java | 12 +-
.../iiot/protocol/stream/FileReplayAdapter.java | 5 +-
.../iiot/protocol/stream/KafkaProtocol.java | 21 +-
.../connect/iiot/protocol/stream/NatsProtocol.java | 14 +-
.../strings.en | 12 +
.../generic/elements/AddTimestampTest.java | 2 +-
.../generic/elements/DuplicateFilterTest.java | 2 +-
.../streampipes-connectors-opcua/pom.xml | 12 +
.../connectors/opcua/adapter/OpcUaAdapter.java | 82 +-
.../connectors/opcua/adapter/OpcUaNodeBrowser.java | 37 +-
.../opcua/adapter/OpcUaNodeMetadataExtractor.java | 171 +
.../opcua/adapter/configuration/SpOpcUaConfig.java | 148 -
.../opcua/{adapter => client}/SpOpcUaClient.java | 30 +-
.../MiloOpcUaConfigurationProvider.java | 7 +-
.../opcua/config/OpcUaAdapterConfig.java | 17 +-
.../connectors/opcua/config/OpcUaConfig.java | 70 +
.../opcua/config/SharedUserConfiguration.java | 89 +
.../SpOpcUaConfigExtractor.java} | 101 +-
.../opcua/{adapter => model}/OpcNode.java | 2 +-
.../extensions/connectors/opcua/sink/OpcUa.java | 83 +-
.../connectors/opcua/sink/OpcUaParameters.java | 45 +-
.../connectors/opcua/sink/OpcUaSink.java | 62 +-
.../utils/ExceptionMessageExtractor.java | 2 +-
.../opcua/{adapter => }/utils/OpcUaTypes.java | 2 +-
.../opcua/{adapter => }/utils/OpcUaUtil.java | 39 +-
.../strings.en | 42 +-
.../adapter/OpcUaNodeMetadataExtractorTest.java | 258 +
.../streampipes-extensions-all-iiot/pom.xml | 4 +
.../extensions/all/iiot/AllExtensionsIIoTInit.java | 4 +-
.../extensions/all/jvm/AllExtensionsInit.java | 4 +-
.../pom.xml | 5 -
.../boilerpipe/BoilerpipeDocumentSource.java | 18 -
.../boilerpipe/BoilerpipeExtractor.java | 18 -
.../kohlschutter/boilerpipe/BoilerpipeFilter.java | 18 -
.../kohlschutter/boilerpipe/BoilerpipeInput.java | 18 -
.../boilerpipe/BoilerpipeProcessingException.java | 26 +-
.../boilerpipe/conditions/TextBlockCondition.java | 18 -
.../kohlschutter/boilerpipe/document/Image.java | 18 -
.../boilerpipe/document/TextBlock.java | 18 -
.../boilerpipe/document/TextDocument.java | 18 -
.../document/TextDocumentStatistics.java | 18 -
.../boilerpipe/estimators/SimpleEstimator.java | 18 -
.../boilerpipe/extractors/ArticleExtractor.java | 18 -
.../extractors/ArticleSentencesExtractor.java | 18 -
.../boilerpipe/extractors/CanolaExtractor.java | 18 -
.../boilerpipe/extractors/CommonExtractors.java | 18 -
.../boilerpipe/extractors/DefaultExtractor.java | 18 -
.../boilerpipe/extractors/ExtractorBase.java | 18 -
.../extractors/KeepEverythingExtractor.java | 18 -
.../KeepEverythingWithMinKWordsExtractor.java | 18 -
.../extractors/LargestContentExtractor.java | 18 -
.../extractors/NumWordsRulesExtractor.java | 18 -
.../boilerpipe/filters/debug/PrintDebugFilter.java | 18 -
.../filters/english/DensityRulesClassifier.java | 18 -
.../filters/english/HeuristicFilterBase.java | 18 -
.../english/IgnoreBlocksAfterContentFilter.java | 18 -
.../IgnoreBlocksAfterContentFromEndFilter.java | 18 -
.../english/KeepLargestFulltextBlockFilter.java | 18 -
.../filters/english/MinFulltextWordsFilter.java | 18 -
.../filters/english/NumWordsRulesClassifier.java | 18 -
.../filters/english/TerminatingBlocksFinder.java | 18 -
.../heuristics/AddPrecedingLabelsFilter.java | 18 -
.../filters/heuristics/ArticleMetadataFilter.java | 18 -
.../filters/heuristics/BlockProximityFusion.java | 18 -
.../filters/heuristics/ContentFusion.java | 18 -
.../heuristics/DocumentTitleMatchClassifier.java | 18 -
.../heuristics/ExpandTitleToContentFilter.java | 18 -
.../filters/heuristics/KeepLargestBlockFilter.java | 18 -
.../boilerpipe/filters/heuristics/LabelFusion.java | 18 -
.../LargeBlockSameTagLevelToContentFilter.java | 18 -
.../filters/heuristics/ListAtEndFilter.java | 18 -
.../heuristics/SimpleBlockFusionProcessor.java | 18 -
.../TrailingHeadlineToBoilerplateFilter.java | 18 -
.../filters/simple/BoilerplateBlockFilter.java | 18 -
.../boilerpipe/filters/simple/InvertedFilter.java | 18 -
.../filters/simple/LabelToBoilerplateFilter.java | 18 -
.../filters/simple/LabelToContentFilter.java | 18 -
.../simple/MarkEverythingBoilerplateFilter.java | 18 -
.../simple/MarkEverythingContentFilter.java | 18 -
.../filters/simple/MinClauseWordsFilter.java | 18 -
.../boilerpipe/filters/simple/MinWordsFilter.java | 18 -
.../filters/simple/SplitParagraphBlocksFilter.java | 18 -
.../filters/simple/SurroundingToContentFilter.java | 18 -
.../boilerpipe/labels/ConditionalLabelAction.java | 18 -
.../boilerpipe/labels/DefaultLabels.java | 18 -
.../boilerpipe/labels/LabelAction.java | 18 -
.../sax/BoilerpipeHTMLContentHandler.java | 18 -
.../boilerpipe/sax/BoilerpipeHTMLParser.java | 18 -
.../boilerpipe/sax/BoilerpipeSAXInput.java | 18 -
.../boilerpipe/sax/CommonTagActions.java | 18 -
.../boilerpipe/sax/DefaultTagActionMap.java | 18 -
.../kohlschutter/boilerpipe/sax/HTMLDocument.java | 18 -
.../kohlschutter/boilerpipe/sax/HTMLFetcher.java | 18 -
.../boilerpipe/sax/HTMLHighlighter.java | 18 -
.../boilerpipe/sax/ImageExtractor.java | 18 -
.../boilerpipe/sax/InputSourceable.java | 18 -
.../boilerpipe/sax/MarkupTagAction.java | 18 -
.../com/kohlschutter/boilerpipe/sax/TagAction.java | 18 -
.../kohlschutter/boilerpipe/sax/TagActionMap.java | 18 -
.../boilerpipe/util/UnicodeTokenizer.java | 18 -
.../pe/shared/config/kafka/KafkaConfig.java | 15 +-
.../pe/shared/config/kafka/KafkaConnectUtils.java | 32 +-
.../pe/shared/config/kafka/kafka/KafkaConfig.java | 13 +-
.../config/kafka/kafka/KafkaConnectUtils.java | 35 +-
.../complex/TopologyValidationProcessor.java | 4 +-
.../sinks/brokers/jvm/jms/JmsPublisherSink.java | 6 +-
.../streampipes-sinks-internal-jvm/pom.xml | 4 -
streampipes-integration-tests/pom.xml | 16 +
.../integration/adapters/AdaptersTest.java | 8 +
...tAdapterTester.java => KafkaAdapterTester.java} | 112 +-
.../integration/adapters/MqttAdapterTester.java | 18 +-
.../integration/adapters/PulsarAdapterTester.java | 14 +-
.../integration/client/ClientLiveDataTest.java | 14 +-
.../client/ClientLiveDataTesterBase.java | 117 +
.../integration/client/ClientNatsTester.java | 64 +
.../integration/containers/KafkaContainer.java | 42 +-
.../integration/containers/KafkaDevContainer.java | 17 +-
.../integration/containers/NatsContainer.java | 36 +-
.../integration/containers/NatsDevContainer.java | 9 +-
.../streampipes/integration/utils/Utils.java | 25 +-
.../apache/streampipes/mail/utils/MailUtils.java | 7 +-
streampipes-measurement-units/pom.xml | 3 +-
.../java/com/github/jqudt/onto/UnitFactory.java | 24 -
.../java/com/github/jqudt/onto/units/AreaUnit.java | 23 -
.../github/jqudt/onto/units/ConcentrationUnit.java | 25 -
.../com/github/jqudt/onto/units/CountingUnit.java | 16 -
.../com/github/jqudt/onto/units/EnergyUnit.java | 16 -
.../com/github/jqudt/onto/units/LengthUnit.java | 19 -
.../java/com/github/jqudt/onto/units/MassUnit.java | 23 -
.../jqudt/onto/units/PressureOrStressUnit.java | 15 -
.../github/jqudt/onto/units/TemperatureUnit.java | 18 -
.../com/github/jqudt/onto/units/VolumeUnit.java | 18 -
.../messaging/jms/ActiveMQConnectionProvider.java | 8 +
.../messaging/jms/ActiveMQConsumer.java | 12 +-
.../messaging/jms/ActiveMQPublisher.java | 47 +-
.../streampipes/messaging/jms/SpJmsProtocol.java | 15 +-
.../messaging/kafka/SpKafkaConsumer.java | 14 +-
.../messaging/kafka/SpKafkaProducer.java | 8 +-
.../messaging/kafka/SpKafkaProtocol.java | 16 +-
.../kafka/config/AutoOffsetResetConfig.java | 32 +-
.../kafka/config/ConsumerConfigFactory.java | 3 +-
.../messaging/mqtt/AbstractMqttConnector.java | 6 +
.../streampipes/messaging/mqtt/MqttConsumer.java | 12 +-
.../streampipes/messaging/mqtt/MqttPublisher.java | 12 +-
.../streampipes/messaging/mqtt/SpMqttProtocol.java | 16 +-
.../messaging/nats/AbstractNatsConnector.java | 8 +
.../streampipes/messaging/nats/NatsConsumer.java | 22 +-
.../streampipes/messaging/nats/NatsPublisher.java | 12 +-
.../streampipes/messaging/nats/SpNatsProtocol.java | 16 +-
streampipes-messaging-pulsar/pom.xml | 57 +
.../messaging/pulsar/PulsarConsumer.java | 86 +
.../messaging/pulsar/PulsarProducer.java | 78 +
.../messaging/pulsar/SpPulsarProtocol.java | 28 +-
.../messaging/pulsar/SpPulsarProtocolFactory.java | 28 +-
.../streampipes/messaging/EventConsumer.java | 6 +-
.../streampipes/messaging/EventProducer.java | 5 +-
.../messaging/SpProtocolDefinition.java | 5 +-
streampipes-model/pom.xml | 12 +-
.../apache/streampipes/model/ShortUserInfo.java | 70 +
.../streampipes/model/config/SpProtocol.java | 3 +-
.../adapter/migration/GenericAdapterConverter.java | 94 +-
.../adapter/migration/IAdapterConverter.java | 6 +-
.../adapter/migration}/MigrationHelpers.java | 11 +-
.../migration/SpecificAdapterConverter.java | 17 +-
.../migration}/format/CsvFormatMigrator.java | 2 +-
.../migration}/format/EmptyFormatMigrator.java | 2 +-
.../adapter/migration}/format/FormatMigrator.java | 2 +-
.../migration}/format/JsonFormatMigrator.java | 12 +-
.../migration}/format/XmlFormatMigrator.java | 2 +-
.../adapter/migration/utils/AdapterModels.java | 28 +-
.../adapter/migration}/utils/DocumentKeys.java | 2 +-
.../adapter/migration}/utils/FormatIds.java | 2 +-
.../migration}/utils/GenericAdapterUtils.java | 8 +-
.../model/connect/guess/AdapterEventPreview.java | 7 +-
.../model/connect/guess/AdapterGuessInfo.java | 55 -
.../model/connect/guess/GuessSchema.java | 8 +-
.../model/connect/guess/GuessTypeInfo.java | 72 -
.../model/datalake/DataLakeMeasure.java | 2 +
.../model/file/GenericStorageAttachment.java | 31 +-
.../model/grounding/PulsarTransportProtocol.java | 26 +-
.../model/grounding/TransportProtocol.java | 3 +-
.../streampipes/model/monitoring/SpLogEntry.java | 16 +-
...{StreamPipesStatistics.java => SpLogLevel.java} | 6 +-
.../SpLogMessage.java} | 79 +-
.../streampipes/model/schema/EventProperty.java | 2 +-
.../streampipes/model/schema/EventSchema.java | 3 +-
.../RuntimeResolvableTreeInputStaticProperty.java | 10 +
.../org/apache/streampipes/model/util/Cloner.java | 3 +
.../apache/streampipes/model/util/ListUtils.java | 49 +-
streampipes-pipeline-management/pom.xml | 30 +-
.../manager/assets/DocumentationParser.java | 6 +-
.../manager/endpoint/EndpointItemFetcher.java | 3 +-
.../manager/endpoint/EndpointItemParser.java | 3 +-
.../manager/matching/ProtocolSelector.java | 6 +
.../monitoring/pipeline/ExtensionsLogProvider.java | 6 +-
.../manager/pipeline/PipelineManager.java | 23 +-
.../runtime/PipelineElementRuntimeInfoFetcher.java | 101 +-
.../streampipes/ps/DataLakeMeasureResourceV4.java | 9 +-
.../apache/streampipes/ps/DataLakeResourceV4.java | 4 +-
.../management/NotificationsResourceManager.java | 75 +
.../extensions/connect/AdapterWorkerResource.java | 10 +-
.../extensions/monitoring/MonitoringResource.java | 2 +-
.../shared/impl/AbstractSharedRestInterface.java | 4 +
streampipes-rest/pom.xml | 7 +-
.../apache/streampipes/rest/impl/UserResource.java | 40 +-
.../rest/impl/admin/UserAdminResource.java | 61 +
.../rest/impl/connect/AdapterResource.java | 6 +-
.../rest/impl/connect/GuessResource.java | 15 +-
.../impl/connect/RuntimeResolvableResource.java | 8 +-
.../impl/datalake/PersistedDataStreamResource.java | 7 +-
.../rest/impl/pe/DataProcessorResource.java | 4 +-
.../streampipes/rest/impl/pe/DataSinkResource.java | 4 +-
.../rest/impl/pe/DataStreamResource.java | 4 +-
.../org/apache/streampipes/rest/utils/Utils.java | 22 +-
streampipes-sdk/pom.xml | 9 +-
.../apache/streampipes/sdk/StaticProperties.java | 5 +-
...AbstractConfigurablePipelineElementBuilder.java | 12 +-
.../sdk/builder/adapter/GuessSchemaBuilder.java | 50 +-
.../org/apache/streampipes/sdk/helpers/Labels.java | 17 +-
.../sdk/helpers/SupportedProtocols.java | 5 +
streampipes-service-base/pom.xml | 4 -
.../service/base/StreamPipesServiceBase.java | 2 +-
.../Dockerfile | 4 +-
streampipes-service-core-nats/pom.xml | 94 +
.../core/nats/StreamPipesCoreApplicationNats.java | 53 +
streampipes-service-core/Dockerfile | 4 +-
streampipes-service-core/pom.xml | 39 +-
...cation.java => StreamPipesCoreApplication.java} | 40 +-
.../service/core/StreamPipesResourceConfig.java | 2 +
...FormatMigrator.java => SupportedProtocols.java} | 11 +-
.../service/core/WebSecurityConfig.java | 2 +-
.../core}/filter/TokenAuthenticationFilter.java | 2 +-
.../core/migrations/v093/AdapterBackupWriter.java | 2 +-
.../core/migrations/v093/AdapterMigration.java | 36 +-
.../v093/migrator/GenericAdapterMigrator.java | 102 +-
.../v093/migrator/SpecificAdapterMigrator.java | 11 +-
streampipes-service-discovery-consul/pom.xml | 4 -
.../streampipes/storage/api/IGenericStorage.java | 7 +
.../storage/api/INotificationStorage.java | 2 +
streampipes-storage-couchdb/pom.xml | 8 +-
.../couchdb/impl/ConnectionStorageImpl.java | 5 +-
.../storage/couchdb/impl/DataLakeStorageImpl.java | 3 +-
.../storage/couchdb/impl/GenericStorageImpl.java | 25 +-
.../couchdb/impl/NotificationStorageImpl.java | 28 +-
.../streampipes/storage/couchdb/utils/Utils.java | 11 +
.../storage/couchdb/utils/TestUrlEscapers.java | 44 +
streampipes-user-management/pom.xml | 4 +-
.../wrapper/flink/consumer/JmsFlinkConsumer.java | 12 +-
.../wrapper/flink/consumer/MqttFlinkConsumer.java | 12 +-
.../wrapper/flink/sink/JmsFlinkProducer.java | 4 +-
.../wrapper/flink/sink/MqttFlinkProducer.java | 4 +-
.../flink/status/PipelineElementStatusSender.java | 46 -
.../status/PipelineElementStatusSenderFactory.java | 42 -
.../kafka/KafkaStreamsDataProcessorRuntime.java | 18 +-
.../wrapper/kafka/KafkaStreamsOutputCollector.java | 14 +-
.../standalone/function/FunctionContext.java | 10 +-
.../standalone/function/StreamPipesFunction.java | 4 +-
.../routing/StandaloneSpInputCollector.java | 14 +-
.../routing/StandaloneSpOutputCollector.java | 20 +-
.../runtime/StandaloneEventProcessorRuntime.java | 4 +-
.../runtime/StandaloneEventSinkRuntime.java | 4 +-
.../runtime/StandalonePipelineElementRuntime.java | 20 +-
.../context/SpEventProcessorRuntimeContext.java | 19 +-
.../wrapper/context/SpEventSinkRuntimeContext.java | 14 +-
.../wrapper/context/SpRuntimeContext.java | 34 +-
.../generator/DataProcessorContextGenerator.java | 4 +-
.../generator/DataSinkContextGenerator.java | 4 +-
.../support/utils/ConnectEventSchemaUtils.ts | 2 +-
.../support/utils/DataDownloadDialogUtils.ts | 16 +-
ui/cypress/support/utils/PrepareTestDataUtils.ts | 2 +-
.../support/utils/ProcessingElementTestUtils.ts | 2 +-
ui/cypress/support/utils/StaticPropertyUtils.ts | 28 +-
ui/cypress/support/utils/connect/ConnectUtils.ts | 5 +-
ui/cypress/support/utils/datalake/DataLakeUtils.ts | 9 +-
ui/cypress/tests/adapter/formats/format.spec.ts | 8 +-
ui/cypress/tests/thirdparty/InfluxDb.smoke.spec.ts | 4 +-
ui/cypress/tests/thirdparty/Kafka.smoke.spec.ts | 12 +-
ui/deployment/appng5.module.mst | 5 +-
ui/deployment/base-navigation.component.mst | 4 +-
ui/deployment/prebuild.js | 8 +-
ui/package-lock.json | 12431 +++++++++----------
ui/package.json | 72 +-
.../streampipes/platform-services/package.json | 8 +-
.../src/lib/apis/user-admin.service.ts} | 54 +-
.../platform-services/src/lib/apis/user.service.ts | 15 +-
.../src/lib/model/gen/streampipes-model.ts | 134 +-
.../platform-services/src/public-api.ts | 1 +
ui/projects/streampipes/shared-ui/package.json | 16 +-
.../basic-nav-tabs/basic-nav-tabs.component.html | 5 +-
.../basic-view/basic-view.component.html | 1 -
.../basic-view/basic-view.component.scss | 2 +-
.../exception-details-dialog.component.html | 6 +-
.../exception-details-dialog.component.ts | 4 +-
.../sp-exception-message.component.html | 4 +-
.../sp-exception-message.component.ts | 4 +-
.../confirm-dialog/confirm-dialog.component.html | 42 +-
.../panel-dialog/panel-dialog.component.html | 2 +-
.../standard-dialog/standard-dialog.component.html | 2 +-
.../src/lib/services/current-user.service.ts} | 50 +-
.../src/lib}/services/jwt-token-storage.service.ts | 2 +
.../shared-ui/src/lib/shared-ui.module.ts | 4 +-
.../streampipes/shared-ui/src/public-api.ts | 2 +
ui/src/app/add/add.component.html | 89 +-
ui/src/app/add/add.module.ts | 2 +-
ui/src/app/apidocs/apidocs.module.ts | 2 +-
.../app-asset-monitoring.module.ts | 2 +-
.../create-asset/create-asset.component.html | 7 +-
.../add-pipeline-dialog.component.html | 10 +-
.../app/app-overview/app-overview.component.html | 2 +-
ui/src/app/app-overview/app-overview.module.ts | 2 +-
ui/src/app/assets/assets.module.ts | 2 +-
.../asset-link-item/asset-link-item.component.html | 3 -
.../asset-selection-panel.component.html | 3 -
.../asset-overview/asset-overview.component.html | 5 -
ui/src/app/configuration/configuration.module.ts | 2 +-
.../consul-configs-password.component.spec.ts | 2 +-
.../datalake-configuration.component.html | 4 -
.../general-configuration.component.html | 3 +-
.../edit-label/edit-label.component.html | 23 +-
.../label-configuration.component.html | 2 -
.../abstract-security-principal-config.ts | 2 +
.../edit-user-dialog/edit-user-dialog.component.ts | 5 +-
.../security-service-config.component.ts | 2 +-
.../security-user-config.component.ts | 2 +-
.../error-message/error-message.component.ts | 4 +-
.../event-property-row.component.html | 9 +-
.../event-property-row.component.ts | 17 +-
.../event-schema-preview.component.ts | 27 +-
.../event-schema/event-schema.component.html | 1 -
.../event-schema/event-schema.component.ts | 11 +-
.../schema-editor-header.component.html | 2 -
.../abstract-adapter-details.directive.ts | 12 +-
.../adapter-details-logs.component.html | 1 -
.../adapter-details-logs.component.ts | 11 +-
.../adapter-details-metrics.component.html | 1 -
.../adapter-details-metrics.component.ts | 9 +-
.../adapter-details-overview.component.ts | 10 +-
.../existing-adapters.component.html | 9 -
.../existing-adapters.component.scss | 9 +-
.../existing-adapters.component.ts | 12 +-
.../filter-toolbar/filter-toolbar.component.html | 53 +-
ui/src/app/connect/connect.module.ts | 2 +-
ui/src/app/connect/services/rest.service.ts | 5 +-
ui/src/app/core-ui/core-ui.module.ts | 2 +-
.../select-data-range.component.ts | 8 +-
.../image-labeling/image-labeling.component.html | 1 -
.../object-permission-dialog.component.ts | 6 +-
.../static-color-picker.component.html | 28 +-
.../static-file-input.component.html | 1 -
.../static-free-input.component.html | 8 +-
.../static-free-input.component.scss | 4 +-
.../static-mapping-unary.component.html | 2 +-
.../static-property.component.html | 2 +-
.../static-properties/static-property.component.ts | 5 +-
.../base-runtime-resolvable-input.ts | 7 +-
.../core/components/iconbar/iconbar.component.html | 2 -
.../core/components/iconbar/iconbar.component.scss | 7 +-
.../core/components/iconbar/iconbar.component.ts | 4 +-
.../streampipes/streampipes.component.ts | 5 +-
.../core/components/toolbar/toolbar.component.html | 2 -
.../core/components/toolbar/toolbar.component.ts | 17 +-
ui/src/app/core/core.module.ts | 2 +-
.../overview/dashboard-overview.component.css | 4 +-
.../overview/dashboard-overview.component.html | 6 -
.../overview/dashboard-overview.component.ts | 4 +-
.../panel/dashboard-panel.component.html | 4 +-
.../components/panel/dashboard-panel.component.ts | 4 +-
.../widget/dashboard-widget.component.html | 18 +-
.../widgets/status/status-widget.component.html | 3 +
.../widgets/status/status-widget.component.ts | 22 +-
ui/src/app/dashboard/dashboard.module.ts | 2 +-
.../add-visualization-dialog.component.html | 29 +-
.../add-visualization-dialog.component.scss | 5 +
.../add-visualization-dialog.component.ts | 2 +-
...lorer-widget-appearance-settings.component.html | 60 +-
.../data-explorer-designer-panel.component.html | 1 -
...ta-explorer-widget-data-settings.component.html | 147 +-
.../field-selection-panel.component.html | 2 -
.../field-selection/field-selection.component.html | 3 +-
.../field-selection/field-selection.component.scss | 2 +-
.../filter-selection-panel.component.html | 18 +-
...-explorer-visualisation-settings.component.html | 19 +-
...data-explorer-dashboard-overview.component.html | 5 -
...data-explorer-dashboard-overview.component.scss | 6 +-
.../data-explorer-dashboard-overview.component.ts | 24 +-
.../data-explorer-dashboard-panel.component.html | 9 +-
.../data-explorer-dashboard-panel.component.ts | 4 +-
.../time-selector/timeRangeSelector.component.html | 18 +-
.../time-selector/timeRangeSelector.component.scss | 23 +-
.../data-explorer-dashboard-widget.component.html | 5 +-
.../data-explorer-dashboard-widget.component.ts | 23 +-
.../base/base-data-explorer-widget.directive.ts | 6 +-
.../widgets/base/data-explorer-widget-data.ts | 4 +-
.../correlation-chart-widget-config.component.html | 9 +-
...distribution-chart-widget-config.component.html | 9 +-
.../map/config/map-widget-config.component.html | 7 +-
.../config/table-widget-config.component.html | 9 +-
.../aggregate-configuration.component.html | 16 +-
.../select-color-properties.component.html | 58 +-
.../select-color-properties.component.scss | 6 +
.../select-property/select-property.component.html | 7 +-
ui/src/app/data-explorer/data-explorer.module.ts | 2 +-
...a-explorer-edit-data-view-dialog.component.html | 4 +-
.../user-defined-output.component.html | 7 +-
.../pipeline-assembly.component.html | 3 -
.../pipeline-element-icon-stand-row.component.html | 3 +-
.../pipeline-element-icon-stand.component.html | 48 +-
.../pipeline-element-icon-stand.component.scss | 2 +-
.../pipeline-element-options.component.css | 53 +
.../pipeline-element-options.component.html | 6 -
ui/src/app/editor/editor.component.ts | 4 +-
ui/src/app/editor/editor.module.ts | 2 +-
.../file-overview/file-overview.component.html | 1 -
ui/src/app/files/files.module.ts | 2 +-
ui/src/app/home/home.component.html | 15 +-
ui/src/app/home/home.component.scss | 5 +
ui/src/app/home/home.component.ts | 8 +-
ui/src/app/home/home.module.ts | 2 +-
ui/src/app/http-interceptor.ts | 8 +-
ui/src/app/info/info.module.ts | 2 +-
.../login/components/login/login.component.html | 2 +-
.../components/startup/startup.component.scss | 4 +-
ui/src/app/login/login.module.ts | 2 +-
.../app/notifications/notifications.component.html | 11 +-
ui/src/app/notifications/notifications.module.ts | 2 +-
.../notifications/service/notifications.service.ts | 6 +
.../actions/pipeline-actions.component.ts | 13 +-
.../components/edit/quickedit.component.ts | 14 +-
.../monitoring/pipeline-monitoring.component.html | 1 -
.../monitoring/pipeline-monitoring.component.ts | 14 +-
.../pipeline-details-overview.component.ts | 14 +-
.../pipeline-logs/pipeline-logs.component.html | 1 -
.../pipeline-logs/pipeline-logs.component.ts | 14 +-
.../components/sp-pipeline-details.directive.ts | 8 +-
.../pipeline-details/pipeline-details.module.ts | 2 +-
.../functions-logs/functions-logs.component.html | 1 -
.../functions-metrics.component.html | 1 -
.../functions-overview.component.html | 1 -
.../pipeline-overview.component.html | 92 +-
.../pipeline-overview.component.scss | 9 +-
.../pipeline-overview.component.ts | 4 +-
.../pipeline-categories-dialog.component.html | 8 -
ui/src/app/pipelines/pipelines.component.html | 3 -
ui/src/app/pipelines/pipelines.component.ts | 4 +-
ui/src/app/pipelines/pipelines.module.ts | 2 +-
.../profile/components/basic-profile-settings.ts | 6 +-
.../general-profile-settings.component.html | 2 +-
.../general/general-profile-settings.component.ts | 20 +-
ui/src/app/profile/profile.module.ts | 2 +-
ui/src/app/services/auth.service.ts | 47 +-
ui/src/app/services/secure.pipe.ts | 6 +-
ui/src/app/services/services.module.ts | 4 -
ui/src/scss/sp/buttons.scss | 44 +-
ui/src/scss/sp/colors.scss | 2 -
ui/src/scss/sp/data-explorer.scss | 4 +-
ui/src/scss/sp/forms.scss | 170 +-
ui/src/scss/sp/layout.scss | 30 +-
ui/src/scss/sp/mat-tab.scss | 8 +-
ui/src/scss/sp/pipeline-element-options.scss | 52 -
ui/src/scss/sp/sp-theme.scss | 101 +-
ui/src/scss/sp/widgets.scss | 6 +-
627 files changed, 12431 insertions(+), 11754 deletions(-)
create mode 100644
archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/pe/__packageName__/__classNamePrefix__GenericAdapter.java
create mode 100644
archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/pe/__packageName__/__classNamePrefix__SpecificAdapter.java
copy
ui/projects/streampipes/shared-ui/src/lib/dialog/panel-dialog/panel-dialog.component.html
=>
archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/__package__.pe.__packageName__.genericadapter/documentation.md
(64%)
copy
archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/{__package__.pe.__packageName__.processor
=> __package__.pe.__packageName__.genericadapter}/icon.png (100%)
copy
archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/{Dockerfile
=>
src/main/resources/__package__.pe.__packageName__.genericadapter/strings.en}
(74%)
copy
ui/projects/streampipes/shared-ui/src/lib/dialog/panel-dialog/panel-dialog.component.html
=>
archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/__package__.pe.__packageName__.specificadapter/documentation.md
(64%)
copy
archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/{__package__.pe.__packageName__.processor
=> __package__.pe.__packageName__.specificadapter}/icon.png (100%)
copy
archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/{Dockerfile
=>
src/main/resources/__package__.pe.__packageName__.specificadapter/strings.en}
(73%)
copy streampipes-service-core/Dockerfile =>
installer/cli/deploy/standalone/pulsar/docker-compose.dev.yml (82%)
create mode 100644 installer/cli/deploy/standalone/pulsar/docker-compose.yml
copy streampipes-service-core/Dockerfile =>
installer/cli/environments/backend-pulsar (83%)
copy streampipes-service-core/Dockerfile =>
installer/cli/environments/basic-pulsar (83%)
copy streampipes-service-core/Dockerfile =>
installer/cli/environments/lite-pulsar (83%)
copy streampipes-service-core/Dockerfile =>
installer/cli/environments/pipeline-element-pulsar (83%)
create mode 100644 installer/compose/docker-compose.pulsar.yml
copy
streampipes-messaging/src/main/java/org/apache/streampipes/messaging/SpProtocolDefinition.java
=>
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/live/IBrokerConfigOverride.java
(72%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/live/{IKafkaConfig.java
=> IConfiguredEventProducer.java} (80%)
rename
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/live/{IKafkaConfig.java
=> ISubscription.java} (91%)
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/live/ConfiguredEventProducer.java
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/live/ProducerManager.java
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/format/EmptyFormatMigrator.java
=>
streampipes-client/src/main/java/org/apache/streampipes/client/live/Subscription.java
(65%)
copy
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IGenericStorage.java
=>
streampipes-commons/src/main/java/org/apache/streampipes/commons/resources/Resources.java
(60%)
copy
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/AdaptersTest.java
=> streampipes-commons/src/test/java/TestResources.java (65%)
create mode 100644 streampipes-commons/src/test/resources/test.txt
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/model/pipeline
=>
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management}/AdapterEventPreviewPipeline.java
(68%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management}/util/TransportFormatGenerator.java
(96%)
copy {streampipes-extensions/streampipes-connectors-opcua =>
streampipes-connect-shared}/pom.xml (75%)
create mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/AdapterPipelineGeneratorBase.java
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/util
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/DatatypeUtils.java
(98%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/Util.java
(93%)
copy
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/elements/AddTimestampPipelineElement.java
(93%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/elements/AddValuePipelineElement.java
(93%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/elements/TransformSchemaAdapterPipelineElement.java
(79%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/elements/TransformStreamAdapterElement.java
(86%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/elements/TransformValueAdapterPipelineElement.java
(79%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/TransformationRule.java
(90%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/schema/CreateNestedTransformationRule.java
(94%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/schema/DeleteTransformationRule.java
(94%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/schema/MoveTransformationRule.java
(97%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/schema/RenameTransformationRule.java
(94%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/schema/SchemaEventTransformer.java
(95%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/schema/SchemaTransformationRule.java
(80%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/stream/DuplicateFilterPipelineElement.java
(96%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/stream/EventRateTransformationRule.java
(94%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/stream/StreamEventTransformer.java
(90%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/stream/StreamTransformationRule.java
(80%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/value/CorrectionValueTransformationRule.java
(96%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/value/DatatypeTransformationRule.java
(90%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/value/TimestampTranformationRule.java
(96%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/value/TimestampTranformationRuleMode.java
(89%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/value/UnitTransformationRule.java
(96%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/value/ValueEventTransformer.java
(93%)
rename
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared}/preprocessing/transform/value/ValueTransformationRule.java
(80%)
rename
{streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/util
=>
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform}/DatatypeUtilsTest.java
(96%)
rename
{streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing}/transform/schema/CreateNestedTransformationRuleTest.java
(90%)
rename
{streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing}/transform/schema/DeleteTransformationRuleTest.java
(89%)
rename
{streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing}/transform/schema/MoveTransformationRuleTest.java
(93%)
rename
{streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing}/transform/schema/RenameTransformationRuleTest.java
(91%)
rename
{streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing}/transform/schema/SchemaEventTransformerTest.java
(75%)
rename
{streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing}/transform/value/CorrectionValueTest.java
(95%)
rename
{streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing}/transform/value/UnitTransformRuleTest.java
(96%)
rename
{streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter
=>
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing}/transform/value/ValueEventTransformerTest.java
(81%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/config/IStreamPipesClientConfig.java
=>
streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/sanitizer/MeasureNameSanitizer.java
(66%)
create mode 100644
streampipes-data-explorer-commons/src/test/java/org/apache/streampipes/dataexplorer/commons/sanitizer/MeasureNameSanitizerTest.java
create mode 100644
streampipes-data-export/src/main/java/org/apache/streampipes/export/utils/ImportAdapterMigrationUtils.java
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/monitoring/{IPipelineElementLogger.java
=> FixedSizeList.java} (54%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/monitoring/{IPipelineElementLogger.java
=> IExtensionsLogger.java} (72%)
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/preprocessing/elements/{SendToNatsAdapterSink.java
=> SendToPulsarAdapterSink.java} (62%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/monitoring/ExtensionsLogger.java
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/adapter/OpcUaNodeMetadataExtractor.java
delete mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/adapter/configuration/SpOpcUaConfig.java
rename
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/{adapter
=> client}/SpOpcUaClient.java (89%)
rename
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/{adapter
=> config}/MiloOpcUaConfigurationProvider.java (92%)
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/format/EmptyFormatMigrator.java
=>
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/config/OpcUaAdapterConfig.java
(63%)
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/config/OpcUaConfig.java
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/config/SharedUserConfiguration.java
rename
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/{adapter/configuration/SpOpcUaConfigBuilder.java
=> config/SpOpcUaConfigExtractor.java} (63%)
rename
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/{adapter
=> model}/OpcNode.java (98%)
rename
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/{adapter
=> }/utils/ExceptionMessageExtractor.java (94%)
rename
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/{adapter
=> }/utils/OpcUaTypes.java (96%)
rename
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/{adapter
=> }/utils/OpcUaUtil.java (87%)
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/test/java/org/apache/streampipes/extensions/connectors/opcua/adapter/OpcUaNodeMetadataExtractorTest.java
copy
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/{MqttAdapterTester.java
=> KafkaAdapterTester.java} (52%)
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/format/EmptyFormatMigrator.java
=>
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/client/ClientLiveDataTest.java
(77%)
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/client/ClientLiveDataTesterBase.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/client/ClientNatsTester.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/StreamPipesRuntimeError.java
=>
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/KafkaContainer.java
(54%)
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/format/EmptyFormatMigrator.java
=>
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/KafkaDevContainer.java
(75%)
rename
streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/StreamPipesRuntimeError.java
=>
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/NatsContainer.java
(53%)
rename
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/monitoring/IPipelineElementLogger.java
=>
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/NatsDevContainer.java
(81%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/config/IStreamPipesClientConfig.java
=>
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/utils/Utils.java
(66%)
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/AreaUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/ConcentrationUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/CountingUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/EnergyUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/LengthUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/MassUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/PressureOrStressUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/TemperatureUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/VolumeUnit.java
rename
streampipes-client/src/main/java/org/apache/streampipes/client/live/KafkaConfig.java
=>
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/config/AutoOffsetResetConfig.java
(58%)
create mode 100644 streampipes-messaging-pulsar/pom.xml
create mode 100644
streampipes-messaging-pulsar/src/main/java/org/apache/streampipes/messaging/pulsar/PulsarConsumer.java
create mode 100644
streampipes-messaging-pulsar/src/main/java/org/apache/streampipes/messaging/pulsar/PulsarProducer.java
copy
streampipes-messaging-nats/src/main/java/org/apache/streampipes/messaging/nats/SpNatsProtocol.java
=>
streampipes-messaging-pulsar/src/main/java/org/apache/streampipes/messaging/pulsar/SpPulsarProtocol.java
(58%)
copy
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/SpJmsProtocol.java
=>
streampipes-messaging-pulsar/src/main/java/org/apache/streampipes/messaging/pulsar/SpPulsarProtocolFactory.java
(55%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/ShortUserInfo.java
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/migrator/GenericAdapterMigrator.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration/GenericAdapterConverter.java
(52%)
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/format/FormatMigrator.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration/IAdapterConverter.java
(84%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/migrator
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/MigrationHelpers.java
(79%)
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/format/EmptyFormatMigrator.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration/SpecificAdapterConverter.java
(61%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/format/CsvFormatMigrator.java
(96%)
copy
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/format/EmptyFormatMigrator.java
(93%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/format/FormatMigrator.java
(92%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/format/JsonFormatMigrator.java
(84%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/format/XmlFormatMigrator.java
(95%)
rename
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/utils/AdapterMigrationUtils.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration/utils/AdapterModels.java
(66%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/utils/DocumentKeys.java
(93%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/utils/FormatIds.java
(96%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/utils/GenericAdapterUtils.java
(97%)
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/AdapterGuessInfo.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/GuessTypeInfo.java
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/preprocessing/elements/AddTimestampPipelineElement.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/file/GenericStorageAttachment.java
(59%)
rename
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/preprocessing/elements/AddTimestampPipelineElement.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/grounding/PulsarTransportProtocol.java
(61%)
rename
streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/{StreamPipesStatistics.java
=> SpLogLevel.java} (94%)
rename
streampipes-model/src/main/java/org/apache/streampipes/model/{StreamPipesErrorMessage.java
=> monitoring/SpLogMessage.java} (59%)
rename
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/adapter/utils/OpcUaNodeVariants.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/util/ListUtils.java
(53%)
create mode 100644
streampipes-resource-management/src/main/java/org/apache/streampipes/resource/management/NotificationsResourceManager.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/UserAdminResource.java
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/config/IStreamPipesClientConfig.java
=> streampipes-rest/src/main/java/org/apache/streampipes/rest/utils/Utils.java
(63%)
copy {streampipes-service-core => streampipes-service-core-nats}/Dockerfile
(87%)
create mode 100644 streampipes-service-core-nats/pom.xml
create mode 100644
streampipes-service-core-nats/src/main/java/org/apache/streampipes/service/core/nats/StreamPipesCoreApplicationNats.java
rename
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/{StreamPipesBackendApplication.java
=> StreamPipesCoreApplication.java} (88%)
rename
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/{migrations/v093/format/EmptyFormatMigrator.java
=> SupportedProtocols.java} (77%)
rename {streampipes-rest/src/main/java/org/apache/streampipes/rest =>
streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/filter/TokenAuthenticationFilter.java
(98%)
create mode 100644
streampipes-storage-couchdb/src/test/java/org/apache/streampipes/storage/couchdb/utils/TestUrlEscapers.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/status/PipelineElementStatusSender.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/status/PipelineElementStatusSenderFactory.java
copy ui/{src/app/services/secure.pipe.ts =>
projects/streampipes/platform-services/src/lib/apis/user-admin.service.ts} (50%)
copy ui/{src/app/services/jwt-token-storage.service.ts =>
projects/streampipes/shared-ui/src/lib/services/current-user.service.ts} (51%)
rename ui/{src/app =>
projects/streampipes/shared-ui/src/lib}/services/jwt-token-storage.service.ts
(95%)
