This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch
3266-add-api-to-programmatically-create-pipelines
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from c1e15fe099 docs:Modify the README file of K8S and note that the port
does not match the document use case (#3262)
add b02dbbb6c7 feat(#3266): Add API to programmatically create pipelines
No new revisions were added by this update.
Summary of changes:
.../management/AdapterUpdateManagement.java | 2 +-
.../adapter/compact/CompactConfiguration.java | 23 -----
... => ExtendedPipelineElementValidationInfo.java} | 23 ++++-
.../model/pipeline/PipelineModification.java | 17 +---
...oLevel.java => PipelineModificationResult.java} | 11 ++-
.../model/pipeline/PipelineVerificationResult.java | 11 +--
.../model/pipeline/compact/CompactPipeline.java | 17 ++--
.../pipeline/compact/CompactPipelineElement.java | 14 ++-
.../model/pipeline/compact/CreateOptions.java | 5 +-
.../matching/PipelineModificationGenerator.java | 7 +-
.../matching/PipelineVerificationHandlerV2.java | 27 ++++--
.../v2/pipeline/CheckCompletedVisitor.java | 65 ++++++++++++--
.../compact/CompactPipelineManagement.java | 51 +++++++++++
.../generation/CompactPipelineGenerator.java | 11 ++-
.../DataProcessorPipelineElementGenerator.java | 40 +++++++++
.../DataSinkPipelineElementGenerator.java | 38 +++-----
.../DataStreamPipelineElementGenerator.java} | 18 ++--
.../InvocablePipelineElementGenerator.java | 51 +++++++++++
.../PipelineElementConfigurationStep.java | 74 +++++++++++++++
.../manager/preview/PipelinePreview.java | 1 +
.../rest/impl/CompactPipelineResource.java | 100 +++++++++++++++++++++
21 files changed, 477 insertions(+), 129 deletions(-)
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CompactConfiguration.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/pipeline/{ValidationInfoLevel.java
=> ExtendedPipelineElementValidationInfo.java} (54%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/pipeline/{ValidationInfoLevel.java
=> PipelineModificationResult.java} (71%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/data/PipelineGraph.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/pipeline/PipelineVerificationResult.java
(76%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/credentials/CredentialsProvider.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/pipeline/compact/CompactPipeline.java
(73%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/storage/RunningPipelineElementStorage.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/pipeline/compact/CompactPipelineElement.java
(71%)
copy
streampipes-dataformat/src/main/java/org/apache/streampipes/dataformat/SpDataFormatFactory.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/pipeline/compact/CreateOptions.java
(88%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/CompactPipelineManagement.java
copy
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IPipelineStorage.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/CompactPipelineGenerator.java
(75%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/DataProcessorPipelineElementGenerator.java
copy
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/pe/sink/__packageName__/__classNamePrefix__Parameters.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/DataSinkPipelineElementGenerator.java
(50%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{matching/mapping/AbstractRequirementsSelectorGenerator.java
=> pipeline/compact/generation/DataStreamPipelineElementGenerator.java} (68%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/InvocablePipelineElementGenerator.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/PipelineElementConfigurationStep.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/CompactPipelineResource.java
