Flink redis connector: обновление getCommandDescription () после создания экземпляра

Я использую раковину FLink Redis для записи некоторых счетчиков в redis.
https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/connectors/redis.html

Я хотел бы создать хэш для каждого дня, однако getCommandDescription()для раковины вызывается только один раз, когда раковина создана. Есть ли способ обновить это?

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

Как вы можете видеть, я пытаюсь добавить дату в имя хэша. как лучше всего этого добиться?

1 ответ

  1. Как вы поняли, в настоящее время он не поддерживается. На данный момент Вы можете сохранить ключ timestamp внутри хэша.