Доступ к времени начала окна в функции агрегации ⇐ JAVA

[Anonymous]

У меня есть топология kafkaStream, показанная в:

Код: Выделить всё

stream
.filter(((key, Trade) -> Trade.tradeTime != null && Trade.tradeTime > todayMillis ))
.groupByKey(
Grouped.with(Serdes.String(),JSONSerdes.Trade())
)
.windowedBy(TimeWindows.ofSizeAndGrace(Duration.ofMinutes(Convertor.getCandleByResolution(resolution)), Duration.ofDays(1)))
.aggregate(
OHLC::new,
(( key, value, aggregate) -> aggregate.add(value,key)),
Materialized.
as(stateStoreName)
.withKeySerde(Serdes.String())
.withValueSerde(JSONSerdes.OHLC())
);

как мне получить доступ к времени начала окна в функции агрегации?
например, я хочу передать время начала окна для добавления функции, но ключ — это строка.
my ( пара ключ, значение) — («IFTTT»,объект OHLC)

Подробнее здесь: https://stackoverflow.com/questions/790 ... n-function