Page History

• CompositeReadOnlyKeyValueStore#range() (v)
  • WrappingStoreProvider#stores() (v)
    • StreamThreadStateStoreProvider#stores() (v)
  • return new DelegatingPeekingKeyValueIterator<>()DelegatingPeekingKeyValueIterator
• DelegatingPeekingKeyValueIterator#hasNext() (v)
  • CompositKeyValueIterator#hasNext()
    • NextIteratorFunction#apply() (v)
      • MeteredKeyValueBytesStore#range()
        • InnerMeteredKeyValueStore#range()
          • CachingKeyValueStore#range()
            • AbstractStateStore#validateStoreOpen() (v)
            • ChangeLoggingKeyValueBytesStore#range()
              • RocksDBStore#range()
                • RocksDBStore#validateStoreOpen() (v)
                • return new RocksDBRangeIterator()
            • return new MergedSortedCacheKeyValueBytesStoreIterator()
          • return new MeteredKeyValueIterator()
        • return
      • return
    • return
  • CompositKeyValueIterator#next()
    • MeteredKeyValueIterator#next()
      
      • MergedSortedCacheKeyValueBytesStoreIterator#next()
        AbstractMergedSortedCacheStoreIterator#next()

• • • • • RocksDBRangeIterator#hasNext()
          RocksDBIterator#hasNext() (v)
          • • RocksIterator#isValid()
        • AbstractMergedStortedCacheStoreIterator#nextSrtoreValue()
          • RocksDBRangeIterator#next()
            RocksDBIterator#next()
            • RocksDbIterator#hasNext() (v)
            • RocksDbIterator#getKeyValue()
            • RocksIterator#next()
            • return keyvalue entry
          • return
        • return
      • return outerkeyvalue
    • return
  • return
• DelegatingPeekingKeyValueIterator#next()
  • return keyvalue

• CompositeReadOnlyKeyValueStore#all() (v)
  • WrappingStoreProvider#stores() (v)
    • StreamThreadStateStoreProvider#stores() (v)
  • return new DelegatingPeekingKeyValueIterator<>()DelegatingPeekingKeyValueIterator
• DelegatingPeekingKeyValueIterator#hasNext() (v)
  • CompositKeyValueIterator#hasNext()
    • NextIteratorFunction#apply() (v)
      • MeteredKeyValueBytesStore#all()
        • InnerMeteredKeyValueStore#all()
          CachingKeyValueStore#all()
          • AbstractStateStore#validateStoreOpen() (v)
            • ChangeLoggingKeyValueBytesStore#all()
              • RocksDBStore#all()
                • RocksDBStore#validateStoreOpen() (v)
                • return new RocksDBIterator()
              • return
            • return new MergedSortedCacheKeyValueBytesStoreIterator()
          • return new MeteredKeyValueIterator()
        • return
      • return
    • return
  • CompositKeyValueIterator#next()
    • MeteredKeyValueIterator#next()
      
      • MergedSortedCacheKeyValueBytesStoreIterator#next()
        AbstractMergedSortedCacheStoreIterator#next()
        • MemoryLRUCacheBytesIterator.hasNext()
        • DelegatingPeekingKeyValueIterator.hasNext() (v)
        • AbstractMergedSortedCacheStoreIterator#nextStoreValue()
          • DelegatingPeekingKeyValueIterator#next()
            • DelegatingPeekingKeyValueIterator#hasNext() (v)
          • return
        • return
      • return outerkeyvalue
    • return
  • return
• DelegatingPeekingKeyValueIterator#next()
  • return keyvalue

• 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

public <T> T getStore(final String storeName, final QueryableStoreType<T> queryableStoreType) {
    final List<T> globalStore = globalStoreProvider.stores(storeName, queryableStoreType);
    if (!globalStore.isEmpty()) {
        return queryableStoreType.create(new WrappingStoreProvider(Collections.<StateStoreProvider>singletonList(globalStoreProvider)), storeName);
    }
    final List<T> allStores = new ArrayList<>();
    for (StateStoreProvider storeProvider : storeProviders) {
        allStores.addAll(storeProvider.stores(storeName, queryableStoreType));
    }
    if (allStores.isEmpty()) {
        // TODO: Replace with StateStoreMigratedException
        throw new InvalidStateStoreException("theThe state store, " + storeName + ", may have migrated to another instance.");
    }
    return queryableStoreType.create(
            new WrappingStoreProvider(storeProviders),
            storeName);
}

public <T> List<T> stores(final String storeName, QueryableStoreType<T> type) {
    final List<T> allStores = new ArrayList<>();
    for (StateStoreProvider provider : storeProviders) {
        final List<T> stores =
            provider.stores(storeName, type);
        allStores.addAll(stores);
    }
    if (allStores.isEmpty()) {
        // TODO: Replace with StateStoreMigratedException
        throw new InvalidStateStoreException("theThe state store, " + storeName + ", may have migrated to another instance.");
    }
    return allStores;
}