Class SessionFetchQuery<K,​V>

    • Method Detail

      • execute

        public Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,​V>>> execute​(LocalStoreAccessProvider provider,
                                                                                           long limit)
        Executes this query to the specified KafkaStreams application.
        Parameters:
        provider - the KafkaStreamsContainer instance.
        limit - the maximum number of records the result should be limited to (-1 means no limit).