Class WindowFetchQuery<K,​V>

    • Method Detail

      • storeType

        public StoreType storeType()
        The storeName type on which this query can be executed.
        Returns:
        a new StoreOperation instance.
      • execute

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