This is an automated email from the ASF dual-hosted git repository.
lresende pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/bahir-flink.git.
from 16b4b21 Kudu Connector rework (#78)
add e71c6e6 Update Redis connector with HINCRBY (#81)
No new revisions were added by this update.
Summary of changes:
flink-connector-redis/README.md | 4 ++--
.../streaming/connectors/redis/RedisSink.java | 3 +++
.../streaming/connectors/redis/RedisTableSink.java | 7 +++---
.../connectors/redis/RedisTableSinkFactory.java | 28 ++++++++--------------
.../common/container/RedisClusterContainer.java | 16 +++++++++++++
.../common/container/RedisCommandsContainer.java | 2 ++
.../redis/common/container/RedisContainer.java | 20 ++++++++++++++++
.../redis/common/hanlder/RedisMapperHandler.java | 9 +++----
.../redis/common/mapper/RedisCommand.java | 2 ++
.../redis/common/mapper/RedisDataType.java | 2 ++
.../row/{HSetMapper.java => HIncrByMapper.java} | 6 ++---
.../redis/common/mapper/row/RowRedisMapper.java | 11 +++++----
.../connectors/redis/descriptor/Redis.java | 14 ++++-------
13 files changed, 79 insertions(+), 45 deletions(-)
copy
flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/{HSetMapper.java
=> HIncrByMapper.java} (89%)
