Class and Description |
---|
StreamShardHandle
A wrapper class around the information provided along with streamName and
Shard , with some extra utility methods to determine whether
or not a shard is closed and whether or not the shard is a result of parent shard splits or
merges. |
Class and Description |
---|
SentinelSequenceNumber
Special flag values for sequence numbers in shards to indicate special positions.
|
Class and Description |
---|
KinesisStreamShardState
A wrapper class that bundles a
StreamShardHandle with its last processed sequence number. |
SequenceNumber
A serializable representation of a Kinesis record's sequence number.
|
StreamShardHandle
A wrapper class around the information provided along with streamName and
Shard , with some extra utility methods to determine whether
or not a shard is closed and whether or not the shard is a result of parent shard splits or
merges. |
StreamShardMetadata
A serializable representation of a AWS Kinesis Stream shard.
|
Class and Description |
---|
SequenceNumber
A serializable representation of a Kinesis record's sequence number.
|
StartingPosition
The position in which to start consuming from a stream.
|
StreamShardHandle
A wrapper class around the information provided along with streamName and
Shard , with some extra utility methods to determine whether
or not a shard is closed and whether or not the shard is a result of parent shard splits or
merges. |
Class and Description |
---|
StartingPosition
The position in which to start consuming from a stream.
|
StreamShardHandle
A wrapper class around the information provided along with streamName and
Shard , with some extra utility methods to determine whether
or not a shard is closed and whether or not the shard is a result of parent shard splits or
merges. |
Class and Description |
---|
StartingPosition
The position in which to start consuming from a stream.
|
StreamShardHandle
A wrapper class around the information provided along with streamName and
Shard , with some extra utility methods to determine whether
or not a shard is closed and whether or not the shard is a result of parent shard splits or
merges. |
Class and Description |
---|
KinesisStreamShard
Deprecated.
Will be remove in a future version in favor of
StreamShardHandle . |
SentinelSequenceNumber
Special flag values for sequence numbers in shards to indicate special positions.
|
SequenceNumber
A serializable representation of a Kinesis record's sequence number.
|
StartingPosition
The position in which to start consuming from a stream.
|
StreamShardHandle
A wrapper class around the information provided along with streamName and
Shard , with some extra utility methods to determine whether
or not a shard is closed and whether or not the shard is a result of parent shard splits or
merges. |
StreamShardMetadata
A serializable representation of a AWS Kinesis Stream shard.
|
Class and Description |
---|
StreamShardHandle
A wrapper class around the information provided along with streamName and
Shard , with some extra utility methods to determine whether
or not a shard is closed and whether or not the shard is a result of parent shard splits or
merges. |
Class and Description |
---|
SequenceNumber
A serializable representation of a Kinesis record's sequence number.
|
StartingPosition
The position in which to start consuming from a stream.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.