Modifier and Type | Class and Description |
---|---|
class |
AsyncSinkBase<InputT,RequestEntryT extends Serializable>
A generic sink for destinations that provide an async client to persist data.
|
Modifier and Type | Class and Description |
---|---|
class |
FileSink<IN>
A unified sink that emits its input elements to
FileSystem files within buckets. |
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 |
KafkaSink<IN>
Flink Sink to produce data into a Kafka topic.
|
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.