You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by bo...@apache.org on 2022/11/25 14:07:17 UTC
[streampipes] branch STREAMPIPES-584 updated (f79d4b1a6 -> f3230e002)
This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a change to branch STREAMPIPES-584
in repository https://gitbox.apache.org/repos/asf/streampipes.git
discard f79d4b1a6 remove comments on fallback options
discard 6a6de96d0 change to correct volume path for external scripts
discard 1ee270b39 use correct sql comments
discard d5a52bbe9 moving script files to source_external position
discard 2927dc8ca retry not working log functionality
discard f1ae80143 remove old approach classes
discard ec0e9b23d replace processor in init file
discard 0676afc6d fixed unresolved issue due mapping variable
discard b312bfe3f Merge remote-tracking branch 'origin/STREAMPIPES-584' into STREAMPIPES-584
discard 1312c9a3c 1 Class Processor but with unresolved issue
discard 6b4cd6340 [STREAMPIPES-590] add missing license headers
discard 0895e11de move setDatabase functionality to Jvminit and change to service name
discard e33efade7 add docker-compose files. DISCUSSION required where to put the script files
discard e66d357cd [STREAMPIPES-584] fix typo
discard 5a22bd4a0 [STREAMPIPES-590] add licence header to `strings.en` resource files
discard db2c1eb89 run style check and add missing license
discard bde9b4a9c implement checks against the DB if valid and correct version is used
discard bf4226db4 handel invalid epsg code due input field
discard 09fc4a777 misc style style check fixes and code format
discard ab6b72856 fix license
discard 364faf403 stylecheck misc. and optimized import
discard 46bf87178 change image with other icons
discard b829dadb7 implement basic processor
discard 5d64135a3 add postgres deps
discard 0a447d5bb add new base processor reprojection with sources but without db connection
discard 1365f45a3 add new Builder for Reprojection
discard 1c5d6b7a7 add exception class for if geometry type is not supported (multigeom atm)
discard 6d0d840cd add new methods for projections in builder
discard 2c75f44df missing code format action
discard 4bb117a49 change method modifier
discard 4329e89cb add apache sis dependencies
discard c615cc0e1 update maven jts version to 1.19
add d511c435c Provide RocketMQ 5.0.0 Dockerfile and docker-compose.yml files
add a7e377fae [STREAMPIPES-589] Explicitly name MIT-licsensed files in LICENSE
add d15065ad9 [STREAMPIPES-588] Use range in NOTICE file
add 655cdc7a2 Merge branch 'dev' of github.com:apache/streampipes into dev
add fbbe78677 Streampipes 634 - ADD MkDocs Documentation (#143)
add 896994031 [STREAMPIPES-591] Prevent tests from failing with Java 17+
add d0300e2e5 [STREAMPIPES-590] add licence header to resource files
add e3c1c660c [STREAMPIPES-566] Fix query download, improve code structure
add 3ae6e5375 [STREAMPIPES-566] Delete unused classes
add e7123dbdc [STREAMPIPES-566] Add license header
add 4aeef8b3a [STREAMPIPES-566] Do not use wildcard imports
add 50af75b11 [STREAMPIPES-566] Add basic tests
add c6ad8b85a [STREAMPIPES-566] Use time field index over fixed assignment
add d9ae947a3 [hotfix] Add tsconfig to fix ui build in github actions
add f134cf1f7 Bump postgresql from 42.4.1 to 42.4.3
add f21ccb263 Merge pull request #153 from apache/dependabot/maven/org.postgresql-postgresql-42.4.3
add b69929063 Merge branch 'dev' of github.com:apache/streampipes into dev
add 66e8d970f [STREAMPIPES-648] Add license header check to checkstyle.xml
add cd4243bfa hotfix: update docs to remove incubator status
add af8785b04 [STREAMPIPES-649] Update REST API for data streams
add 1f382da63 update maven jts version to 1.19
add 793480a5a add apache sis dependencies
add 235615635 change method modifier
add 1a4da3aff missing code format action
add de14f5282 add new methods for projections in builder
add 8d58f7cf6 add exception class for if geometry type is not supported (multigeom atm)
add 28f1af1eb add new Builder for Reprojection
add 6fcb72966 add new base processor reprojection with sources but without db connection
add be4e51e9b add postgres deps
add baf00e4e5 implement basic processor
add 72e15c19e change image with other icons
add 3cb0c6bbb stylecheck misc. and optimized import
add e70b03199 fix license
add 6aebd9eda misc style style check fixes and code format
add 183f3f122 handel invalid epsg code due input field
add a6dc6157b implement checks against the DB if valid and correct version is used
add b5228389b run style check and add missing license
add e64191ede [STREAMPIPES-590] add licence header to `strings.en` resource files
add 082c9a4e9 [STREAMPIPES-584] fix typo
add ab89ce00d add docker-compose files. DISCUSSION required where to put the script files
add 826270a62 move setDatabase functionality to Jvminit and change to service name
add d45624fc1 1 Class Processor but with unresolved issue
add 2c324fbc4 [STREAMPIPES-590] add missing license headers
add 9e329207a fixed unresolved issue due mapping variable
add 4abddd673 replace processor in init file
add a41a63b55 remove old approach classes
add 9c679fc44 retry not working log functionality
add bd8751566 moving script files to source_external position
add ea16f497d use correct sql comments
add 159637887 change to correct volume path for external scripts
add f3230e002 remove comments on fallback options
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (f79d4b1a6)
\
N -- N -- N refs/heads/STREAMPIPES-584 (f3230e002)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
LICENSE | 10 +-
NOTICE | 2 +-
README.md | 20 +--
.../strings.en | 17 ++
.../__package__.pe.__packageName__.sink/strings.en | 17 ++
installer/README.md | 6 +-
installer/cli/README.md | 4 +-
.../cli/deploy/standalone/rocketmq/Dockerfile | 76 ++++++++
.../standalone/rocketmq/docker-compose.dev.yml | 19 +-
.../deploy/standalone/rocketmq/docker-compose.yml | 75 ++++++--
pom.xml | 16 +-
streampipes-client-python/README.md | 6 +-
.../docs/getting-started/installation.md | 17 +-
.../getting-started/quickstart.md} | 38 +---
.../{README.md => docs/index.md} | 4 +-
streampipes-client-python/docs/overrides/main.html | 47 +++++
.../docs/overrides/partials/footer.html | 44 +++--
.../docs/scripts/gen_ref_pages.py | 50 ++++++
.../docs/stylesheets/extra.css | 21 +++
streampipes-client-python/mkdocs.yml | 81 +++++++++
streampipes-client-python/setup.py | 6 +-
streampipes-data-explorer/pom.xml | 6 +
.../dataexplorer/DataLakeManagementV4.java | 199 +--------------------
.../autoagg/AbstractAutoAggregationQuery.java | 70 --------
.../autoagg/FromNowAutoAggregationQuery.java | 49 -----
.../autoagg/GroupedAutoAggregationQuery.java | 48 -----
.../autoagg/TimeBoundAutoAggregationQuery.java | 49 -----
.../param/AggregatedTimeBoundQueryParams.java | 50 ------
.../param/AggregatedTimeUnitQueryParams.java | 51 ------
.../dataexplorer/param/CountQueryParams.java | 21 ---
.../GroupedAggregatedTimeBoundQueryParams.java | 46 -----
.../dataexplorer/param/GroupedQueryParams.java | 42 -----
.../dataexplorer/param/PagingQueryParams.java | 95 ----------
.../dataexplorer/param/TimeBoundQueryParams.java | 44 -----
.../dataexplorer/param/TimeUnitQueryParams.java | 42 -----
.../query/GetAggregatedEventsFromNowQuery.java | 47 -----
.../query/GetAggregatedEventsQuery.java | 45 -----
.../query/GetDateFromSortedTableRecord.java | 69 -------
.../query/GetEventsAutoAggregationQuery.java | 21 ---
.../dataexplorer/query/GetEventsFromNowQuery.java | 44 -----
.../dataexplorer/query/GetEventsQuery.java | 42 -----
.../query/GetGroupedAggregatedEventsQuery.java | 44 -----
.../dataexplorer/query/GetGroupedEventsQuery.java | 42 -----
.../query/GetHeadersWithTypesQuery.java | 46 -----
.../dataexplorer/query/GetMaxPagesQuery.java | 41 -----
.../query/GetNumberOfRecordsByTimeUnitQuery.java | 52 ------
.../query/GetNumberOfRecordsQuery.java | 51 ------
.../dataexplorer/query/GetPagingEventsQuery.java | 72 --------
.../dataexplorer/v4/query/QueryResultProvider.java | 64 +++++++
.../v4/query/StreamedQueryResultProvider.java | 118 ++++++++++++
.../v4/query/writer/ConfiguredCsvOutputWriter.java | 76 ++++++++
.../query/writer/ConfiguredJsonOutputWriter.java | 70 ++++++++
.../v4/query/writer/ConfiguredOutputWriter.java | 53 ++++++
.../dataexplorer/v4/query/writer/OutputFormat.java | 17 +-
.../v4/query/writer/item/CsvItemWriter.java | 23 +--
.../v4/query/writer/item/ItemGenerator.java | 57 ++++++
.../v4/query/writer/item/JsonItemWriter.java | 37 ++--
.../dataexplorer/v4/utils/TimeParser.java | 48 +++++
.../writer/TestConfiguredCsvOutputWriter.java | 52 ++++++
.../writer/TestConfiguredJsonOutputWriter.java | 53 ++++++
.../query/writer/TestConfiguredOutputWriter.java | 28 ++-
.../v4/query/writer/item/TestCsvItemWriter.java | 31 ++--
.../v4/query/writer/item/TestItemWriter.java | 28 ++-
.../v4/query/writer/item/TestJsonItemWriter.java | 24 +--
streampipes-extensions/README.md | 14 +-
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 17 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 17 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 17 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 17 ++
.../strings.en | 18 ++
.../strings.en | 18 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 19 +-
.../strings.en | 17 ++
.../strings.en | 18 +-
.../strings.en | 18 ++
.../strings.en | 18 +-
.../strings.en | 18 +-
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 19 +-
.../strings.en | 19 +-
.../strings.en | 18 +-
.../strings.en | 19 +-
.../strings.en | 19 +-
.../strings.en | 17 ++
.../strings.en | 18 +-
.../strings.en | 17 ++
.../strings.en | 19 +-
.../strings.en | 17 ++
.../strings.en | 19 +-
.../strings.en | 18 +-
.../strings.en | 19 +-
.../strings.en | 17 ++
.../strings.en | 19 +-
.../strings.en | 19 +-
.../strings.en | 17 ++
.../strings.en | 19 +-
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 18 +-
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 19 +-
.../strings.en | 19 +-
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../strings.en | 17 ++
.../apache/streampipes/ps/DataLakeResourceV4.java | 3 +-
.../rest/impl/pe/DataStreamResource.java | 108 ++++++-----
streampipes-wrapper-python/README.md | 6 +-
.../maven/checkstyle-header.txt | 3 +-
tools/maven/checkstyle.xml | 5 +
.../services/data-export.service.ts | 2 +-
ui/src/app/info/about/about.component.html | 4 +-
ui/tsconfig.json | 1 +
235 files changed, 4117 insertions(+), 1678 deletions(-)
create mode 100644 installer/cli/deploy/standalone/rocketmq/Dockerfile
copy CONTRIBUTING.md => streampipes-client-python/docs/getting-started/installation.md (76%)
copy streampipes-client-python/{README.md => docs/getting-started/quickstart.md} (60%)
copy streampipes-client-python/{README.md => docs/index.md} (95%)
create mode 100644 streampipes-client-python/docs/overrides/main.html
copy ui/projects/streampipes/shared-ui/src/lib/components/sp-exception-message/sp-exception-message.component.html => streampipes-client-python/docs/overrides/partials/footer.html (52%)
create mode 100644 streampipes-client-python/docs/scripts/gen_ref_pages.py
create mode 100644 streampipes-client-python/docs/stylesheets/extra.css
create mode 100644 streampipes-client-python/mkdocs.yml
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/autoagg/AbstractAutoAggregationQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/autoagg/FromNowAutoAggregationQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/autoagg/GroupedAutoAggregationQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/autoagg/TimeBoundAutoAggregationQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/AggregatedTimeBoundQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/AggregatedTimeUnitQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/CountQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/GroupedAggregatedTimeBoundQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/GroupedQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/PagingQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/TimeBoundQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/TimeUnitQueryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetAggregatedEventsFromNowQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetAggregatedEventsQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetDateFromSortedTableRecord.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetEventsAutoAggregationQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetEventsFromNowQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetEventsQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetGroupedAggregatedEventsQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetGroupedEventsQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetHeadersWithTypesQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetMaxPagesQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetNumberOfRecordsByTimeUnitQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetNumberOfRecordsQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetPagingEventsQuery.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/QueryResultProvider.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/StreamedQueryResultProvider.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/writer/ConfiguredCsvOutputWriter.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/writer/ConfiguredJsonOutputWriter.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/writer/ConfiguredOutputWriter.java
copy streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/connect/AbstractAdapterResource.java => streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/writer/OutputFormat.java (66%)
copy streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/PulsarDevContainer.java => streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/writer/item/CsvItemWriter.java (69%)
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/writer/item/ItemGenerator.java
copy streampipes-extensions/streampipes-processors-transformation-flink/src/test/java/org/apache/streampipes/processors/transformation/flink/utils/DummyCollector.java => streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/writer/item/JsonItemWriter.java (55%)
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/utils/TimeParser.java
create mode 100644 streampipes-data-explorer/src/test/java/org/apache/streampipesdataexplorer/v4/query/writer/TestConfiguredCsvOutputWriter.java
create mode 100644 streampipes-data-explorer/src/test/java/org/apache/streampipesdataexplorer/v4/query/writer/TestConfiguredJsonOutputWriter.java
copy ui/src/app/connect/components/adapter-details/adapter-details-tabs.ts => streampipes-data-explorer/src/test/java/org/apache/streampipesdataexplorer/v4/query/writer/TestConfiguredOutputWriter.java (65%)
copy streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/selector/TestSelectorGenerator.java => streampipes-data-explorer/src/test/java/org/apache/streampipesdataexplorer/v4/query/writer/item/TestCsvItemWriter.java (55%)
copy streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/Filetypes.java => streampipes-data-explorer/src/test/java/org/apache/streampipesdataexplorer/v4/query/writer/item/TestItemWriter.java (68%)
copy streampipes-extensions/streampipes-processors-transformation-flink/src/test/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/TestFieldHasherController.java => streampipes-data-explorer/src/test/java/org/apache/streampipesdataexplorer/v4/query/writer/item/TestJsonItemWriter.java (60%)
copy ui/src/app/connect/dialog/edit-event-property/components/edit-value-transformation/edit-correction-value/edit-correction-value.component.scss => tools/maven/checkstyle-header.txt (93%)