我在用flink redis的Flume给redis写一些计数器。https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/connectors/redis.html
我想为每一天创建一个哈希 getCommandDescription() 因为sink只在sink被示例化时被调用一次。有没有办法让它更新？

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

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