Flink redis連接器：實例化後更新getCommandDescription（）

Question

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

我想爲每一天創建一個HASH，然而getCommandDescription()只有當sink被實例化時纔會調用sink。有沒有辦法讓它更新？

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

正如你所看到的，我試圖在HASH名稱中添加日期。達到這個目標的最好方法是什麼？

Answer 1

正如你想象的那樣，目前還不支持。目前，您可以在散列內維護一個時間戳記密鑰。