@PublicEvolving public interface SinkFunctionProvider extends DynamicTableSink.SinkRuntimeProvider
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)
SinkFunction<RowData> createSinkFunction()
SinkFunction
instance.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.