java.io.Closeable
, java.lang.AutoCloseable
, Serde<T>
Serdes.ByteArraySerde
, Serdes.ByteBufferSerde
, Serdes.BytesSerde
, Serdes.DoubleSerde
, Serdes.FloatSerde
, Serdes.IntegerSerde
, Serdes.LongSerde
, Serdes.ShortSerde
, Serdes.StringSerde
, WindowedSerdes.SessionWindowedSerde
, WindowedSerdes.TimeWindowedSerde
public static class Serdes.WrapperSerde<T> extends java.lang.Object implements Serde<T>
Constructor | Description |
---|---|
WrapperSerde(Serializer<T> serializer,
Deserializer<T> deserializer) |
Modifier and Type | Method | Description |
---|---|---|
void |
close() |
Close this serde class, which will close the underlying serializer and deserializer.
|
void |
configure(java.util.Map<java.lang.String,?> configs,
boolean isKey) |
Configure this class, which will configure the underlying serializer and deserializer.
|
Deserializer<T> |
deserializer() |
|
Serializer<T> |
serializer() |
public WrapperSerde(Serializer<T> serializer, Deserializer<T> deserializer)
public void configure(java.util.Map<java.lang.String,?> configs, boolean isKey)
Serde
public void close()
Serde
public Serializer<T> serializer()
serializer
in interface Serde<T>
public Deserializer<T> deserializer()
deserializer
in interface Serde<T>