This is an automated email from the ASF dual-hosted git repository. zehnder pushed a commit to branch 2252-enhance-data-lake-sink-schema-management-options in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 7009dde09a6103e72176828ce60f6853b5d9df59 Author: Philipp Zehnder <[email protected]> AuthorDate: Mon Dec 4 16:49:19 2023 +0100 refactor(#2246): Register migration --- .../sinks/internal/jvm/InternalSinksExtensionModuleExports.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/InternalSinksExtensionModuleExports.java b/streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/InternalSinksExtensionModuleExports.java index ccf27a5da..a32aaa7cf 100644 --- a/streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/InternalSinksExtensionModuleExports.java +++ b/streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/InternalSinksExtensionModuleExports.java @@ -23,6 +23,7 @@ import org.apache.streampipes.extensions.api.declarer.IExtensionModuleExport; import org.apache.streampipes.extensions.api.migration.IModelMigrator; import org.apache.streampipes.extensions.api.pe.IStreamPipesPipelineElement; import org.apache.streampipes.sinks.internal.jvm.datalake.DataLakeSink; +import org.apache.streampipes.sinks.internal.jvm.migration.DataLakeSinkMigrationV1; import org.apache.streampipes.sinks.internal.jvm.notification.NotificationProducer; import java.util.Collections; @@ -44,6 +45,6 @@ public class InternalSinksExtensionModuleExports implements IExtensionModuleExpo @Override public List<IModelMigrator<?, ?>> migrators() { - return Collections.emptyList(); + return List.of(new DataLakeSinkMigrationV1()); } }
