This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from 5e3f196e2 [Improve] [Connector-V2] Fix Kafka sink can't run
EXACTLY_ONCE semantics (#3724)
add 8ef080f20 [Connector][Sink]Support load data to S3 then Copy to
Redshift (#3736)
No new revisions were added by this update.
Summary of changes:
plugin-mapping.properties | 1 +
.../pom.xml | 25 +++--
.../seatunnel/redshift/RedshiftJdbcClient.java | 88 ++++++++++++++++
.../commit/S3RedshiftSinkAggregatedCommitter.java | 112 +++++++++++++++++++++
.../redshift/config/S3RedshiftConfig.java} | 23 ++---
.../S3RedshiftJdbcConnectorException.java} | 11 +-
.../redshift/sink/S3RedshiftFactory.java} | 38 +++----
.../seatunnel/redshift/sink/S3RedshiftSink.java} | 62 ++++--------
seatunnel-connectors-v2/pom.xml | 1 +
9 files changed, 270 insertions(+), 91 deletions(-)
copy seatunnel-connectors-v2/{connector-redis =>
connector-s3-redshift}/pom.xml (73%)
create mode 100644
seatunnel-connectors-v2/connector-s3-redshift/src/main/java/org/apache/seatunnel/connectors/seatunnel/redshift/RedshiftJdbcClient.java
create mode 100644
seatunnel-connectors-v2/connector-s3-redshift/src/main/java/org/apache/seatunnel/connectors/seatunnel/redshift/commit/S3RedshiftSinkAggregatedCommitter.java
copy
seatunnel-connectors-v2/{connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertConfig.java
=>
connector-s3-redshift/src/main/java/org/apache/seatunnel/connectors/seatunnel/redshift/config/S3RedshiftConfig.java}
(53%)
copy
seatunnel-connectors-v2/{connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/exception/AmazonDynamoDBConnectorException.java
=>
connector-s3-redshift/src/main/java/org/apache/seatunnel/connectors/seatunnel/redshift/exception/S3RedshiftJdbcConnectorException.java}
(79%)
copy
seatunnel-connectors-v2/{connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/sink/S3FileSinkFactory.java
=>
connector-s3-redshift/src/main/java/org/apache/seatunnel/connectors/seatunnel/redshift/sink/S3RedshiftFactory.java}
(53%)
copy
seatunnel-connectors-v2/{connector-slack/src/main/java/org/apache/seatunnel/connectors/seatunnel/slack/sink/SlackSink.java
=>
connector-s3-redshift/src/main/java/org/apache/seatunnel/connectors/seatunnel/redshift/sink/S3RedshiftSink.java}
(54%)
