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.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, which must be either
String , Integer , Long , or byte[]
. |
abstract <V> Stores.KeyValueFactory<K,V> |
withValues(org.apache.kafka.common.serialization.Serializer<V> valueSerializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
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,byte[]> withByteArrayValues()
public <V> Stores.KeyValueFactory<K,V> withValues(java.lang.Class<V> valueClass)
String
, Integer
, Long
, or byte[]
.valueClass
- the class for the values, which must be one of the types for which Kafka has built-in serializers and
deserializers (e.g., String.class
, Integer.class
, Long.class
, or
byte[].class
)public abstract <V> Stores.KeyValueFactory<K,V> withValues(org.apache.kafka.common.serialization.Serializer<V> valueSerializer, org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
valueSerializer
- the serializer for value; may not be nullvalueDeserializer
- the deserializer for values; may not be null