This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from aa2e1c53c Merge pull request #1141 from apache/SP-1140
add ad423278c Improve structure of pipeline execution management (#1096)
add 9dd1a91f6 Fix checkstyle issues (#1096)
add 473a4a023 Fix checkstyle issue (#1096)
add 7acee1454 Add comments to intefaces (#1096)
add 96ee8cce0 Support output data streams in functions (#1133)
add 109ea0263 Extend client API to add data streams (#1133)
add 7a57d3003 Fix endpoint path (#1133)
add 5ad116436 Minor improvements to code style (#1133)
add cc3ef284f Merge branch 'dev' into SP-1133
new 468032654 Merge pull request #1135 from apache/SP-1133
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:
.../apache/streampipes/client/api/AdminApi.java | 12 ++++
.../streampipes/client/api/DataStreamApi.java | 9 ++-
streampipes-config/pom.xml | 5 ++
.../streampipes/config/backend/BackendConfig.java | 3 +-
...Settings.java => DefaultMessagingSettings.java} | 83 ++--------------------
.../connect/management/util/GroundingUtils.java | 2 +-
...sFunctionDeclarer.java => IFunctionConfig.java} | 11 ++-
.../api/declarer/IStreamPipesFunctionDeclarer.java | 4 +-
.../connect/adapter/AdapterPipelineGenerator.java | 2 +-
.../adapter/util/TransportFormatGenerator.java | 2 +-
.../management/init/DeclarersSingleton.java | 2 +-
.../model/config}/MessagingSettings.java | 32 +--------
.../streampipes/model/config}/SpDataFormat.java | 2 +-
.../streampipes/model/config}/SpProtocol.java | 2 +-
.../manager/matching/DataSetGroundingSelector.java | 2 +-
.../manager/matching/FormatSelector.java | 2 +-
.../manager/matching/ProtocolSelector.java | 2 +-
.../AbstractPipelineElementResourceManager.java | 12 ++++
.../streampipes/rest/impl/admin/ConsulConfig.java | 2 +-
.../rest/impl/pe/DataStreamResource.java | 17 +++++
.../streampipes/rest/security/AuthConstants.java | 4 ++
.../function/StreamPipesFunctionHandler.java | 36 +++++++++-
.../standalone/function/FunctionConfig.java | 46 +++++-------
.../standalone/function/FunctionConfigBuilder.java | 25 +++++--
.../standalone/function/FunctionContext.java | 9 +++
.../function/FunctionContextGenerator.java | 10 ++-
.../standalone/function/StreamPipesFunction.java | 64 +++++++++++++----
27 files changed, 221 insertions(+), 181 deletions(-)
copy
streampipes-config/src/main/java/org/apache/streampipes/config/backend/{MessagingSettings.java
=> DefaultMessagingSettings.java} (52%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/{IStreamPipesFunctionDeclarer.java
=> IFunctionConfig.java} (80%)
rename {streampipes-config/src/main/java/org/apache/streampipes/config/backend
=>
streampipes-model/src/main/java/org/apache/streampipes/model/config}/MessagingSettings.java
(66%)
rename {streampipes-config/src/main/java/org/apache/streampipes/config/backend
=>
streampipes-model/src/main/java/org/apache/streampipes/model/config}/SpDataFormat.java
(96%)
rename {streampipes-config/src/main/java/org/apache/streampipes/config/backend
=>
streampipes-model/src/main/java/org/apache/streampipes/model/config}/SpProtocol.java
(96%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/DataSeries.java
=>
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/function/FunctionConfig.java
(51%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/IStreamPipesFunctionDeclarer.java
=>
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/function/FunctionConfigBuilder.java
(56%)
