Page History

• CompositeReadOnlyWindowStore#fetch(from, to) (v)
  • WrappingStoreProvider#stores() (v)
    • StreamThreadStateStoreProvider#stores() (v)
    • return
  • return new DelegatingPeekingKeyValueIterator()
• DelegatingPeekingKeyValueIterator#hasNext() (v)
  • CompositeKeyValueIterator#hasNext()
    • NextIteratorFunciton#apply()
      • MeteredWindowStore#fetch()
        • CachingWindowStore#fetch()
          • AbstractStateStore#validateStoreOpen() (v)
          • ChangeLoggingWindowBytesStore#fetch()
            • RocksDBWindowBytesStore#fetch()
              • RocksDBSegmentedBytesStore#fetch()
                • WindowKeySchema#segmentsToSearch()
                  • Segments#segments() (v)
                    • return
                  • return
                • return SegmentIterator
              • return keyvalueIterator
            • return
          • ThreadCache.range()
            • return new MemoryLRUCacheBytesIterator
          • WindowKeySchema#hasNextCondition()
          • return new MergedSortedCacheWindowStoreKeyValueIterator()
        • return MeteredWindowKeyValueIterator()
      • return
    • MeteredWindowedKeyValueIterator#hasNext()
      • MergedSortedCacheWindowStoreKeyValueIterator#hasNext()
        AbstractMergedSortedCacheStoreIterator
        
        • WrappedWindowStoreBytesIterator#hasNext()
          WrappedKeyValueIterator#hasNext()
          
          • SegementIterator#hasNext()
            • Segment#range()
              RocksDBStore#range()
              • RocksDBStore#validateStoreOpen() (v)
              • return RocksDBRangeIterator
            • return
        • return
      • return
    • return
  • CompositeKeyValueIterator#next()
    • MeteredWindowedKeyValueIterator#next()
      • MergedSortedCacheWindowStoreKeyValueIterator#next()
        AbstractMergedSortedCacheStoreIterator#next()
        
        • AbstractMergedSortedCacheStoreIterator#hasNext()
        • AbstractMergedSortedCacheStoreIterator#nextStoreValue()
          • WrappedWindowStoreBytesIterator#next()
            • SegmentIteator#hasNext()
            • SegmentIterator#next()
              • SegmentIterator#hasNext() (v)
              • RocksDBRangeIterator#next()
                RocksDbIterator#next()
                • RocksDbIterator#hasNext()
                • RocksIterator#next()
                • return entry
              • return
            • return keyvalue
          • return
        • return keyvalue
      • return
    • return
  • return
• DelegatingPeekingKeyValueIterator#next()
  • DelegatingPeekingKeyValueIterator#hasNext()
  • return

public interface QueryableStoreType<T> {
    // TODO: pass stream instance parameter
    T create(final KafkaStreams streams, final StateStoreProvider storeProvider, final String storeName);
}