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

Question

我正在使用 FLink Redis Sink 向 Redis 写入一些计数器。 https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/connectors/redis.html

我想为每一天创建一个 HASH，但是当实例化接收器时，接收器的 getCommandDescription() 只会被调用一次。有没有办法让它更新？

@Override
public RedisCommandDescription getCommandDescription() {
    long millis = DateTime.now(DateTimeZone.UTC).withTimeAtStartOfDay().getMillis();
    return new RedisCommandDescription(RedisCommand.HSET, "view_count_" + millis);
}

如您所见，我正在尝试在 HASH 名称中添加日期。实现这一目标的最佳方式是什么？

Answer 1

如您所知，目前不支持它。目前，您可以在哈希中维护一个时间戳键。