Interface Serde<T>
-
- Type Parameters:
T- Type to be serialized from and deserialized into. A class that implements this interface is expected to have a constructor with no parameter.
- All Superinterfaces:
AutoCloseable,Closeable
- All Known Implementing Classes:
Serdes.ByteArraySerde,Serdes.ByteBufferSerde,Serdes.BytesSerde,Serdes.DoubleSerde,Serdes.FloatSerde,Serdes.IntegerSerde,Serdes.LongSerde,Serdes.ShortSerde,Serdes.StringSerde,Serdes.UUIDSerde,Serdes.VoidSerde,Serdes.WrapperSerde,WindowedSerdes.SessionWindowedSerde,WindowedSerdes.TimeWindowedSerde
public interface Serde<T> extends Closeable
The interface for wrapping a serializer and deserializer for the given data type.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default voidclose()Close this serde class, which will close the underlying serializer and deserializer.default voidconfigure(Map<String,?> configs, boolean isKey)Configure this class, which will configure the underlying serializer and deserializer.Deserializer<T>deserializer()Serializer<T>serializer()
-
-
-
Method Detail
-
configure
default void configure(Map<String,?> configs, boolean isKey)
Configure this class, which will configure the underlying serializer and deserializer.- Parameters:
configs- configs in key/value pairsisKey- whether is for key or value
-
close
default void close()
Close this serde class, which will close the underlying serializer and deserializer.This method has to be idempotent because it might be called multiple times.
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable
-
serializer
Serializer<T> serializer()
-
deserializer
Deserializer<T> deserializer()
-
-