Package | Description |
---|---|
org.apache.flink.connector.base.sink | |
org.apache.flink.connector.firehose.sink | |
org.apache.flink.connector.kinesis.sink |
Modifier and Type | Method and Description |
---|---|
abstract AsyncSinkBase<InputT,RequestEntryT> |
AsyncSinkBaseBuilder.build()
Builds the Sink with the settings applied to this builder.
|
Modifier and Type | Class and Description |
---|---|
class |
KinesisFirehoseSink<InputT>
A Kinesis Data Firehose (KDF) Sink that performs async requests against a destination delivery
stream using the buffering protocol specified in
AsyncSinkBase . |
Modifier and Type | Class and Description |
---|---|
class |
KinesisStreamsSink<InputT>
A Kinesis Data Streams (KDS) Sink that performs async requests against a destination stream using
the buffering protocol specified in
AsyncSinkBase . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.