Class | Description |
---|---|
KinesisFirehoseConfigConstants |
Defaults for
KinesisFirehoseSinkWriter . |
KinesisFirehoseSink<InputT> |
A Kinesis Data Firehose (KDF) Sink that performs async requests against a destination delivery
stream using the buffering protocol specified in
AsyncSinkBase . |
KinesisFirehoseSinkBuilder<InputT> |
Builder to construct
KinesisFirehoseSink . |
KinesisFirehoseSinkElementConverter<InputT> |
An implementation of the
ElementConverter that uses the AWS Kinesis SDK v2. |
KinesisFirehoseSinkElementConverter.Builder<InputT> |
A builder for the KinesisFirehoseSinkElementConverter.
|
KinesisFirehoseStateSerializer |
Kinesis Firehose implementation
AsyncSinkWriterStateSerializer . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.