Modifier and Type | Interface and Description |
---|---|
interface |
StatefulSink<InputT,WriterStateT>
A
Sink with a stateful SinkWriter . |
interface |
TwoPhaseCommittingSink<InputT,CommT>
A
Sink for exactly-once semantics using a two-phase commit protocol. |
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 . |
Modifier and Type | Class and Description |
---|---|
class |
PulsarSink<IN>
The Sink implementation of Pulsar.
|
Modifier and Type | Method and Description |
---|---|
Sink<T> |
DataStreamSinkV2ExternalContext.createSink(TestingSinkSettings sinkSettings)
Create an instance of
Sink satisfying given options. |
Modifier and Type | Class and Description |
---|---|
class |
UpsertTestSink<IN>
Flink Sink to upsert test data into a file.
|
Modifier and Type | Interface and Description |
---|---|
interface |
WithPostCommitTopology<InputT,CommT>
Allows expert users to implement a custom topology after
Committer . |
interface |
WithPreCommitTopology<InputT,CommT>
Allows expert users to implement a custom topology after
SinkWriter and before Committer . |
interface |
WithPreWriteTopology<InputT>
Allows expert users to implement a custom topology before
SinkWriter . |
Modifier and Type | Method and Description |
---|---|
static <T> DataStreamSink<T> |
DataStreamSink.forSink(DataStream<T> inputStream,
Sink<T> sink,
CustomSinkOperatorUidHashes customSinkOperatorUidHashes) |
DataStreamSink<T> |
DataStream.sinkTo(Sink<T> sink)
Adds the given
Sink to this DataStream. |
DataStreamSink<T> |
DataStream.sinkTo(Sink<T> sink,
CustomSinkOperatorUidHashes customSinkOperatorUidHashes)
Adds the given
Sink to this DataStream. |
Modifier and Type | Class and Description |
---|---|
class |
PrintSink<IN>
Sink implementation writing every element to the standard output or standard error stream.
|
Modifier and Type | Class and Description |
---|---|
class |
SinkV1Adapter<InputT,CommT,WriterStateT,GlobalCommT>
Translates Sink V1 into Sink V2.
|
Modifier and Type | Method and Description |
---|---|
Sink<InputT> |
SinkV1Adapter.asSpecializedSink() |
Sink<InputT> |
SinkTransformation.getSink() |
static <InputT> Sink<InputT> |
SinkV1Adapter.wrap(Sink<InputT,?,?,?> sink) |
Constructor and Description |
---|
SinkTransformation(DataStream<InputT> inputStream,
Sink<InputT> sink,
TypeInformation<OutputT> outputType,
String name,
int parallelism,
CustomSinkOperatorUidHashes customSinkOperatorUidHashes) |
Modifier and Type | Method and Description |
---|---|
Sink<InputT> |
SinkWriterOperatorFactory.getSink() |
Constructor and Description |
---|
SinkWriterOperatorFactory(Sink<InputT> sink) |
Modifier and Type | Method and Description |
---|---|
Sink<RowData> |
SinkV2Provider.createSink() |
Modifier and Type | Method and Description |
---|---|
static SinkV2Provider |
SinkV2Provider.of(Sink<RowData> sink)
Helper method for creating a static provider.
|
static SinkV2Provider |
SinkV2Provider.of(Sink<RowData> sink,
Integer sinkParallelism)
Helper method for creating a Sink provider with a provided sink parallelism.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.