This is an automated email from the ASF dual-hosted git repository.
tyrantlucifer pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from d625b8888 [Doc] [JDBC] Fix error Sql Server URL (#3442)
add db286e863 [Feature][Connector-V2][File] Add option and factory for
file connectors (#3375)
No new revisions were added by this update.
Summary of changes:
docs/en/connector-v2/sink/Hive.md | 35 +------
docs/en/connector-v2/source/Hive.md | 2 +-
.../file/hdfs/source/BaseHdfsFileSource.java | 13 +--
.../file/hdfs/source/config/HdfsSourceConfig.java | 7 +-
.../seatunnel/file/config/BaseSinkConfig.java | 110 +++++++++++++++++++++
.../seatunnel/file/config/BaseSourceConfig.java | 42 ++++++--
.../seatunnel/file/config/BaseTextFileConfig.java | 42 ++++----
.../connectors/seatunnel/file/config/Constant.java | 42 --------
.../file/sink/config/TextFileSinkConfig.java | 57 +++++------
.../file/sink/writer/AbstractWriteStrategy.java | 16 +--
.../file/source/reader/AbstractReadStrategy.java | 4 +-
.../file/source/reader/TextReadStrategy.java | 18 ++--
.../seatunnel/file/ftp/config/FtpConf.java | 8 +-
.../seatunnel/file/ftp/config/FtpConfig.java | 22 ++++-
.../seatunnel/file/ftp/sink/FtpFileSink.java | 4 +-
.../file/ftp/sink/FtpFileSinkFactory.java | 56 +++++++++++
.../seatunnel/file/ftp/source/FtpFileSource.java | 13 +--
.../file/ftp/source/FtpFileSourceFactory.java} | 35 +++----
.../file/hdfs/sink/HdfsFileSinkFactory.java} | 26 +++--
.../file/hdfs/source/HdfsFileSourceFactory.java} | 32 +++---
.../file/local/sink/LocalFileSinkFactory.java} | 26 +++--
.../file/local/source/LocalFileSource.java | 9 +-
.../file/local/source/LocalFileSourceFactory.java} | 31 +++---
.../seatunnel/file/oss/config/OssConf.java | 8 +-
.../seatunnel/file/oss/config/OssConfig.java | 22 ++++-
.../seatunnel/file/oss/sink/OssFileSink.java | 6 +-
.../file/oss/sink/OssFileSinkFactory.java | 56 +++++++++++
.../seatunnel/file/oss/source/OssFileSource.java | 14 +--
.../file/oss/source/OssFileSourceFactory.java} | 35 +++----
.../seatunnel/file/s3/config/S3Conf.java | 6 +-
.../seatunnel/file/s3/config/S3Config.java | 17 +++-
.../seatunnel/file/s3/sink/S3FileSink.java | 4 +-
.../seatunnel/file/s3/sink/S3FileSinkFactory.java} | 30 ++++--
.../seatunnel/file/s3/source/S3FileSource.java | 10 +-
.../file/s3/source/S3FileSourceFactory.java} | 34 +++----
.../seatunnel/file/sftp/config/SftpConf.java | 9 +-
.../seatunnel/file/sftp/config/SftpConfig.java | 22 ++++-
.../seatunnel/file/sftp/sink/SftpFileSink.java | 4 +-
.../file/sftp/sink/SftpFileSinkFactory.java | 56 +++++++++++
.../seatunnel/file/sftp/source/SftpFileSource.java | 13 +--
.../file/sftp/source/SftpFileSourceFactory.java} | 35 +++----
.../connectors/seatunnel/hive/config/Constant.java | 23 -----
.../seatunnel/hive/config/HiveConfig.java | 14 ++-
.../connectors/seatunnel/hive/sink/HiveSink.java | 47 ++++-----
.../seatunnel/hive/sink/HiveSinkFactory.java} | 13 +--
.../seatunnel/hive/source/HiveSource.java | 14 ++-
.../seatunnel/hive/source/HiveSourceFactory.java} | 15 +--
.../seatunnel/hive/utils/HiveMetaStoreProxy.java | 2 +-
48 files changed, 737 insertions(+), 422 deletions(-)
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseSinkConfig.java
delete mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/Constant.java
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/sink/FtpFileSinkFactory.java
copy
seatunnel-connectors-v2/{connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSourceFactory.java
=>
connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/source/FtpFileSourceFactory.java}
(56%)
copy
seatunnel-connectors-v2/{connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSinkFactory.java
=>
connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/HdfsFileSinkFactory.java}
(51%)
copy
seatunnel-connectors-v2/{connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSourceFactory.java
=>
connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/source/HdfsFileSourceFactory.java}
(57%)
copy
seatunnel-connectors-v2/{connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSinkFactory.java
=>
connector-file/connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/sink/LocalFileSinkFactory.java}
(55%)
copy
seatunnel-connectors-v2/{connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSourceFactory.java
=>
connector-file/connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/source/LocalFileSourceFactory.java}
(58%)
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/sink/OssFileSinkFactory.java
copy
seatunnel-connectors-v2/{connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSourceFactory.java
=>
connector-file/connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/source/OssFileSourceFactory.java}
(56%)
copy
seatunnel-connectors-v2/{connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSinkFactory.java
=>
connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/sink/S3FileSinkFactory.java}
(50%)
copy
seatunnel-connectors-v2/{connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSourceFactory.java
=>
connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3FileSourceFactory.java}
(57%)
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/sink/SftpFileSinkFactory.java
copy
seatunnel-connectors-v2/{connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSourceFactory.java
=>
connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/source/SftpFileSourceFactory.java}
(55%)
delete mode 100644
seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/config/Constant.java
copy
seatunnel-connectors-v2/{connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/sink/KuduSinkFactory.java
=>
connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSinkFactory.java}
(77%)
copy
seatunnel-connectors-v2/{connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/source/SocketSourceFactory.java
=>
connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/HiveSourceFactory.java}
(73%)
