This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch 1632-cleanup-data-processor-and-sink-api
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from ffea8215c Fix bug in aggregation flink module
add bed05dd73 chore: mark streampipes-wrapper-python as deprecated (#1623)
add 3ac670bc5 Bump types-requests in /streampipes-client-python (#1588)
add b15ed1023 Bump mkdocstrings[python] in /streampipes-client-python
(#1631)
add 36ee46f2a chore: add missing support of NATS as messaging protocol
(#1628)
add 77a34d567 Bump spring-boot.version from 3.0.6 to 3.1.0 (#1595)
add 0a471ab7f [hotfix] Add proper time selection to another cypress test
(#1641)
add 00a1e9008 Merge branch 'dev' into
1632-cleanup-data-processor-and-sink-api
add 7413d0fce Properly return output source and schema info
No new revisions were added by this update.
Summary of changes:
.../archetype-resources/src/main/java/Init.java | 4 +-
.../archetype-resources/src/main/java/Init.java | 4 +-
.../archetype-resources/src/main/java/Init.java | 4 +-
pom.xml | 2 +-
streampipes-client-python/setup.py | 4 +-
.../api/monitoring/IPipelineElementLogger.java | 5 +-
.../api/pe/param/IDataProcessorParameters.java | 2 +
.../connectors/influx/InfluxConnectorsInit.java | 4 +-
.../pe/flink/AllFlinkPipelineElementsInit.java | 4 +-
.../pe/jvm/AllPipelineElementsInit.java | 4 +-
.../aggregation/flink/AggregationFlinkInit.java | 4 +-
.../jvm/ChangeDetectionJvmInit.java | 4 +-
.../enricher/flink/EnricherFlinkInit.java | 4 +-
.../processors/enricher/jvm/EnricherJvmInit.java | 4 +-
.../processors/filters/jvm/FiltersJvmInit.java | 4 +-
.../processors/siddhi/FiltersSiddhiInit.java | 4 +-
.../processor/geo/flink/GeoFlinkInit.java | 4 +-
.../streampipes/processors/geo/jvm/GeoJvmInit.java | 4 +-
.../jvm/ImageProcessingJvmInit.java | 4 +-
.../detection/flink/PatternDetectionFlinkInit.java | 4 +-
.../statistics/flink/StatisticsFlinkInit.java | 4 +-
.../textmining/flink/TextMiningFlinkInit.java | 4 +-
.../textmining/jvm/TextMiningJvmInit.java | 4 +-
.../flink/TransformationFlinkInit.java | 4 +-
.../transformation/jvm/TransformationJvmInit.java | 4 +-
.../sinks/brokers/jvm/BrokersJvmInit.java | 4 +-
.../sinks/databases/flink/DatabasesFlinkInit.java | 4 +-
.../sinks/databases/jvm/DatabasesJvmInit.java | 4 +-
.../sinks/internal/jvm/SinksInternalJvmInit.java | 4 +-
.../jvm/SinksNotificationsJvmInit.java | 10 ++-
streampipes-wrapper-python/README.md | 91 ++--------------------
streampipes-wrapper-python/setup.py | 1 +
streampipes-wrapper-python/streampipes/api/rest.py | 2 +
streampipes-wrapper-python/streampipes/core.py | 3 +
streampipes-wrapper-python/streampipes/declarer.py | 4 +-
.../streampipes/instances.py | 7 +-
streampipes-wrapper-python/streampipes/manager.py | 2 +
.../model/base/abstract_streampipes_entity.py | 3 +
.../model/base/consumable_streampipes_entity.py | 3 +
.../model/base/named_streampipes_entity.py | 3 +
.../model/base/unnamed_streampipes_entity.py | 4 +
.../streampipes/model/config_item.py | 2 +
.../model/graph/data_processor_description.py | 2 +
.../streampipes/model/pipeline_element_config.py | 2 +
.../staticproperty/free_text_StaticProperty.py | 5 +-
.../model/staticproperty/static_property.py | 3 +
.../streampipes/submitter.py | 3 +-
.../streampipes/utils/register.py | 2 +
.../wrapper/params/DataProcessorParameters.java | 17 ++--
.../wrapper/params/compat/ProcessorParams.java | 5 ++
ui/cypress/support/utils/datalake/DataLakeUtils.ts | 40 ++++++++--
ui/cypress/tests/datalake/widgets/table.ts | 2 +-
52 files changed, 191 insertions(+), 138 deletions(-)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/NoMatchingProtocolException.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/monitoring/IPipelineElementLogger.java
(85%)
