This is an automated email from the ASF dual-hosted git repository. bossenti pushed a commit to branch abstract-data-explorer-from-influx in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 13fd96bc117190be19455b53d7179eaaf6862098 Author: bossenti <[email protected]> AuthorDate: Tue Apr 30 11:32:53 2024 +0200 refactor: small improvements --- .../main/java/org/apache/streampipes/dataexplorer/ImageStore.java | 6 ++---- .../java/org/apache/streampipes/dataexplorer/TimeSeriesStore.java | 1 - .../streampipes/sinks/internal/jvm/datalake/DataLakeSink.java | 4 ++-- 3 files changed, 4 insertions(+), 7 deletions(-) diff --git a/streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/ImageStore.java b/streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/ImageStore.java index dbd3bbd860..0b961b6b50 100644 --- a/streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/ImageStore.java +++ b/streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/ImageStore.java @@ -27,8 +27,6 @@ import org.apache.streampipes.model.schema.EventProperty; import org.apache.commons.codec.binary.Base64; import org.lightcouch.CouchDbClient; import org.lightcouch.CouchDbProperties; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; import java.io.ByteArrayInputStream; import java.io.IOException; @@ -38,8 +36,8 @@ import java.util.UUID; public class ImageStore { private static final String DB_NAME = "images"; - private List<EventProperty> imageProperties; - private CouchDbClient couchDbClient; + private final List<EventProperty> imageProperties; + private final CouchDbClient couchDbClient; public ImageStore(DataLakeMeasure measure, Environment environment) { diff --git a/streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/TimeSeriesStore.java b/streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/TimeSeriesStore.java index 78887b52d2..1a64c21b1d 100644 --- a/streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/TimeSeriesStore.java +++ b/streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/TimeSeriesStore.java @@ -18,7 +18,6 @@ package org.apache.streampipes.dataexplorer; -import org.apache.streampipes.client.api.IStreamPipesClient; import org.apache.streampipes.commons.environment.Environment; import org.apache.streampipes.commons.exceptions.SpRuntimeException; import org.apache.streampipes.dataexplorer.api.ITimeSeriesStorage; diff --git a/streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLakeSink.java b/streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLakeSink.java index 4a2930b7d5..3d801d35e8 100644 --- a/streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLakeSink.java +++ b/streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLakeSink.java @@ -26,6 +26,7 @@ import org.apache.streampipes.extensions.api.pe.context.EventSinkRuntimeContext; import org.apache.streampipes.model.DataSinkType; import org.apache.streampipes.model.datalake.DataLakeMeasure; import org.apache.streampipes.model.datalake.DataLakeMeasureSchemaUpdateStrategy; +import org.apache.streampipes.model.extensions.ExtensionAssetType; import org.apache.streampipes.model.graph.DataSinkDescription; import org.apache.streampipes.model.runtime.Event; import org.apache.streampipes.model.schema.PropertyScope; @@ -35,7 +36,6 @@ import org.apache.streampipes.sdk.helpers.EpRequirements; import org.apache.streampipes.sdk.helpers.Labels; import org.apache.streampipes.sdk.helpers.Locales; import org.apache.streampipes.sdk.helpers.Options; -import org.apache.streampipes.sdk.utils.Assets; import org.apache.streampipes.wrapper.params.compat.SinkParams; import org.apache.streampipes.wrapper.standalone.StreamPipesDataSink; @@ -57,7 +57,7 @@ public class DataLakeSink extends StreamPipesDataSink { return DataSinkBuilder .create("org.apache.streampipes.sinks.internal.jvm.datalake", 1) .withLocales(Locales.EN) - .withAssets(Assets.DOCUMENTATION, Assets.ICON) + .withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON) .category(DataSinkType.INTERNAL) .requiredStream(StreamRequirementsBuilder .create()
