Hi,
I would like to process a stream with a tumbling window of 5secs, create
aggregated stats for keys and push the final aggregates at the end of each
window period to a analytics backend. I have tried doing something like:
stream
.map
.reduceByKey(...
, TimeWindows.of("mywindow", 5000L),...)
.foreach { send stats
}
But I get every update to the ktable in the foreach.
How do I just get the final values once the TumblingWindow is complete so I can
iterate over them and send to some external system?
Thanks,
Clive
PS Using kafka_2.10-0.10.0.0- Kafka Streams reducebykey and tumbling window - need final wi... Clive Cox
- Re: Kafka Streams reducebykey and tumbling window - need... Eno Thereska
- Re: Kafka Streams reducebykey and tumbling window - ... Clive Cox
- Re: Kafka Streams reducebykey and tumbling windo... Eno Thereska
- Re: Kafka Streams reducebykey and tumbling w... Clive Cox
- Re: Kafka Streams reducebykey and tumbl... Eno Thereska
- Re: Kafka Streams reducebykey and t... Eno Thereska
- Re: Kafka Streams reducebykey a... Clive Cox
- Re: Kafka Streams reducebykey a... Srikanth
- Re: Kafka Streams reducebykey a... Eno Thereska
- Re: Kafka Streams reducebykey a... Srikanth
