Class TimestampedKeyValueStoreMaterializer<K,V>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.TimestampedKeyValueStoreMaterializer<K,V>
-
public class TimestampedKeyValueStoreMaterializer<K,V> extends Object
-
-
Constructor Summary
Constructors Constructor Description TimestampedKeyValueStoreMaterializer(MaterializedInternal<K,V,KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StoreBuilder<TimestampedKeyValueStore<K,V>>
materialize()
-
-
-
Constructor Detail
-
TimestampedKeyValueStoreMaterializer
public TimestampedKeyValueStoreMaterializer(MaterializedInternal<K,V,KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
-
-
Method Detail
-
materialize
public StoreBuilder<TimestampedKeyValueStore<K,V>> materialize()
- Returns:
- StoreBuilder
-
-