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/03/29 07:49:34 UTC
[streampipes] branch 1406-cleanup-data-explorer-query-management updated (e157f317e -> 515d17a1c)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch 1406-cleanup-data-explorer-query-management
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from e157f317e Merge missing test (#1406)
add 25bf66f6a #1261 Modified release.yml file to include Python changes to release notes (#1404)
add 7fe524e47 Add support for the Kafka broker in Python (#1363)
add 5b6529efc docs: add matomo tracking to python docs (#1409)
add 1e5fb25b5 [hotfix] refine changelog structure
add 60d3f8153 [hotfix] always set alias for python docs
add bd3e014ab [hotfix] overwrite alias for python docs
add 73819a0cf [hotfix] provide latest as default in python docs
add 420336fb0 miscellaneous improvements for Python docs (#1410)
add 1521545f5 Search For Python DOC (#1408)
add 74a816d23 Bump mkdocs-jupyter from 0.22.0 to 0.23.0 in /streampipes-client-python (#1413)
add ee51abb2e [doc](readme)Enhancement in some Hyperlinks. (#1415)
add 3ee724c9d Bump mkdocs-material from 9.0.8 to 9.1.3 in /streampipes-client-python (#1416)
add 157417eee Bump webpack from 5.75.0 to 5.76.0 in /ui (#1418)
add 622261a44 Bump cypress from 12.6.0 to 12.8.1 in /ui (#1420)
add ad8c8de2f Bump @typescript-eslint/eslint-plugin from 5.53.0 to 5.55.0 in /ui (#1421)
add 25f40ce89 Bump mkdocs-jupyter from 0.23.0 to 0.24.0 in /streampipes-client-python (#1429)
add ed5b074e0 Bump pre-commit from 3.1.0 to 3.2.0 in /streampipes-client-python (#1431)
add 67727505f Bump lint-staged from 13.1.0 to 13.2.0 in /ui (#1430)
add 09327f56b docs: spring cleaning for Python docs (#1419)
add f9c0c67da Maintain the same directory structure for source and test (#1428)
add c7c1a301b Migrate StringCounter processing elements (#1427)
add d8583b155 1423 update archetypes (#1425)
add 7a0650810 Bump @angular-eslint/builder from 15.1.0 to 15.2.1 in /ui (#1432)
add a42fe29c7 update archetypes template (#1433)
add 94716b87e Bump eslint-config-prettier from 8.6.0 to 8.8.0 in /ui (#1437)
add cd38a4bde fix repeated past data (#1440)
add 586666ca4 Bump eslint from 8.35.0 to 8.36.0 in /ui
add d9dea34bc Bump json-smart from 2.4.8 to 2.4.9
add 7cc4e0209 Improve Log info in Processor Test (#1445)
add 83b50d6b0 Migrate StringToState processing elements (#1444)
add a99f0cd44 Migrate StringTimer processing elements (#1453)
add 435171490 Python docs with dark mode (#1454)
add ce1d95f6e [#1113] Added buttons to start and stop all adapters (#1441)
add de73be881 [hotfix] Add test for DataLakeQueryBuilder (#1459)
add 5000139e0 Bump error_prone_annotations from 2.2.0 to 2.18.0 (#1403)
add 3ca5f9b21 Bump @typescript-eslint/parser from 5.54.0 to 5.56.0 in /ui
add 792f2d108 Bump eslint from 8.36.0 to 8.37.0 in /ui
add c8fd621db Bump kafka.version from 3.3.1 to 3.4.0
add 45b27818e Bump black from 23.1.0 to 23.3.0 in /streampipes-client-python
add 004422938 Bump boofcv-core from 0.33 to 0.42
add 515d17a1c Merge branch 'dev' into 1406-cleanup-data-explorer-query-management
No new revisions were added by this update.
Summary of changes:
.github/release.yml | 20 +-
.github/workflows/python-docs.yml | 4 +-
README.md | 4 +-
.../src/main/resources/archetype-resources/pom.xml | 12 +-
.../archetype-resources/src/main/java/Init.java | 36 +-
.../__classNamePrefix__DataProcessor.java | 39 +-
.../__classNamePrefix__DataSink.java | 25 +-
.../src/main/resources/archetype-resources/pom.xml | 61 +--
.../archetype-resources/src/main/java/Init.java | 10 +-
.../__classNamePrefix__Controller.java | 2 +-
.../__classNamePrefix__Program.java | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 56 +-
.../archetype-resources/src/main/java/Init.java | 52 +-
.../src/main/java/config/Config.java | 76 ---
.../src/main/java/config/ConfigKeys.java | 15 +-
.../__classNamePrefix__Controller.java | 11 +-
.../__classNamePrefix__Program.java | 23 +-
pom.xml | 12 +-
streampipes-client-python/.pre-commit-config.yaml | 2 +-
streampipes-client-python/README.md | 14 +-
.../docs/getting-started/developing.md | 18 +-
.../docs/getting-started/first-steps.md | 28 +-
.../docs/getting-started/quickstart.md | 59 +-
.../docs/img/streampipes-python-dark.png | Bin 0 -> 116009 bytes
streampipes-client-python/docs/index.md | 26 +-
.../analytics/matomo.html} | 47 +-
...introduction-to-streampipes-python-client.ipynb | 34 +-
...cting-data-from-the-streampipes-data-lake.ipynb | 17 +-
...ive-data-from-the-streampipes-data-stream.ipynb | 27 +-
...ine-learning-on-a-streampipes-data-stream.ipynb | 6 +-
streampipes-client-python/mkdocs.yml | 46 +-
streampipes-client-python/setup.py | 20 +-
.../streampipes/client/client.py | 90 ++-
.../streampipes/client/config.py | 10 +-
.../streampipes/client/credential_provider.py | 17 +-
.../streampipes/endpoint/api/data_lake_measure.py | 102 ++--
.../streampipes/endpoint/api/data_stream.py | 45 +-
.../streampipes/endpoint/endpoint.py | 48 +-
.../streampipes/function_zoo/river_function.py | 43 +-
.../streampipes/functions/broker/__init__.py | 2 +
.../streampipes/functions/broker/broker.py | 21 +-
.../streampipes/functions/broker/broker_handler.py | 23 +-
.../broker/{nats_broker.py => kafka_broker.py} | 34 +-
.../functions/broker/kafka_message_fetcher.py | 43 +-
.../streampipes/functions/broker/nats_broker.py | 10 +-
.../functions/broker/output_collector.py | 28 +-
.../streampipes/functions/function_handler.py | 16 +-
.../streampipes/functions/registration.py | 17 +-
.../streampipes/functions/streampipes_function.py | 19 +-
.../functions/utils/async_iter_handler.py | 23 +-
.../functions/utils/data_stream_context.py | 4 +-
.../functions/utils/data_stream_generator.py | 17 +-
.../functions/utils/function_context.py | 9 +-
.../streampipes/model/common.py | 27 +-
.../model/container/data_lake_measures.py | 9 +-
.../streampipes/model/container/data_streams.py | 9 +-
.../model/container/resource_container.py | 17 +-
.../model/resource/data_lake_measure.py | 14 +-
.../streampipes/model/resource/data_lake_series.py | 10 +-
.../streampipes/model/resource/data_stream.py | 7 +-
.../model/resource/function_definition.py | 79 ++-
.../streampipes/model/resource/resource.py | 11 +-
.../streampipes-connect-adapters-iiot/pom.xml | 4 -
.../streampipes-connect-adapters/pom.xml | 4 -
.../transformation/jvm/TransformationJvmInit.java | 12 +-
.../stringoperator/counter/StringCounter.java | 79 ---
.../counter/StringCounterParameters.java | 36 --
...Controller.java => StringCounterProcessor.java} | 201 ++++---
.../stringoperator/state/StringToState.java | 59 --
.../state/StringToStateParameters.java | 42 --
...Controller.java => StringToStateProcessor.java} | 172 +++---
.../stringoperator/timer/StringTimer.java | 79 ---
.../timer/StringTimerParameters.java | 48 --
...erController.java => StringTimerProcessor.java} | 252 +++++----
.../counter/TestBooleanCounterProcessor.java | 4 +-
.../inverter/TestBooleanInverterProcessor.java | 4 +-
.../counter/TestStringCounterProcessor.java | 182 ++++++
.../state/TestStringToStateProcessor.java | 207 +++++++
.../timer/TestStringTimerProcessor.java | 213 ++++++++
streampipes-service-base/pom.xml | 4 +
ui/cypress/support/utils/connect/ConnectBtns.ts | 8 +
ui/cypress/support/utils/connect/ConnectUtils.ts | 9 +
...oke.spec.ts => allAdapterActions.smoke.spec.ts} | 40 +-
ui/package-lock.json | 608 +++++++++++----------
ui/package.json | 16 +-
.../existing-adapters.component.html | 28 +-
.../existing-adapters.component.ts | 34 ++
ui/src/app/connect/connect.module.ts | 2 +
.../all-adapter-actions-dialog.component.html} | 27 +-
.../all-adapter-actions-dialog.component.scss} | 0
.../all-adapter-actions-dialog.component.ts | 120 ++++
.../dashboard/components/widgets/raw/raw-config.ts | 1 -
92 files changed, 2430 insertions(+), 1673 deletions(-)
delete mode 100644 archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/config/Config.java
create mode 100644 streampipes-client-python/docs/img/streampipes-python-dark.png
copy streampipes-client-python/docs/overrides/partials/{footer.html => integrations/analytics/matomo.html} (50%)
rename streampipes-client-python/docs/{examples => tutorials}/1-introduction-to-streampipes-python-client.ipynb (90%)
rename streampipes-client-python/docs/{examples => tutorials}/2-extracting-data-from-the-streampipes-data-lake.ipynb (99%)
rename streampipes-client-python/docs/{examples => tutorials}/3-getting-live-data-from-the-streampipes-data-stream.ipynb (98%)
rename streampipes-client-python/docs/{examples => tutorials}/4-using-online-machine-learning-on-a-streampipes-data-stream.ipynb (94%)
copy streampipes-client-python/streampipes/functions/broker/{nats_broker.py => kafka_broker.py} (70%)
copy streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.ti/strings.en => streampipes-client-python/streampipes/functions/broker/kafka_message_fetcher.py (54%)
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/StringCounter.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/StringCounterParameters.java
rename streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/{StringCounterController.java => StringCounterProcessor.java} (57%)
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/StringToState.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/StringToStateParameters.java
rename streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/{StringToStateController.java => StringToStateProcessor.java} (61%)
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/StringTimer.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/StringTimerParameters.java
rename streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/{StringTimerController.java => StringTimerProcessor.java} (55%)
rename streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/{processors => processor}/booloperator/inverter/TestBooleanInverterProcessor.java (97%)
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/TestStringCounterProcessor.java
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/TestStringToStateProcessor.java
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/TestStringTimerProcessor.java
copy ui/cypress/tests/adapter/{editAdapterWithPipeline.smoke.spec.ts => allAdapterActions.smoke.spec.ts} (50%)
copy ui/src/app/{pipelines/dialog/start-all-pipelines/start-all-pipelines-dialog.component.html => connect/dialog/start-all-adapters/all-adapter-actions-dialog.component.html} (74%)
copy ui/src/app/{add/dialogs/add-endpoint/add-endpoint.component.scss => connect/dialog/start-all-adapters/all-adapter-actions-dialog.component.scss} (100%)
create mode 100644 ui/src/app/connect/dialog/start-all-adapters/all-adapter-actions-dialog.component.ts