You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by es...@apache.org on 2020/07/28 15:41:06 UTC
[bahir-flink] branch master updated (e215544 -> 6e872c7)
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%)