This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch
2252-enhance-data-lake-sink-schema-management-options
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 3555de3b0 refactor(#2246): Fix checkstyle
add fdb62d87b refactor(#2246): Add migration script for data lake sink
No new revisions were added by this update.
Summary of changes:
.../streampipes-sinks-internal-jvm/pom.xml | 11 ++++
.../sinks/internal/jvm/datalake/DataLakeSink.java | 5 +-
.../jvm/migration/DataLakeSinkMigrationV1.java | 74 ++++++++++++++++++++++
.../jvm/migration/DataLakeSinkMigrationV1Test.java | 62 ++++++++++++++++++
4 files changed, 149 insertions(+), 3 deletions(-)
create mode 100644
streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/migration/DataLakeSinkMigrationV1.java
create mode 100644
streampipes-extensions/streampipes-sinks-internal-jvm/src/test/java/org/apache/streampipes/sinks/internal/jvm/migration/DataLakeSinkMigrationV1Test.java