Uses of Class
org.apache.flink.statefun.sdk.kinesis.ingress.IngressRecord

Packages that use IngressRecord

Package	Description
org.apache.flink.statefun.flink.io.kinesis.binders.ingress.v1
org.apache.flink.statefun.sdk.kinesis.ingress

Uses of IngressRecord in org.apache.flink.statefun.flink.io.kinesis.binders.ingress.v1

Methods in org.apache.flink.statefun.flink.io.kinesis.binders.ingress.v1 with parameters of type IngressRecord

Modifier and Type	Method and Description
com.google.protobuf.Message	RoutableKinesisIngressDeserializer.deserialize(IngressRecord ingressRecord)

Uses of IngressRecord in org.apache.flink.statefun.sdk.kinesis.ingress

Methods in org.apache.flink.statefun.sdk.kinesis.ingress that return IngressRecord

Modifier and Type	Method and Description
IngressRecord	IngressRecord.Builder.build()

Methods in org.apache.flink.statefun.sdk.kinesis.ingress with parameters of type IngressRecord

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