org.apache.beam.sdk.schemas.io.payloads

Interface PayloadSerializer

All Superinterfaces:

java.io.Serializable

@Internal
 @Experimental(value=SCHEMAS)
public interface PayloadSerializer
extends java.io.Serializable

Field Summary

Fields

Modifier and Type	Field and Description
static long	serialVersionUID

Method Summary

Modifier and Type	Method and Description
Row	deserialize(byte[] bytes)
static PayloadSerializer	of(SerializableFunction<Row,byte[]> serializeFn, SerializableFunction<byte[],Row> deserializeFn)
byte[]	serialize(Row row)

Field Detail

serialVersionUID

static final long serialVersionUID

See Also:

Constant Field Values

Method Detail

serialize

byte[] serialize(Row row)

deserialize

Row deserialize(byte[] bytes)

of

static PayloadSerializer of(SerializableFunction<Row,byte[]> serializeFn,
                            SerializableFunction<byte[],Row> deserializeFn)