If I have an aggregation :

KTable<Windowed<String>, VideoLogLine> outTable =
sourceStream.groupByKey().reduce(rowReducer,
                TimeWindows.of(60 * 60 * 1000L).until(10 * 60 * 1000L),
                "HourAggStore");

how would I go about getting some value from this with a separate process?
I have the "HourAggStore" but Im not clear how to retrieve anything from it.

Reply via email to