org.apache.flink.statefun.sdk.kinesis.egress

Interface KinesisEgressSerializer<T>

Type Parameters:

T - the type of values being written.

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

GenericKinesisEgressSerializer

public interface KinesisEgressSerializer<T>
extends java.io.Serializable

Defines how to serialize values of type T into EgressRecords to be written to AWS Kinesis.

Method Summary

Modifier and Type	Method and Description
EgressRecord	serialize(T value) Serialize an output value into a EgressRecord to be written to AWS Kinesis.

Method Detail

serialize

EgressRecord serialize(T value)

Serialize an output value into a EgressRecord to be written to AWS Kinesis.

Parameters:

value - the output value to write.

Returns:

a EgressRecord to be written to AWS Kinesis.