Modifier and Type | Method and Description |
---|---|
Sink<T,?,?,?> |
DataStreamSinkV1ExternalContext.createSink(TestingSinkSettings sinkSettings)
Create an instance of
Sink satisfying given options. |
Modifier and Type | Method and Description |
---|---|
static <T> DataStreamSink<T> |
DataStreamSink.forSinkV1(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 |
---|---|
static <InputT> Sink<InputT> |
SinkV1Adapter.wrap(Sink<InputT,?,?,?> sink) |
Modifier and Type | Method and Description |
---|---|
Sink<RowData,?,?,?> |
SinkProvider.createSink()
Deprecated.
Creates a
Sink instance. |
Modifier and Type | Method and Description |
---|---|
static SinkProvider |
SinkProvider.of(Sink<RowData,?,?,?> sink)
Deprecated.
Helper method for creating a static provider.
|
static SinkProvider |
SinkProvider.of(Sink<RowData,?,?,?> sink,
Integer sinkParallelism)
Deprecated.
Helper method for creating a Sink provider with a provided sink parallelism.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.