org.apache.flink.table.sinks

接口 StreamTableSink<T>

类型参数:

T - Type of the DataStream created by this TableSink.

所有超级接口:

org.apache.flink.table.sinks.TableSink<T>

所有已知子接口:

AppendStreamTableSink<T>, RetractStreamTableSink<T>, UpsertStreamTableSink<T>

所有已知实现类:

CsvTableSink, OutputFormatTableSink

已过时。

This interface has been replaced by DynamicTableSink. The new interface consumes internal data structures. See FLIP-95 for more information.

@Deprecated
public interface StreamTableSink<T>
extends org.apache.flink.table.sinks.TableSink<T>

Defines an external stream table and provides write access to its data.

方法概要

限定符和类型	方法和说明
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	consumeDataStream(org.apache.flink.streaming.api.datastream.DataStream<T> dataStream) 已过时。 Consumes the DataStream and return the sink transformation DataStreamSink.

从接口继承的方法 org.apache.flink.table.sinks.TableSink

configure, getConsumedDataType, getFieldNames, getFieldTypes, getOutputType, getTableSchema

方法详细资料

consumeDataStream

org.apache.flink.streaming.api.datastream.DataStreamSink<?> consumeDataStream(org.apache.flink.streaming.api.datastream.DataStream<T> dataStream)

已过时。

Consumes the DataStream and return the sink transformation DataStreamSink. The returned DataStreamSink will be used to set resources for the sink operator.