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 2a2d06f62 Bump mkdocstrings[python] in /streampipes-client-python
(#1127)
new 7be2b887d Improve structure of pipeline execution management (#1096)
new ec5e75171 Fix checkstyle issues (#1096)
new 7d091ba95 Fix checkstyle issue (#1096)
new d19b7e042 Add comments to intefaces (#1096)
new 38074381c [hotfix] Add some comments and a log message
The 5 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:
.../org/apache/streampipes/model/SpDataSet.java | 15 +-
.../streampipes/model/api/EndpointSelectable.java | 69 ++++++
.../model/base/InvocableStreamPipesEntity.java | 18 +-
.../model/message/PipelineStatusMessage.java | 9 +-
.../model/pipeline/PipelineOperationStatus.java | 10 +-
.../manager/execution/PipelineExecutionInfo.java | 106 +++++++++
.../execution/PipelineExecutionTaskFactory.java | 60 +++++
.../manager/execution/PipelineExecutor.java | 57 +++++
.../ExtensionsServiceEndpointProvider.java | 62 ++++++
.../manager/execution/http/DetachHttpRequest.java | 24 +-
.../http/DetachPipelineElementSubmitter.java | 53 +++++
.../manager/execution/http/GraphSubmitter.java | 132 -----------
.../manager/execution/http/HttpRequestBuilder.java | 98 ---------
.../manager/execution/http/InvokeHttpRequest.java | 54 +++++
.../http/InvokePipelineElementSubmitter.java | 81 +++++++
.../execution/http/PipelineElementHttpRequest.java | 73 +++++++
.../execution/http/PipelineElementSubmitter.java | 82 +++++++
.../manager/execution/http/PipelineExecutor.java | 243 ---------------------
.../provider/CurrentPipelineElementProvider.java} | 21 +-
.../provider/PipelineElementProvider.java} | 12 +-
.../provider/StoredPipelineElementProvider.java} | 22 +-
.../execution/task/AfterInvocationTask.java | 65 ++++++
.../execution/task/DiscoverEndpointsTask.java | 88 ++++++++
.../execution/task/PipelineExecutionTask.java | 15 +-
.../task/SecretEncryptionTask.java} | 24 +-
.../execution/task/StorePipelineStatusTask.java | 80 +++++++
.../manager/execution/task/SubmitRequestTask.java | 51 +++++
.../manager/execution/task/UpdateGroupIdTask.java | 46 ++++
.../manager/health/PipelineHealthCheck.java | 13 +-
.../streampipes/manager/operations/Operations.java | 22 +-
.../manager/preview/PipelinePreview.java | 10 +-
.../http => storage}/PipelineStorageService.java | 2 +-
.../RunningPipelineElementStorage.java} | 8 +-
.../streampipes/manager/storage/UserService.java | 101 ---------
.../rest/core/base/impl/AbstractRestResource.java | 5 -
35 files changed, 1162 insertions(+), 669 deletions(-)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/api/EndpointSelectable.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/PipelineExecutionInfo.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/PipelineExecutionTaskFactory.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/PipelineExecutor.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/endpoint/ExtensionsServiceEndpointProvider.java
copy
streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/function/FunctionRegistrationHandler.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachHttpRequest.java
(55%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachPipelineElementSubmitter.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/GraphSubmitter.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/HttpRequestBuilder.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/InvokeHttpRequest.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/InvokePipelineElementSubmitter.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/PipelineElementHttpRequest.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/PipelineElementSubmitter.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/PipelineExecutor.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{util/TemporaryGraphStorage.java
=> execution/provider/CurrentPipelineElementProvider.java} (61%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{util/TemporaryGraphStorage.java
=> execution/provider/PipelineElementProvider.java} (73%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{util/TemporaryGraphStorage.java
=> execution/provider/StoredPipelineElementProvider.java} (55%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/AfterInvocationTask.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/DiscoverEndpointsTask.java
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/math/MathSubtractExpression.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/PipelineExecutionTask.java
(71%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{permission/PermissionManager.java
=> execution/task/SecretEncryptionTask.java} (58%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/StorePipelineStatusTask.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/SubmitRequestTask.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/UpdateGroupIdTask.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{execution/http
=> storage}/PipelineStorageService.java (98%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{util/TemporaryGraphStorage.java
=> storage/RunningPipelineElementStorage.java} (78%)
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/storage/UserService.java
