This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 077fa1c1b Merge pull request #1099 from apache/hotfix-fix-nightly-build
add 4981f1208 [#1085] Add getter for event schema to AdapterDescription
add d9250f91f Merge branch 'dev' into SP-1085
add 77354bffc Merge remote-tracking branch 'origin/SP-1065' into SP-1085
add 02059a87d [#1085] Extract find timestamp property from
FileStreamProtocol to EventSchemaUtils
add 8fd086049 [#1085] Replace thread with executor service in
FileStreamProtocol
add 9b1d370de [#1085] Remove SendToBrokerReplayAdapterSink and move code
to FileStreamProtocol
new f84a1311c Merge pull request #1093 from apache/SP-1085
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:
.../extensions/api/connect/IAdapterPipeline.java | 4 +
.../extensions/api/connect/IProtocol.java | 3 -
streampipes-extensions-management/pom.xml | 6 +
.../connect/adapter/AdapterPipelineGenerator.java | 13 +-
.../adapter/model/generic/GenericAdapter.java | 5 -
.../connect/adapter/model/generic/Protocol.java | 10 --
.../pipeline/AdapterEventPreviewPipeline.java | 6 +
.../adapter/model/pipeline/AdapterPipeline.java | 22 ++-
.../elements/SendToBrokerReplayAdapterSink.java | 97 ------------
.../management/util/EventSchemaUtils.java | 61 ++++++++
.../management/util/EventSchemaUtilsTest.java | 80 ++++++++++
.../iiot/protocol/stream/FileStreamProtocol.java | 168 ++++++++++-----------
.../model/connect/adapter/AdapterDescription.java | 3 +
.../connect/adapter/GenericAdapterDescription.java | 4 -
.../adapter/GenericAdapterSetDescription.java | 21 +--
.../adapter/GenericAdapterStreamDescription.java | 12 +-
.../adapter/SpecificAdapterSetDescription.java | 5 +
.../adapter/SpecificAdapterStreamDescription.java | 5 +
.../apache/streampipes/model/util/SchemaUtils.java | 1 +
.../connect/adapter/AdapterDescriptionTest.java | 2 +-
.../generator/EventPropertyNestedTestBuilder.java | 39 ++---
.../EventPropertyPrimitiveTestBuilder.java | 37 ++---
...enerator.java => EventPropertyTestBuilder.java} | 20 ++-
.../test/generator/EventSchemaGenerator.java | 22 ---
.../test/generator/EventSchemaTestBuilder.java | 35 ++---
25 files changed, 354 insertions(+), 327 deletions(-)
delete mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/preprocessing/elements/SendToBrokerReplayAdapterSink.java
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/util/EventSchemaUtils.java
create mode 100644
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/util/EventSchemaUtilsTest.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/output/AppendOutputStrategy.java
=>
streampipes-test-utils/src/main/java/org/apache/streampipes/test/generator/EventPropertyNestedTestBuilder.java
(51%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/grounding/TransportFormat.java
=>
streampipes-test-utils/src/main/java/org/apache/streampipes/test/generator/EventPropertyPrimitiveTestBuilder.java
(52%)
rename
streampipes-test-utils/src/main/java/org/apache/streampipes/test/generator/{EventPropertyGenerator.java
=> EventPropertyTestBuilder.java} (63%)
delete mode 100644
streampipes-test-utils/src/main/java/org/apache/streampipes/test/generator/EventSchemaGenerator.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/output/AppendOutputStrategy.java
=>
streampipes-test-utils/src/main/java/org/apache/streampipes/test/generator/EventSchemaTestBuilder.java
(57%)
