Class SerdePipeline

java.lang.Object

dev.restate.serde.SerdePipeline

@Internal
public final class SerdePipeline
extends Object

Combines a SerdeFactory and a PayloadCodec: resolves the Serde from the TypeTag, then serializes and encodes, or decodes and deserializes, the values.

Constructor Summary

Constructors

Constructor	Description
SerdePipeline(SerdeFactory serdeFactory, @Nullable PayloadCodec payloadCodec)

Method Summary

Modifier and Type	Method	Description
<T> CompletableFuture<T>	decode(TypeTag<T> typeTag, Slice value)	Decode the value, then resolve the serde and deserialize it.
<T> CompletableFuture<Slice>	encode(TypeTag<T> typeTag, T value)	Resolve the serde, serialize the value, then encode it.
PayloadCodec	payloadCodec()
SerdeFactory	serdeFactory()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SerdePipeline

public SerdePipeline(SerdeFactory serdeFactory,
 @Nullable PayloadCodec payloadCodec)

Parameters:

payloadCodec - the codec to use, or null to use PayloadCodec.NOOP.

Method Details

encode

public <T> CompletableFuture<Slice> encode(TypeTag<T> typeTag,
 T value)

Resolve the serde, serialize the value, then encode it.

decode

public <T> CompletableFuture<T> decode(TypeTag<T> typeTag,
 Slice value)

Decode the value, then resolve the serde and deserialize it.

serdeFactory

public SerdeFactory serdeFactory()

payloadCodec

public PayloadCodec payloadCodec()