Interface | Description |
---|---|
PartitionKeyGenerator<InputT> |
This is a serializable function whose
accept() method specifies how to convert from an
input element to the partition key, a string. |
Class | Description |
---|---|
KinesisStreamsConfigConstants |
Defaults for
KinesisStreamsSinkWriter . |
KinesisStreamsSink<InputT> |
A Kinesis Data Streams (KDS) Sink that performs async requests against a destination stream using
the buffering protocol specified in
AsyncSinkBase . |
KinesisStreamsSinkBuilder<InputT> |
Builder to construct
KinesisStreamsSink . |
KinesisStreamsSinkElementConverter<InputT> |
An implementation of the
ElementConverter that uses the AWS Kinesis SDK v2. |
KinesisStreamsSinkElementConverter.Builder<InputT> |
A builder for the KinesisStreamsSinkElementConverter.
|
KinesisStreamsStateSerializer |
Kinesis Streams implementation
AsyncSinkWriterStateSerializer . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.