K
- the type of keyspublic abstract static class Stores.ValueFactory<K>
extends java.lang.Object
Constructor and Description |
---|
Stores.ValueFactory() |
Modifier and Type | Method and Description |
---|---|
Stores.KeyValueFactory<K,byte[]> |
withByteArrayValues()
Use byte arrays for values.
|
Stores.KeyValueFactory<K,java.nio.ByteBuffer> |
withByteBufferValues()
Use
ByteBuffer for values. |
Stores.KeyValueFactory<K,java.lang.Double> |
withDoubleValues()
Use
Double values. |
Stores.KeyValueFactory<K,java.lang.Integer> |
withIntegerValues()
Use
Integer values. |
Stores.KeyValueFactory<K,java.lang.Long> |
withLongValues()
Use
Long values. |
Stores.KeyValueFactory<K,java.lang.String> |
withStringValues()
Use
String values. |
<V> Stores.KeyValueFactory<K,V> |
withValues(java.lang.Class<V> valueClass)
Use values of the specified type.
|
abstract <V> Stores.KeyValueFactory<K,V> |
withValues(Serde<V> valueSerde)
Use the specified serializer and deserializer for the values.
|
public Stores.KeyValueFactory<K,java.lang.String> withStringValues()
String
values.public Stores.KeyValueFactory<K,java.lang.Integer> withIntegerValues()
Integer
values.public Stores.KeyValueFactory<K,java.lang.Long> withLongValues()
Long
values.public Stores.KeyValueFactory<K,java.lang.Double> withDoubleValues()
Double
values.public Stores.KeyValueFactory<K,java.nio.ByteBuffer> withByteBufferValues()
ByteBuffer
for values.public Stores.KeyValueFactory<K,byte[]> withByteArrayValues()
public <V> Stores.KeyValueFactory<K,V> withValues(java.lang.Class<V> valueClass)
valueClass
- the class for the values, which must be one of the types for which Kafka has built-in serdespublic abstract <V> Stores.KeyValueFactory<K,V> withValues(Serde<V> valueSerde)
valueSerde
- the serialization factory for values; may be null