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

Packages that use org.apache.flink.statefun.sdk.kinesis.ingress

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

Classes in org.apache.flink.statefun.sdk.kinesis.ingress used by org.apache.flink.statefun.flink.io.kinesis.binders.ingress.v1

Class and Description
IngressRecord A record consumed from AWS Kinesis.
KinesisIngressDeserializer Describes how to deserialize IngressRecords consumed from AWS Kinesis into data types that are processed by the system.
KinesisIngressSpec
KinesisIngressStartupPosition Position for the ingress to start consuming AWS Kinesis shards.

Classes in org.apache.flink.statefun.sdk.kinesis.ingress used by org.apache.flink.statefun.sdk.kinesis.ingress

Class and Description
IngressRecord A record consumed from AWS Kinesis.
IngressRecord.Builder Builder for IngressRecord.
KinesisIngressBuilder A builder for creating an IngressSpec for consuming data from AWS Kinesis.
KinesisIngressDeserializer Describes how to deserialize IngressRecords consumed from AWS Kinesis into data types that are processed by the system.
KinesisIngressSpec
KinesisIngressStartupPosition Position for the ingress to start consuming AWS Kinesis shards.
KinesisIngressStartupPosition.DatePosition