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

Interface PayloadSerializer

All Superinterfaces:

Serializable

@Internal
public interface PayloadSerializer
extends Serializable

Field Summary

Fields

Modifier and Type	Field	Description
static final long	serialVersionUID

Method Summary

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

Field Details

serialVersionUID

static final long serialVersionUID

See Also:

• Constant Field Values

Method Details

serialize

byte[] serialize(Row row)

deserialize

Row deserialize(byte[] bytes)

of

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