@PublicEvolving public interface SinkFunctionProvider extends DynamicTableSink.SinkRuntimeProvider, ParallelismProvider
SinkFunction
instance as a runtime implementation for DynamicTableSink
.Modifier and Type | Method and Description |
---|---|
SinkFunction<RowData> |
createSinkFunction()
Creates a
SinkFunction instance. |
static SinkFunctionProvider |
of(SinkFunction<RowData> sinkFunction)
Helper method for creating a static provider.
|
static SinkFunctionProvider |
of(SinkFunction<RowData> sinkFunction,
Integer sinkParallelism)
Helper method for creating a SinkFunction provider with a provided sink parallelism.
|
getParallelism
static SinkFunctionProvider of(SinkFunction<RowData> sinkFunction)
static SinkFunctionProvider of(SinkFunction<RowData> sinkFunction, @Nullable Integer sinkParallelism)
SinkFunction<RowData> createSinkFunction()
SinkFunction
instance.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.