Package | Description |
---|---|
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.transformations |
Modifier and Type | Field and Description |
---|---|
static CustomSinkOperatorUidHashes |
CustomSinkOperatorUidHashes.DEFAULT
Default instance providing no custom sink operator hashes.
|
Modifier and Type | Method and Description |
---|---|
CustomSinkOperatorUidHashes |
CustomSinkOperatorUidHashes.SinkOperatorUidHashesBuilder.build()
Constructs the
CustomSinkOperatorUidHashes with the given uid hashes. |
Modifier and Type | Method and Description |
---|---|
static <T> DataStreamSink<T> |
DataStreamSink.forSink(DataStream<T> inputStream,
Sink<T> sink,
CustomSinkOperatorUidHashes customSinkOperatorUidHashes) |
static <T> DataStreamSink<T> |
DataStreamSink.forSinkV1(DataStream<T> inputStream,
Sink<T,?,?,?> sink,
CustomSinkOperatorUidHashes customSinkOperatorUidHashes) |
DataStreamSink<T> |
DataStream.sinkTo(Sink<T,?,?,?> sink,
CustomSinkOperatorUidHashes customSinkOperatorUidHashes)
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 |
---|---|
CustomSinkOperatorUidHashes |
SinkTransformation.getSinkOperatorsUidHashes() |
Constructor and Description |
---|
SinkTransformation(DataStream<InputT> inputStream,
Sink<InputT> sink,
TypeInformation<OutputT> outputType,
String name,
int parallelism,
CustomSinkOperatorUidHashes customSinkOperatorUidHashes) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.