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 | Method and Description |
---|---|
DataStreamSink<T> |
DataStream.sinkTo(Sink<T,?,?,?> sink)
Adds the given
Sink to this DataStream. |
Constructor and Description |
---|
DataStreamSink(DataStream<T> inputStream,
Sink<T,?,?,?> sink) |
Modifier and Type | Method and Description |
---|---|
Sink<InputT,CommT,WriterStateT,GlobalCommT> |
SinkTransformation.getSink() |
Constructor and Description |
---|
SinkTransformation(Transformation<InputT> input,
Sink<InputT,CommT,WriterStateT,GlobalCommT> sink,
String name,
int parallelism) |
Constructor and Description |
---|
BatchCommitterOperatorFactory(Sink<?,CommT,?,?> sink) |
BatchGlobalCommitterOperatorFactory(Sink<?,CommT,?,GlobalCommT> sink) |
StatefulSinkWriterOperatorFactory(Sink<InputT,CommT,WriterStateT,?> sink) |
StatefulSinkWriterOperatorFactory(Sink<InputT,CommT,WriterStateT,?> sink,
String previousSinkStateName) |
StatelessSinkWriterOperatorFactory(Sink<InputT,CommT,?,?> sink) |
StreamingCommitterOperatorFactory(Sink<?,CommT,?,?> sink) |
StreamingGlobalCommitterOperatorFactory(Sink<?,CommT,?,GlobalCommT> sink) |
Modifier and Type | Method and Description |
---|---|
Sink<RowData,?,?,?> |
SinkProvider.createSink()
Creates a
Sink instance. |
Modifier and Type | Method and Description |
---|---|
static SinkProvider |
SinkProvider.of(Sink<RowData,?,?,?> sink)
Helper method for creating a static provider.
|
static SinkProvider |
SinkProvider.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.