You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2023/01/20 19:48:09 UTC
[streampipes] branch SP-1133 updated (5ad116436 -> cc3ef284f)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch SP-1133
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 5ad116436 Minor improvements to code style (#1133)
add a93628b43 Update mkdocs.yml
add 6a30688a2 update logo
add d607a94a1 Merge pull request #1095 from parthsali/dev
add a532da19d [#877] Format and lint core-model module (#1094)
add 73f858188 [hotfix] add stream example to Mkdocs (#1098)
add 73fa98d74 [hotfix] Fix failing e2e tests
add 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
add f84a1311c Merge pull request #1093 from apache/SP-1085
add bd7b0dffa Bump apache from 25 to 29
add 03f2cd837 Merge pull request #1073 from apache/dependabot/maven/org.apache-apache-29
add 32afa895b chore: adapt setup of python dependencies (#1100)
add 5f7ec0d64 Bump commons-pool2 from 2.9.0 to 2.11.1
add 26cccbacf Merge pull request #1110 from apache/dependabot/maven/org.apache.commons-commons-pool2-2.11.1
add 36e1892b1 Bump pyupgrade from 3.2.1 to 3.3.1 in /streampipes-client-python
add 7f789ea30 Merge pull request #1109 from apache/dependabot/pip/streampipes-client-python/pyupgrade-3.3.1
add 351cb5af4 [#877] Format and lint core-services module (#1116)
add d6a7e94d9 [hotfix] Remove isDebug from `IAdapter`
add d74a8353a Merge pull request #1112 from apache/hotfix-remove-debug-from-adapter
add 2d338cfc7 [hotfix] Remove performance module
add 222f60dc8 Merge pull request #1111 from apache/hotfix-remove-performance-module
add dce34337a Reduce warnings at startup, improve structure of resource configs (#1091)
add 9e00f0d6e Bump graalvm.js.version from 21.3.0 to 22.3.1
add f582f869c Merge pull request #1118 from apache/dependabot/maven/graalvm.js.version-22.3.1
add b5abec08c [#1114] Adapters can now be added without starting them
add 88981773c [hotfix] Undo mark baseUrl method as static
add d305616ec [hotfix] Do not start set adpaters when instantiated
add 619361120 [hotfix] Fix import of AdapterDescription models
add c1ac05a14 Merge pull request #1117 from apache/SP-1114
add 4d9c7aff8 Bump jcl-over-slf4j from 1.7.30 to 2.0.6
add 289990ea3 [hotfix] Remove dependency jcl-over-slf4j from pom file
add bc9fa1dc1 Merge pull request #1123 from apache/dependabot/maven/org.slf4j-jcl-over-slf4j-2.0.6
add f01988656 [hotfix] use logo link from homepage for python docs
add 2a2d06f62 Bump mkdocstrings[python] in /streampipes-client-python (#1127)
add 7be2b887d Improve structure of pipeline execution management (#1096)
add ec5e75171 Fix checkstyle issues (#1096)
add 7d091ba95 Fix checkstyle issue (#1096)
add d19b7e042 Add comments to intefaces (#1096)
add 38074381c [hotfix] Add some comments and a log message
add db127e959 [hotfix] update disclaimer for the Python client
add cc3ef284f Merge branch 'dev' into SP-1133
No new revisions were added by this update.
Summary of changes:
.github/workflows/pr-validation.yml | 36 ++++-
pom.xml | 13 +-
streampipes-client-python/README.md | 13 +-
streampipes-client-python/mkdocs.yml | 3 +-
streampipes-client-python/setup.py | 43 +++---
.../streampipes_client/client/client.py | 1 -
.../management/AdapterMasterManagement.java | 31 +---
.../extensions/api/connect/IAdapter.java | 3 +-
.../extensions/api/connect/IAdapterPipeline.java | 4 +
.../extensions/api/connect/IProtocol.java | 3 -
streampipes-extensions-management/pom.xml | 6 +
.../management/connect/adapter/Adapter.java | 22 +--
.../connect/adapter/AdapterPipelineGenerator.java | 13 +-
.../connect/adapter/format/csv/CsvParser.java | 9 +-
.../adapter/model/generic/GenericAdapter.java | 11 +-
.../model/generic/GenericDataSetAdapter.java | 12 --
.../model/generic/GenericDataStreamAdapter.java | 15 +-
.../connect/adapter/model/generic/Protocol.java | 10 --
.../pipeline/AdapterEventPreviewPipeline.java | 6 +
.../adapter/model/pipeline/AdapterPipeline.java | 22 ++-
.../adapter/model/specific/SpecificAdapter.java | 3 -
.../model/specific/SpecificDataSetAdapter.java | 3 -
.../model/specific/SpecificDataStreamAdapter.java | 4 -
.../elements/SendToBrokerReplayAdapterSink.java | 97 ------------
.../connect/adapter/util/DatatypeUtils.java | 30 ++--
.../management/util/EventSchemaUtils.java | 61 ++++++++
.../connect/adapter/format/csv/CsvParserTest.java | 32 ++--
.../connect/adapter/util/DatatypeUtilsTest.java | 130 ++++++++++++++++
.../management/util/EventSchemaUtilsTest.java | 80 ++++++++++
.../iiot/protocol/stream/FileStreamProtocol.java | 169 ++++++++++-----------
.../streampipes-sinks-databases-jvm/pom.xml | 4 -
.../streampipes/model/api/EndpointSelectable.java | 33 ++++
.../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 +-
streampipes-performance-tests/pom.xml | 64 --------
.../streampipes/performance/PerformanceTest.java | 26 ----
.../performance/PipelinePerformanceTest.java | 57 -------
.../performance/dataprovider/DataProvider.java | 26 ----
.../performance/dataprovider/JsonDataProvider.java | 110 --------------
.../dataprovider/SimpleSchemaProvider.java | 53 -------
.../performance/dataprovider/StreamProvider.java | 26 ----
.../performance/model/PerformanceTestSettings.java | 79 ----------
.../pipeline/PipelineDescriptionFetcher.java | 21 ---
.../pipeline/PipelineDescriptionParser.java | 21 ---
.../performance/producer/DataSimulator.java | 74 ---------
.../simulation/DataReplayStatusNotifier.java | 24 ---
.../performance/simulation/SimulationManager.java | 69 ---------
.../simulation/SimulationStatusNotifier.java | 24 ---
.../tests/serializer/JsonSerializerTest.java | 71 ---------
.../performance/util/ParameterTool.java | 36 -----
.../execution/task/StorePipelineStatusTask.java | 6 +-
.../streampipes/ps/DataLakeMeasureResourceV4.java | 1 -
.../streampipes/rest/impl/PipelineResource.java | 1 -
.../rest/impl/pe/DataStreamResource.java | 1 -
.../service/base/rest/BaseResourceConfig.java | 20 ++-
.../service/core/StreamPipesResourceConfig.java | 167 ++++++++++----------
.../extensions/ExtensionsResourceConfig.java | 40 +++--
.../generator/EventPropertyNestedTestBuilder.java | 39 ++---
.../EventPropertyPrimitiveTestBuilder.java | 37 ++---
...enerator.java => EventPropertyTestBuilder.java} | 20 ++-
.../test/generator/EventSchemaGenerator.java | 22 ---
.../test/generator/EventSchemaTestBuilder.java | 35 ++---
ui/.eslintignore | 2 -
ui/.prettierignore | 2 -
ui/cypress/support/utils/connect/ConnectBtns.ts | 14 +-
ui/cypress/support/utils/connect/ConnectUtils.ts | 55 +++++--
...pec.ts => createAdapterWithoutStarting.spec.ts} | 13 +-
ui/cypress/tests/adapter/editAdapter.smoke.spec.ts | 18 +--
.../src/lib/apis/adapter.service.ts | 6 +-
.../event-schema-preview.component.html | 1 +
.../adapter-options-panel.component.html | 1 +
.../adapter-options-panel.component.ts | 5 +-
.../start-adapter-configuration.component.html | 12 +-
.../start-adapter-configuration.component.ts | 3 +
.../adapter-started-dialog.component.html | 3 +-
.../adapter-started-dialog.component.ts | 134 ++++++++++------
ui/src/app/core-model/base/UserErrorMessage.ts | 16 +-
ui/src/app/core-model/coco/Annotation.ts | 40 +++--
ui/src/app/core-model/coco/Category.ts | 26 ++--
ui/src/app/core-model/coco/Coco.format.ts | 28 ++--
ui/src/app/core-model/coco/Image.ts | 16 +-
.../semantic-type/semantic-type-utils.service.ts | 8 +-
.../template/PipelineInvocationBuilder.ts | 86 ++++++-----
89 files changed, 1040 insertions(+), 1594 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
copy streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/selector/TestSelectorGenerator.java => streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/format/csv/CsvParserTest.java (60%)
create mode 100644 streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/util/DatatypeUtilsTest.java
create mode 100644 streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/util/EventSchemaUtilsTest.java
delete mode 100644 streampipes-performance-tests/pom.xml
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/PerformanceTest.java
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/PipelinePerformanceTest.java
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/dataprovider/DataProvider.java
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/dataprovider/JsonDataProvider.java
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/dataprovider/SimpleSchemaProvider.java
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/dataprovider/StreamProvider.java
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/model/PerformanceTestSettings.java
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/pipeline/PipelineDescriptionFetcher.java
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/pipeline/PipelineDescriptionParser.java
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/producer/DataSimulator.java
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/simulation/DataReplayStatusNotifier.java
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/simulation/SimulationManager.java
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/simulation/SimulationStatusNotifier.java
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/tests/serializer/JsonSerializerTest.java
delete mode 100644 streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/util/ParameterTool.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%)
copy ui/cypress/tests/adapter/{machineDataSimulator.smoke.spec.ts => createAdapterWithoutStarting.spec.ts} (81%)