| Interface | Description |
|---|---|
| Deserializer<T> |
A standard interface for Samza compatible deserializers, used for deserializing serialized objects back to their
original form.
|
| Serde<T> |
A Serde is a convenience type that implements both the
Serializer and
Deserializer interfaces, allowing it to both read and write data
in its value type, T. |
| SerdeFactory<T> |
Build an instance of
Serde |
| Serializer<T> |
A standard interface for Samza compatible serializers, used for serializing objects to bytes.
|
| Class | Description |
|---|---|
| ByteBufferSerde |
A serializer for ByteBuffers.
|
| ByteBufferSerdeFactory | |
| ByteSerde |
A serializer for bytes that is effectively a pass-through, but can be useful for binary messages.
|
| ByteSerdeFactory | |
| DoubleSerde |
A serializer for doubles
|
| DoubleSerdeFactory | |
| IntegerSerde |
A serializer for integers
|
| IntegerSerdeFactory | |
| JsonSerdeV2<T> |
A serializer for UTF-8 encoded JSON strings.
|
| JsonSerdeV2Factory | |
| KVSerde<K,V> |
A serializer that serves one of the following two purposes:
When used for input/output streams, serves as an indication to the framework that messages are keyed and
should be deserialized as K-V pairs.
When used for a key or value of type KV, serializes the key and value pair using the provided serdes.
|
| LongSerde |
A serializer for longs
|
| LongSerdeFactory | |
| NoOpSerde<T> |
A marker serde class to indicate that messages should not be serialized or deserialized.
|
| SerializableSerde<T extends java.io.Serializable> |
A serializer for Serializable objects
|
| SerializableSerdeFactory<T extends java.io.Serializable> | |
| StringSerde |
A serializer for strings
|
| StringSerdeFactory | |
| UUIDSerde |
A serializer for UUID
|
| UUIDSerdeFactory |