This is an automated email from the ASF dual-hosted git repository.
eskabetxe pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/bahir-flink.git.
from e215544 Add batch table env support and filter push down to Kudu
connector (#82)
add 6e872c7 Add zincrby command to Redis connector (#86)
No new revisions were added by this update.
Summary of changes:
.../streaming/connectors/redis/RedisSink.java | 3 +
.../common/container/RedisClusterContainer.java | 14 +++
.../common/container/RedisCommandsContainer.java | 9 ++
.../redis/common/container/RedisContainer.java | 17 ++++
.../redis/common/mapper/RedisCommand.java | 2 +
.../row/{IncrByMapper.java => ZIncrByMapper.java} | 10 +-
.../RedisSinkZIncrByTest.java} | 102 +++++++++------------
7 files changed, 93 insertions(+), 64 deletions(-)
copy
flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/{IncrByMapper.java
=> ZIncrByMapper.java} (86%)
copy
flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/{RedisSinkPublishITCase.java
=> common/RedisSinkZIncrByTest.java} (52%)
