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

Interface Summary

Interface	Description
KinesisIngressDeserializer<T>	Describes how to deserialize IngressRecords consumed from AWS Kinesis into data types that are processed by the system.

Class Summary

Class	Description
IngressRecord	A record consumed from AWS Kinesis.
IngressRecord.Builder	Builder for IngressRecord.
KinesisIngressBuilder<T>	A builder for creating an IngressSpec for consuming data from AWS Kinesis.
KinesisIngressBuilderApiExtension
KinesisIngressSpec<T>
KinesisIngressStartupPosition	Position for the ingress to start consuming AWS Kinesis shards.
KinesisIngressStartupPosition.DatePosition
KinesisIngressStartupPosition.EarliestPosition
KinesisIngressStartupPosition.LatestPosition