You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2022/08/02 09:12:21 UTC
[incubator-streampipes] 01/01: Merge pull request #101 from apache/STREAMPIPES-563
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 80498b7235546e18209fc154e92ab55b73d51299
Merge: f08ed0cd9 83e35f9a7
Author: Philipp Zehnder <te...@users.noreply.github.com>
AuthorDate: Tue Aug 2 11:12:15 2022 +0200
Merge pull request #101 from apache/STREAMPIPES-563
Streampipes 563 Refactor Data Lake Sink
.../backend/StreamPipesResourceConfig.java | 8 +-
streampipes-data-explorer-commons/pom.xml | 9 +-
.../dataexplorer/commons/DataExplorerUtils.java | 55 ++++--
.../dataexplorer/commons/DataExplorerWriter.java | 7 +-
.../dataexplorer/commons/TimeSeriesStore.java | 86 +++++++++
.../CouchDbConfigurations.java} | 25 ++-
.../commons/configs/CouchDbEnvKeys.java | 5 +-
.../{ => configs}/DataExplorerConfigurations.java | 16 +-
.../commons/{ => configs}/DataExplorerEnvKeys.java | 2 +-
.../dataexplorer/commons/image/ImageStore.java | 85 +++++++++
.../commons/image/ImageStoreUtils.java | 31 ++--
.../InfluxConnectionSettings.java} | 32 ++--
.../commons/influx}/InfluxDbReservedKeywords.java | 2 +-
.../commons/influx/InfluxNameSanitizer.java | 31 ++--
.../dataexplorer/commons/influx/InfluxStore.java | 83 ++++-----
.../dataexplorer/DataLakeManagementV4.java | 69 ++++++-
.../dataexplorer/DataLakeNoUserManagementV3.java | 7 +-
.../streampipes-sinks-internal-jvm/pom.xml | 3 +
.../sinks/internal/jvm/SinksInternalJvmInit.java | 12 +-
.../sinks/internal/jvm/datalake/DataLake.java | 133 --------------
.../internal/jvm/datalake/DataLakeController.java | 75 --------
.../internal/jvm/datalake/DataLakeParameters.java | 62 -------
.../sinks/internal/jvm/datalake/DataLakeSink.java | 92 ++++++++++
.../sinks/internal/jvm/datalake/ImageStore.java | 54 ------
.../model/datalake/DataLakeMeasure.java | 28 +++
.../streampipes/ps}/DataLakeMeasureResourceV3.java | 3 +-
.../streampipes/ps/DataLakeMeasureResourceV4.java | 26 ++-
.../apache/streampipes/ps/DataLakeResourceV3.java | 199 +--------------------
.../apache/streampipes/ps/DataLakeResourceV4.java | 21 ---
ui/cypress/support/utils/PipelineUtils.ts | 2 +-
30 files changed, 546 insertions(+), 717 deletions(-)