Class KinesisShardOffset
java.lang.Object
org.springframework.integration.aws.inbound.kinesis.KinesisShardOffset
A model to represent a sequence in the shard for particular
ShardIteratorType.- Since:
- 1.1
- Author:
- Artem Bilan
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic KinesisShardOffsetafterSequenceNumber(String sequenceNumber) static KinesisShardOffsetafterSequenceNumber(String stream, String shard, String sequenceNumber) static KinesisShardOffsetatSequenceNumber(String sequenceNumber) static KinesisShardOffsetatSequenceNumber(String stream, String shard, String sequenceNumber) static KinesisShardOffsetatTimestamp(String stream, String shard, Date timestamp) static KinesisShardOffsetatTimestamp(Date timestamp) booleangetShard()inthashCode()booleanisReset()static KinesisShardOffsetlatest()static KinesisShardOffsetreset()voidsetIteratorType(ShardIteratorType iteratorType) voidsetReset(boolean reset) voidsetSequenceNumber(String sequenceNumber) voidvoidvoidsetTimestamp(Date timestamp) toString()static KinesisShardOffsetstatic KinesisShardOffsettrimHorizon(String stream, String shard)
-
Constructor Details
-
KinesisShardOffset
-
KinesisShardOffset
-
-
Method Details
-
setIteratorType
-
getIteratorType
-
setSequenceNumber
-
setTimestamp
-
setStream
-
setShard
-
setReset
public void setReset(boolean reset) -
getSequenceNumber
-
getTimestamp
-
getStream
-
getShard
-
isReset
public boolean isReset() -
reset
-
toShardIteratorRequest
-
equals
-
hashCode
public int hashCode() -
toString
-
latest
-
latest
-
trimHorizon
-
trimHorizon
-
atSequenceNumber
-
atSequenceNumber
public static KinesisShardOffset atSequenceNumber(String stream, String shard, String sequenceNumber) -
afterSequenceNumber
-
afterSequenceNumber
public static KinesisShardOffset afterSequenceNumber(String stream, String shard, String sequenceNumber) -
atTimestamp
-
atTimestamp
-