<K,V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,V>> |
KafkaStreamsContainer.getLocalKeyValueStore(String storeName) |
|
<K,V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlySessionStore<K,V>> |
KafkaStreamsContainer.getLocalSessionStore(String storeName) |
|
<K,V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,org.apache.kafka.streams.state.ValueAndTimestamp<V>>> |
KafkaStreamsContainer.getLocalTimestampedKeyValueStore(String storeName) |
|
<K,V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyWindowStore<K,org.apache.kafka.streams.state.ValueAndTimestamp<V>>> |
KafkaStreamsContainer.getLocalTimestampedWindowStore(String storeName) |
|
<K,V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyWindowStore<K,V>> |
KafkaStreamsContainer.getLocalWindowStore(String storeName) |
|