Package | Description |
---|---|
com.amazonaws.services.kinesis | |
com.amazonaws.services.kinesis.model | |
com.amazonaws.services.kinesis.model.transform |
Modifier and Type | Method and Description |
---|---|
PutRecordResult |
AmazonKinesisClient.putRecord(PutRecordRequest putRecordRequest)
Writes a single data record into an Amazon Kinesis stream.
|
PutRecordResult |
AmazonKinesis.putRecord(PutRecordRequest putRecordRequest)
Writes a single data record into an Amazon Kinesis stream.
|
PutRecordResult |
AbstractAmazonKinesis.putRecord(PutRecordRequest request) |
java.util.concurrent.Future<PutRecordResult> |
AmazonKinesisAsyncClient.putRecordAsync(PutRecordRequest request) |
java.util.concurrent.Future<PutRecordResult> |
AmazonKinesisAsync.putRecordAsync(PutRecordRequest putRecordRequest)
Writes a single data record into an Amazon Kinesis stream.
|
java.util.concurrent.Future<PutRecordResult> |
AbstractAmazonKinesisAsync.putRecordAsync(PutRecordRequest request) |
java.util.concurrent.Future<PutRecordResult> |
AmazonKinesisAsyncClient.putRecordAsync(PutRecordRequest request,
AsyncHandler<PutRecordRequest,PutRecordResult> asyncHandler) |
java.util.concurrent.Future<PutRecordResult> |
AmazonKinesisAsync.putRecordAsync(PutRecordRequest putRecordRequest,
AsyncHandler<PutRecordRequest,PutRecordResult> asyncHandler)
Writes a single data record into an Amazon Kinesis stream.
|
java.util.concurrent.Future<PutRecordResult> |
AbstractAmazonKinesisAsync.putRecordAsync(PutRecordRequest request,
AsyncHandler<PutRecordRequest,PutRecordResult> asyncHandler) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<PutRecordResult> |
AmazonKinesisAsyncClient.putRecordAsync(PutRecordRequest request,
AsyncHandler<PutRecordRequest,PutRecordResult> asyncHandler) |
java.util.concurrent.Future<PutRecordResult> |
AmazonKinesisAsync.putRecordAsync(PutRecordRequest putRecordRequest,
AsyncHandler<PutRecordRequest,PutRecordResult> asyncHandler)
Writes a single data record into an Amazon Kinesis stream.
|
java.util.concurrent.Future<PutRecordResult> |
AbstractAmazonKinesisAsync.putRecordAsync(PutRecordRequest request,
AsyncHandler<PutRecordRequest,PutRecordResult> asyncHandler) |
java.util.concurrent.Future<PutRecordResult> |
AmazonKinesisAsyncClient.putRecordAsync(java.lang.String streamName,
java.nio.ByteBuffer data,
java.lang.String partitionKey,
AsyncHandler<PutRecordRequest,PutRecordResult> asyncHandler)
Simplified method form for invoking the PutRecord operation with an
AsyncHandler.
|
java.util.concurrent.Future<PutRecordResult> |
AmazonKinesisAsync.putRecordAsync(java.lang.String streamName,
java.nio.ByteBuffer data,
java.lang.String partitionKey,
AsyncHandler<PutRecordRequest,PutRecordResult> asyncHandler)
Simplified method form for invoking the PutRecord operation with an
AsyncHandler.
|
java.util.concurrent.Future<PutRecordResult> |
AbstractAmazonKinesisAsync.putRecordAsync(java.lang.String streamName,
java.nio.ByteBuffer data,
java.lang.String partitionKey,
AsyncHandler<PutRecordRequest,PutRecordResult> asyncHandler)
Simplified method form for invoking the PutRecord operation with an
AsyncHandler.
|
java.util.concurrent.Future<PutRecordResult> |
AmazonKinesisAsyncClient.putRecordAsync(java.lang.String streamName,
java.nio.ByteBuffer data,
java.lang.String partitionKey,
java.lang.String sequenceNumberForOrdering,
AsyncHandler<PutRecordRequest,PutRecordResult> asyncHandler)
Simplified method form for invoking the PutRecord operation with an
AsyncHandler.
|
java.util.concurrent.Future<PutRecordResult> |
AmazonKinesisAsync.putRecordAsync(java.lang.String streamName,
java.nio.ByteBuffer data,
java.lang.String partitionKey,
java.lang.String sequenceNumberForOrdering,
AsyncHandler<PutRecordRequest,PutRecordResult> asyncHandler)
Simplified method form for invoking the PutRecord operation with an
AsyncHandler.
|
java.util.concurrent.Future<PutRecordResult> |
AbstractAmazonKinesisAsync.putRecordAsync(java.lang.String streamName,
java.nio.ByteBuffer data,
java.lang.String partitionKey,
java.lang.String sequenceNumberForOrdering,
AsyncHandler<PutRecordRequest,PutRecordResult> asyncHandler)
Simplified method form for invoking the PutRecord operation with an
AsyncHandler.
|
Modifier and Type | Method and Description |
---|---|
PutRecordRequest |
PutRecordRequest.clone() |
PutRecordRequest |
PutRecordRequest.withData(java.nio.ByteBuffer data)
The data blob to put into the record, which is base64-encoded when the
blob is serialized.
|
PutRecordRequest |
PutRecordRequest.withExplicitHashKey(java.lang.String explicitHashKey)
The hash value used to explicitly determine the shard the data record is
assigned to by overriding the partition key hash.
|
PutRecordRequest |
PutRecordRequest.withPartitionKey(java.lang.String partitionKey)
Determines which shard in the stream the data record is assigned to.
|
PutRecordRequest |
PutRecordRequest.withSequenceNumberForOrdering(java.lang.String sequenceNumberForOrdering)
Guarantees strictly increasing sequence numbers, for puts from the same
client and to the same partition key.
|
PutRecordRequest |
PutRecordRequest.withStreamName(java.lang.String streamName)
The name of the stream to put the data record into.
|
Modifier and Type | Method and Description |
---|---|
Request<PutRecordRequest> |
PutRecordRequestMarshaller.marshall(PutRecordRequest putRecordRequest) |
Modifier and Type | Method and Description |
---|---|
Request<PutRecordRequest> |
PutRecordRequestMarshaller.marshall(PutRecordRequest putRecordRequest) |