Flink Redis Connector: Update getCommandDescription() nach Instanziierung

Question

Ich benutze die FLink Redis Sink, um einige Zähler zu redis zu schreiben.

Ich möchte einen HASH für jeden Tag erstellen, aber getCommandDescription() für die Senke wird nur einmal aufgerufen, wenn Sink instanziiert wird. Gibt es eine Möglichkeit, das zu aktualisieren?

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

Wie Sie sehen können, versuche ich das Datum in den HASH-Namen hinzuzufügen. Was ist der beste Weg dies zu erreichen?

Answer 1

Wie Sie herausgefunden haben, wird es zur Zeit nicht unterstützt. Vorläufig können Sie einen Zeitstempelschlüssel in Ihrem Hash beibehalten.