Dataframes have the combined functionalities of both KTable and Kstreams. So I dont quite understand what you mean by querying a Ktable. If you meant interactively querying a table, then you can put an aggregation streaming query into memory format sink and complete output mode to have interactive queries on the aggregated table. Is that what you want?
If not, could you further elaborate your use case? On May 16, 2017 5:41 PM, "Stephen Fletcher" <stephen.fletc...@gmail.com> wrote: > Are there any plans to add Kafka Streams KTable like functionality in > structured streaming for kafka sources? Allowing querying keyed messages > using spark sql,maybe calling KTables in the backend >
