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/incubator-streampipes.git.
from 36c86b8 Merge branch 'dev' of github.com:apache/incubator-streampipes
into dev
new 6cdeb31 [STREAMPIPES-250] Refactor Siddhi wrapper
new 6e1c9ef [STREAMPIPES-249] Add compact data sink
new 8c5beb8 [STREAMPIPES-250] Refactor Siddhi Wrapper
The 3 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:
streampipes-wrapper-siddhi/pom.xml | 6 +
.../wrapper/siddhi/constants/SiddhiConstants.java | 31 ++-
.../wrapper/siddhi/engine/SiddhiEngine.java | 127 ++++++++++
.../wrapper/siddhi/engine/SiddhiEventEngine.java | 274 ++-------------------
.../siddhi/engine/SiddhiStatementGenerator.java | 11 +-
.../siddhi/engine/StreamPipesSiddhiProcessor.java | 57 +++++
.../engine/{ => callback}/SiddhiDebugCallback.java | 2 +-
.../callback/SiddhiOutputStreamCallback.java | 54 ++++
.../SiddhiOutputStreamDebugCallback.java} | 24 +-
.../engine/generator/EventTypeGenerator.java | 77 ++++++
.../engine/generator/InputStreamNameGenerator.java | 31 ++-
.../engine/generator/SiddhiAppGenerator.java | 86 +++++++
.../generator/SiddhiInvocationConfigGenerator.java | 65 +++++
.../wrapper/siddhi/model/EventType.java | 25 +-
.../siddhi/model/SiddhiProcessorParams.java | 93 +++++++
.../siddhi/query/AbstractQueryGenerator.java | 27 +-
.../wrapper/siddhi/query/FromClause.java | 6 +-
.../wrapper/siddhi/query/SelectClause.java | 26 +-
.../wrapper/siddhi/query/SiddhiStatement.java | 39 ++-
.../siddhi/query/expression/Expression.java | 27 +-
.../siddhi/query/expression/Expressions.java | 11 +-
.../query/expression/PropertyExpression.java | 6 +-
.../wrapper/siddhi/utils/SiddhiUtils.java | 80 ++++++
.../streampipes/wrapper/standalone/SinkParams.java | 18 +-
.../wrapper/standalone/StreamPipesDataSink.java | 16 +-
25 files changed, 827 insertions(+), 392 deletions(-)
copy
archetypes/streampipes-archetype-pe-processors-jvm/src/main/resources/archetype-resources/src/main/java/pe/processor/__packageName__/__classNamePrefix__Parameters.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/constants/SiddhiConstants.java
(52%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/SiddhiEngine.java
copy
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataProcessorDeclarer.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/SiddhiStatementGenerator.java
(72%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/StreamPipesSiddhiProcessor.java
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/{
=> callback}/SiddhiDebugCallback.java (93%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/callback/SiddhiOutputStreamCallback.java
rename
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/{SiddhiDebugCallback.java
=> callback/SiddhiOutputStreamDebugCallback.java} (55%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/generator/EventTypeGenerator.java
copy
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/pe/processor/__packageName__/__classNamePrefix__Parameters.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/generator/InputStreamNameGenerator.java
(55%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/generator/SiddhiAppGenerator.java
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/generator/SiddhiInvocationConfigGenerator.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/runtime/SourceInfo.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/model/EventType.java
(71%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/model/SiddhiProcessorParams.java
copy
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/Filetypes.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/AbstractQueryGenerator.java
(63%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/NoValidSepaStructureException.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/FromClause.java
(88%)
copy
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/Filetypes.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/SelectClause.java
(64%)
copy
ui/src/app/editor/components/pipeline-element-icon-stand/pipeline-element-icon-stand.component.scss
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/SiddhiStatement.java
(59%)
copy
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/Filetypes.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/Expression.java
(65%)
copy
streampipes-code-generation/src/main/java/org/apache/streampipes/codegeneration/api/IDeclareModelGenerator.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/Expressions.java
(73%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/NoSuitableSepasAvailableException.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/PropertyExpression.java
(86%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/utils/SiddhiUtils.java
