org.apache.flink.statefun.sdk.kinesis.ingress

Interface KinesisIngressDeserializer<T>

Type Parameters:

T - The type created by the ingress deserializer.

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

RoutableKinesisIngressDeserializer

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

Describes how to deserialize IngressRecords consumed from AWS Kinesis into data types that are processed by the system.

Method Summary

Modifier and Type	Method and Description
T	deserialize(IngressRecord ingressRecord) Deserialize an input value from a IngressRecord consumed from AWS Kinesis.

Method Detail

deserialize

T deserialize(IngressRecord ingressRecord)

Deserialize an input value from a IngressRecord consumed from AWS Kinesis.

Parameters:

ingressRecord - the IngressRecord consumed from AWS Kinesis.

Returns:

the deserialized data object.