Versions Compared

Old Version 30

changes.mady.by.user vitojeng

Saved on

compared with

New Version 31

changes.mady.by.user vitojeng

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Call trace 11

...

Expand
titleCall trace 9: ReadOnlyWindowStore#fetch(from, to)
  • 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
Expand
titleCall trace 10: ReadOnlyWindowStore#all()
  • CompositeReadOnlyWindowStore#all(from, to) (v)
    • 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()
                  WrappedKeyValueIterator.
                    • RocksDbIterator#next()
                      • RocksDbIterator#hasNext() (v)
                      • RocksIterator.next()
                      • return entry
                    • return
                  • return keyvalue
                • return
              • return
            • return keyvalue
          • return
        • return
      • DelegatingPeekingKeyValueIterator#next()
        • DelegatingPeekingKeyValueIterator#hasNext()
        • return
    Expand
    titleCall trace 11: ReadOnlyWindowStore#fetchAll()
    • CompositeReadOnlyWindowStore#fetchAll()
      • WrappingStoreProvider#stores() (v)
        • StreamThreadStateStoreProvider#stores() (v)
        • return
      • return new DelegatingPeekingKeyValueIterator()
    • DelegatingPeekingKeyValueIterator#hasNext() (v)
      • CompositeKeyValueIterator#hasNext()
        • NextIteratorFunciton#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#nextnext()
                • 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

    ...