Jon, you can use Kafka's interactive queries feature for this: http://docs.confluent.io/current/streams/developer-guide.html#interactive-queries
-Michael On Thu, Mar 23, 2017 at 1:52 PM, Jon Yeargers <jon.yearg...@cedexis.com> wrote: > 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. >
