org.apache.kafka.streams.state

Class Stores.StoreFactory

java.lang.Object

org.apache.kafka.streams.state.Stores.StoreFactory

Enclosing class:

Stores

public abstract static class Stores.StoreFactory
extends Object

Constructor Summary

Constructors

Constructor and Description
Stores.StoreFactory()

Method Summary

Methods

Modifier and Type	Method and Description
Stores.ValueFactory<byte[]>	withByteArrayKeys() Begin to create a KeyValueStore by specifying the keys will be byte arrays.
Stores.ValueFactory<ByteBuffer>	withByteBufferKeys() Begin to create a KeyValueStore by specifying the keys will be ByteBuffer.
Stores.ValueFactory<Double>	withDoubleKeys() Begin to create a KeyValueStore by specifying the keys will be Doubles.
Stores.ValueFactory<Integer>	withIntegerKeys() Begin to create a KeyValueStore by specifying the keys will be Integers.
<K> Stores.ValueFactory<K>	withKeys(Class<K> keyClass) Begin to create a KeyValueStore by specifying the keys.
abstract <K> Stores.ValueFactory<K>	withKeys(Serde<K> keySerde) Begin to create a KeyValueStore by specifying the serializer and deserializer for the keys.
Stores.ValueFactory<Long>	withLongKeys() Begin to create a KeyValueStore by specifying the keys will be Longs.
Stores.ValueFactory<String>	withStringKeys() Begin to create a KeyValueStore by specifying the keys will be Strings.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Stores.StoreFactory

public Stores.StoreFactory()

Method Detail

withStringKeys

public Stores.ValueFactory<String> withStringKeys()

Begin to create a KeyValueStore by specifying the keys will be Strings.

Returns:

the interface used to specify the type of values; never null

withIntegerKeys

public Stores.ValueFactory<Integer> withIntegerKeys()

Begin to create a KeyValueStore by specifying the keys will be Integers.

Returns:

the interface used to specify the type of values; never null

withLongKeys

public Stores.ValueFactory<Long> withLongKeys()

Begin to create a KeyValueStore by specifying the keys will be Longs.

Returns:

the interface used to specify the type of values; never null

withDoubleKeys

public Stores.ValueFactory<Double> withDoubleKeys()

Begin to create a KeyValueStore by specifying the keys will be Doubles.

Returns:

the interface used to specify the type of values; never null

withByteBufferKeys

public Stores.ValueFactory<ByteBuffer> withByteBufferKeys()

Begin to create a KeyValueStore by specifying the keys will be ByteBuffer.

Returns:

the interface used to specify the type of values; never null

withByteArrayKeys

public Stores.ValueFactory<byte[]> withByteArrayKeys()

Begin to create a KeyValueStore by specifying the keys will be byte arrays.

Returns:

the interface used to specify the type of values; never null

withKeys

public <K> Stores.ValueFactory<K> withKeys(Class<K> keyClass)

Begin to create a KeyValueStore by specifying the keys.

Parameters:

keyClass - the class for the keys, which must be one of the types for which Kafka has built-in serdes

Returns:

the interface used to specify the type of values; never null

withKeys

public abstract <K> Stores.ValueFactory<K> withKeys(Serde<K> keySerde)

Begin to create a KeyValueStore by specifying the serializer and deserializer for the keys.

Parameters:

keySerde - the serialization factory for keys; may be null

Returns:

the interface used to specify the type of values; never null