Package | Description |
---|---|
com.amazonaws.services.kinesis | |
com.amazonaws.services.kinesis.model | |
com.amazonaws.services.kinesis.model.transform |
Modifier and Type | Method and Description |
---|---|
GetRecordsResult |
AmazonKinesisClient.getRecords(GetRecordsRequest getRecordsRequest)
Gets data records from an Amazon Kinesis stream's shard.
|
GetRecordsResult |
AmazonKinesis.getRecords(GetRecordsRequest getRecordsRequest)
Gets data records from an Amazon Kinesis stream's shard.
|
GetRecordsResult |
AbstractAmazonKinesis.getRecords(GetRecordsRequest request) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<GetRecordsResult> |
AmazonKinesisAsyncClient.getRecordsAsync(GetRecordsRequest request) |
java.util.concurrent.Future<GetRecordsResult> |
AmazonKinesisAsync.getRecordsAsync(GetRecordsRequest getRecordsRequest)
Gets data records from an Amazon Kinesis stream's shard.
|
java.util.concurrent.Future<GetRecordsResult> |
AbstractAmazonKinesisAsync.getRecordsAsync(GetRecordsRequest request) |
java.util.concurrent.Future<GetRecordsResult> |
AmazonKinesisAsyncClient.getRecordsAsync(GetRecordsRequest request,
AsyncHandler<GetRecordsRequest,GetRecordsResult> asyncHandler) |
java.util.concurrent.Future<GetRecordsResult> |
AmazonKinesisAsync.getRecordsAsync(GetRecordsRequest getRecordsRequest,
AsyncHandler<GetRecordsRequest,GetRecordsResult> asyncHandler)
Gets data records from an Amazon Kinesis stream's shard.
|
java.util.concurrent.Future<GetRecordsResult> |
AbstractAmazonKinesisAsync.getRecordsAsync(GetRecordsRequest request,
AsyncHandler<GetRecordsRequest,GetRecordsResult> asyncHandler) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<GetRecordsResult> |
AmazonKinesisAsyncClient.getRecordsAsync(GetRecordsRequest request,
AsyncHandler<GetRecordsRequest,GetRecordsResult> asyncHandler) |
java.util.concurrent.Future<GetRecordsResult> |
AmazonKinesisAsync.getRecordsAsync(GetRecordsRequest getRecordsRequest,
AsyncHandler<GetRecordsRequest,GetRecordsResult> asyncHandler)
Gets data records from an Amazon Kinesis stream's shard.
|
java.util.concurrent.Future<GetRecordsResult> |
AbstractAmazonKinesisAsync.getRecordsAsync(GetRecordsRequest request,
AsyncHandler<GetRecordsRequest,GetRecordsResult> asyncHandler) |
Modifier and Type | Method and Description |
---|---|
GetRecordsResult |
GetRecordsResult.clone() |
GetRecordsResult |
GetRecordsResult.withMillisBehindLatest(java.lang.Long millisBehindLatest)
The number of milliseconds the GetRecords response is from the tip
of the stream, indicating how far behind current time the consumer is.
|
GetRecordsResult |
GetRecordsResult.withNextShardIterator(java.lang.String nextShardIterator)
The next position in the shard from which to start sequentially reading
data records.
|
GetRecordsResult |
GetRecordsResult.withRecords(java.util.Collection<Record> records)
The data records retrieved from the shard.
|
GetRecordsResult |
GetRecordsResult.withRecords(Record... records)
The data records retrieved from the shard.
|
Modifier and Type | Method and Description |
---|---|
GetRecordsResult |
GetRecordsResultJsonUnmarshaller.unmarshall(JsonUnmarshallerContext context) |