Page History

...

KafkaStreams
- store()
ReadOnlyKeyValueStore(CompositeReadOnlyKeyValueStore)
- get(k)
- range(from, to)
- all()
- approximateNumEntries()
ReadOnlySessionStore(CompositeReadOnlySessionStore)
- fetch(k)
- fetch(from, to)
ReadOnlyWindowStore(CompositeReadOnlyWindowStore)
- fetch(k, rf, tt)
- fetch(from, to, rf, tt)
- all()
- fetchAll()
KeyValueIterator(DelegatingPeekingKeyValueIterator)
- next()
- hasNext()
- peekNextKey()
WindowStoreIterator(MeteredWindowStoreIterator)
- next()
- hasNext()
- peekNextKey()

Call Trace

Expand

title	Call trace 1: KafkaStreams#store()

KafkaStreams#store() (v)
- QueryableStoreProvider#getStore() (v)
  - GlobalStateStoreProvider#stores() (v)
  - StreamThreadStateStroeProvider#stores() (v)

...

Expand

title	Call trace 8: ReadOnlyWindowStore#fetch(key)

CompositeReadOnlySessionStore#fetch(key) (v)
- WrappingStoreProvider#stores() (v)
  - StreamThreadStateStoreProvider#stores() (v)
- MeteredWindowStore#fetch()
  - CachingWindowStore#fetch(k, tf, tt)
    - AbstractStateStore#validateStoreOpen()
      - ChangeLoggingWindowBytesStore#isOpen()
        AbstractStateStore#isOpen()
        RocksDBWindowBytesStore#isOpen()
        RocksDBSegmentedBytesStore#isOpen()
        return
        return
        return
      - return
    - ChangeLoggingWindowBytesStore#fetch()
      - RocksDBWindowStoreBytesStore#fetch()
        RocksDBSegmentedBytesStore#fetch()
        WindowKeySchema#segmentsToSearch()
        Segments#segments()
        RocksDBStore#isOpen()
        return segments
        return
        return new SegmentIterator()
        WindowStoreIteratorWrapper.bytesIterator()
        return new WrappedWindowStoreBytesIterator()
        return
      - return
    - ThreadCache#range()
      - return new MemoryLRUCacheBytesIterator
    - return new MergedSortedCacheWindowStoreIterator
  - return new MeteredWindowStoreIterator
- MeteredWindowStoreIterator#hasNext()
  AbstractMergedSortedCacheStoreIterator#hasNext()
  - WrappedWindowStoreIterator#hasNext()
    - SegmentIterator#hasNext()
      - Segment#range()
        RocksDBStore#range()
        RocksDBStore#validateStoreOpen()
        return RocksDBRangeIterator
      - return
    - return
  - return
- return
MeteredWindowStoreIterator#hasNext()
- MeteredSortedCacheWindowStoreIterator#hasNext()
  AbstractMergedSortedCacheStoreIterator#hasNext()
  - WrappedWindowStoreIterator#hasNext()
    - SegmentIterator#hasNext()
      - Segment#range()
        RocksDBStore#range()
        RocksDBStore#validateStoreOpen() (v)
        return RocksDBRangeIterator
      - return
    - return
  - return
- return
MeteredWindowStoreIterator#next()
- MergedSortedCacheWindowStoreIterator#next()
  AbstractMergedSortedCacheStoreIterator#next()
  - WrappedWindowStoreBytesIterator#hasNext()
    - SegmentIterator#hasNext()
      - return
    - return
  - AbstractMergedSortedCacheStoreIterator#nextStoreValue()
    - WrappedWindowStoreBytesIterator#next()
      - SegmentIterator#next()
        SegmentIterator#hasNext()
        return
        RocksDBRangeIterator#next()
        RocksDBRangeIterator#hasNext()
        RocksDBIterator#hasNext() (v)
        return
        RocksIterator#next()
        return entry
        return
      - return keyvalue
    - return
  - return
- return keyvalue

...

Expand

title	Call trace 9: ReadOnlyWindowStore#fetch(from, to)

CompositeReadOnlyWindowStore#fetch(from, to)
- 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

...

Expand

title	Call trace 10: ReadOnlyWindowStore#all()

CompositeReadOnlyWindowStore#all()
- WrappingStoreProvider#stores() (v)
  - StreamThreadStateStoreProvider#stores() (v)
  - return
- return new DelegatingPeekingKeyValueIterator()
DelegatingPeekingKeyValueIterator#hasNext() (v)
- CompositeKeyValueIterator#hasNext()
  - NextIteratorFunciton#apply()
    - MeteredWindowStore#all()
      - CachingWindowStore#all()
        AbstractStateStore#validateStoreOpen() (v)
        ChangeLoggingWindowBytesStore#all()
        RocksDBWindowBytesStore#all()
        RocksDBSegmentedBytesStore#all()
        Segments#allSegments() (v)
        return new SegmentIterator()
        return keyValueIterator
        return
        ThreadCache#all()
        return new MemoryLRUCacheBytesIterator
        return new MergedSortedCacheWindowStoreKeyValueIterator
      - return new MeteredWindowedKeyValueIterator()
    - return
  - MeteredWindowedKeyValueIterator#hasNext()
    - MergedSortedCacheWindowStoreKeyValueIterator#hasNext()
      AbstractMergedSortedCacheStoreIterator#hasNext()
      - WrappedKeyValueIterator#hasNext()
        SegmentIterator#hasNext() (v)
        return currentIterator
        return
      - return
    - return
  - return
- CompositeKeyValueIterator#next()
  - MeteredWindowedKeyValueIterator#next()
    - MergedSortedCacheWindowStoreKeyValueIterator#next()
      AbstractMergedSortedCacheStoreIterator#next()
      - WrappedKeyValueIterator#hasNext()
        SegmentIterator#hasNext()
      - AbstractMergedSortedCacheStoreIterator#nextStoreValue()
        WrappedKeyValueIterator#next()
        SegmentIterator#next()
        RocksDbIterator#next()
        RocksDbIterator#hasNext() (v)
        RocksIterator.next()
        return entry
        return
        return keyvalue
        return
      - return
    - return keyvalue
  - return
- return
DelegatingPeekingKeyValueIterator#next()
- DelegatingPeekingKeyValueIterator#hasNext()
- return

...

Expand

title	Call trace 11: ReadOnlyWindowStore#fetchAll()

CompositeReadOnlyWindowStore#fetchAll()
- WrappingStoreProvider#stores() (v)
  - StreamThreadStateStoreProvider#stores() (v)
  - return
- return new DelegatingPeekingKeyValueIterator()
DelegatingPeekingKeyValueIterator#hasNext() (v)
- CompositeKeyValueIterator#hasNext()
  - NextIteratorFunciton#applyNextIteratorFunction#apply()
    - MeteredWindowStore#fetchAll()
      - CachingWindowStore#fetchAll()
        AbstractStateStore#validateStoreOpen() (v)
        ChangeLoggingWindowBytesStore#fetchAll()
        RocksDBWindowBytesStore#fetchAll()
        RocksDBSegmentedBytesStore#fetchAll()
        Segments#allSegments() (v)
        return new SegmentIterator()
        return keyValueIterator
        return
        ThreadCache#all()
        return new MemoryLRUCacheBytesIterator
        return new MergedSortedCacheWindowStoreKeyValueIterator
      - return new MeteredWindowedKeyValueIterator()
    - return
  - MeteredWindowedKeyValueIterator#hasNext()
    - MergedSortedCacheWindowStoreKeyValueIterator#hasNext()
      AbstractMergedSortedCacheStoreIterator#hasNext()
      - WrappedKeyValueIterator#hasNext()
        SegmentIterator#hasNext() (v)
        return currentIterator
        return
      - return
    - return
  - return
- CompositeKeyValueIterator#next()
  - MeteredWindowedKeyValueIterator#next()
    - MergedSortedCacheWindowStoreKeyValueIterator#next()
      AbstractMergedSortedCacheStoreIterator#next()
      - WrappedKeyValueIterator#hasNext()
        SegmentIterator#hasNext() (v)
        return
      - AbstractMergedSortedCacheStoreIterator#nextStoreValue()
        WrappedKeyValueIterator#next()
        SegmentIterator#next()
        RocksDbIterator#next()
        RocksDbIterator#hasNext() (v)
        RocksIterator.next()
        return entry
        return
        return keyvalue
        return
      - return
    - return keyvalue
  - return
- return
DelegatingPeekingKeyValueIterator#next()
- DelegatingPeekingKeyValueIterator#hasNext()
- return

...

Space shortcuts

Child pages

Versions Compared

Old Version 45

New Version 46

Key

Call Trace