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 | Method and Description |
---|---|
Sink<T> |
DataStreamSinkV2ExternalContext.createSink(TestingSinkSettings sinkSettings)
Create an instance of
Sink satisfying given options. |
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 | 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–2023 The Apache Software Foundation. All rights reserved.