This is an automated email from the ASF dual-hosted git repository.
kirs pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from 7a5135b98 [seatunnel-1947][seatunnel-server] add query log (#2614)
add 71a9e4b01 [Feature][Connector-V2] Add redis sink connector (#2647)
No new revisions were added by this update.
Summary of changes:
docs/en/connector-v2/sink/Redis.md | 113 +++++++++++++++++++++
plugin-mapping.properties | 1 +
.../seatunnel/redis/config/RedisConfig.java | 1 +
.../seatunnel/redis/config/RedisDataType.java | 31 ++++++
.../seatunnel/redis/config/RedisParameters.java | 19 +++-
.../seatunnel/redis/sink/RedisSink.java} | 23 +++--
.../seatunnel/redis/sink/RedisSinkWriter.java | 71 +++++++++++++
.../seatunnel/redis/source/RedisSourceReader.java | 6 +-
.../seatunnel/e2e/flink/v2/redis/RedisIT.java | 5 +-
...edis_source.conf => redis_source_and_sink.conf} | 7 +-
.../seatunnel/e2e/spark/v2/redis/RedisIT.java | 5 +-
...edis_source.conf => redis_source_and_sink.conf} | 7 +-
12 files changed, 264 insertions(+), 25 deletions(-)
create mode 100644 docs/en/connector-v2/sink/Redis.md
copy
seatunnel-connectors-v2/{connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/sink/SocketSink.java
=>
connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/sink/RedisSink.java}
(75%)
create mode 100644
seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/sink/RedisSinkWriter.java
rename
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-redis-flink-e2e/src/test/resources/redis/{redis_source.conf
=> redis_source_and_sink.conf} (94%)
rename
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-redis-spark-e2e/src/test/resources/redis/{redis_source.conf
=> redis_source_and_sink.conf} (94%)
