草庐IT

getCommandDescription

全部标签

redis - Flink Redis 连接器 : update getCommandDescription() after instantiation

我正在使用FLinkRedisSink向Redis写入一些计数器。https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/connectors/redis.html我想为每一天创建一个HASH,但是当实例化接收器时,接收器的getCommandDescription()只会被调用一次。有没有办法让它更新?@OverridepublicRedisCommandDescriptiongetCommandDescription(){longmillis=DateTime.now(DateTimeZo