@PublicEvolving public interface DataStreamSinkProvider extends DynamicTableSink.SinkRuntimeProvider
DataStream
as a runtime implementation for DynamicTableSink
.
Note: This provider is only meant for advanced connector developers. Usually, a sink should
consist of a single entity expressed via OutputFormatProvider
or SinkFunctionProvider
.
Modifier and Type | Method and Description |
---|---|
DataStreamSink<?> |
consumeDataStream(DataStream<RowData> dataStream)
Consumes the given Java
DataStream and returns the sink transformation DataStreamSink . |
DataStreamSink<?> consumeDataStream(DataStream<RowData> dataStream)
DataStream
and returns the sink transformation DataStreamSink
.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.