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

Packages that use KinesisIngressStartupPosition

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

Uses of KinesisIngressStartupPosition 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 KinesisIngressStartupPosition

Modifier and Type	Method and Description
RoutableKinesisIngressSpec.Builder	RoutableKinesisIngressSpec.Builder.withStartupPosition(KinesisIngressStartupPosition startupPosition)

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

Subclasses of KinesisIngressStartupPosition in org.apache.flink.statefun.sdk.kinesis.ingress

Modifier and Type	Class and Description
static class	KinesisIngressStartupPosition.DatePosition
static class	KinesisIngressStartupPosition.EarliestPosition
static class	KinesisIngressStartupPosition.LatestPosition

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

Modifier and Type	Method and Description
static KinesisIngressStartupPosition	KinesisIngressStartupPosition.fromDate(java.time.ZonedDateTime date) Start consuming from position with ingestion timestamps after or equal to a specified ZonedDateTime.
static KinesisIngressStartupPosition	KinesisIngressStartupPosition.fromEarliest() Start consuming from the earliest position possible.
static KinesisIngressStartupPosition	KinesisIngressStartupPosition.fromLatest() Start consuming from the latest position, i.e.
KinesisIngressStartupPosition	KinesisIngressSpec.startupPosition()

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

Modifier and Type	Method and Description
KinesisIngressBuilder<T>	KinesisIngressBuilder.withStartupPosition(KinesisIngressStartupPosition startupPosition) Configures the position that the ingress should start consuming from.