org.apache.flink.statefun.flink.io.kinesis.binders.ingress.v1

Class RoutableKinesisIngressDeserializer

java.lang.Object

org.apache.flink.statefun.flink.io.kinesis.binders.ingress.v1.RoutableKinesisIngressDeserializer

All Implemented Interfaces:

java.io.Serializable, KinesisIngressDeserializer<com.google.protobuf.Message>

public final class RoutableKinesisIngressDeserializer
extends java.lang.Object
implements KinesisIngressDeserializer<com.google.protobuf.Message>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RoutableKinesisIngressDeserializer(java.util.Map<java.lang.String,RoutingConfig> routingConfigs)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RoutableKinesisIngressDeserializer

public RoutableKinesisIngressDeserializer(java.util.Map<java.lang.String,RoutingConfig> routingConfigs)

Method Detail

deserialize

public com.google.protobuf.Message deserialize(IngressRecord ingressRecord)

Description copied from interface: KinesisIngressDeserializer

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

Specified by:

deserialize in interface KinesisIngressDeserializer<com.google.protobuf.Message>

Parameters:

ingressRecord - the IngressRecord consumed from AWS Kinesis.

Returns:

the deserialized data object.