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

Class KinesisIngressStartupPosition

java.lang.Object

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

Direct Known Subclasses:

KinesisIngressStartupPosition.DatePosition, KinesisIngressStartupPosition.EarliestPosition, KinesisIngressStartupPosition.LatestPosition

public abstract class KinesisIngressStartupPosition
extends java.lang.Object

Position for the ingress to start consuming AWS Kinesis shards.

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method and Description
KinesisIngressStartupPosition.DatePosition	asDate() Returns this position as a KinesisIngressStartupPosition.DatePosition.
static KinesisIngressStartupPosition	fromDate(java.time.ZonedDateTime date) Start consuming from position with ingestion timestamps after or equal to a specified ZonedDateTime.
static KinesisIngressStartupPosition	fromEarliest() Start consuming from the earliest position possible.
static KinesisIngressStartupPosition	fromLatest() Start consuming from the latest position, i.e.
boolean	isDate() Checks whether this position is configured using a date.
boolean	isEarliest() Checks whether this position is configured using the earliest position.
boolean	isLatest() Checks whether this position is configured using the latest position.

Methods inherited from class java.lang.Object

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

Method Detail

fromEarliest

public static KinesisIngressStartupPosition fromEarliest()

Start consuming from the earliest position possible.

fromLatest

public static KinesisIngressStartupPosition fromLatest()

Start consuming from the latest position, i.e. head of the stream shards.

fromDate

public static KinesisIngressStartupPosition fromDate(java.time.ZonedDateTime date)

Start consuming from position with ingestion timestamps after or equal to a specified ZonedDateTime.

isEarliest

public final boolean isEarliest()

Checks whether this position is configured using the earliest position.

isLatest

public final boolean isLatest()

Checks whether this position is configured using the latest position.

isDate

public final boolean isDate()

Checks whether this position is configured using a date.

asDate

public final KinesisIngressStartupPosition.DatePosition asDate()

Returns this position as a KinesisIngressStartupPosition.DatePosition.