org.apache.flink.table.sinks

类 OutputFormatTableSink<T>

java.lang.Object

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

类型参数:

T - Type of the bounded OutputFormat that this TableSink expects and supports.

所有已实现的接口:

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

已过时。

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

@Deprecated
 @Experimental
public abstract class OutputFormatTableSink<T>
extends Object
implements StreamTableSink<T>

Defines an external TableSink to emit a bounded Table.

构造器概要

构造器

构造器和说明
OutputFormatTableSink() 已过时。

方法概要

限定符和类型	方法和说明
org.apache.flink.streaming.api.datastream.DataStreamSink<T>	consumeDataStream(org.apache.flink.streaming.api.datastream.DataStream<T> dataStream) 已过时。 Consumes the DataStream and return the sink transformation DataStreamSink.
abstract org.apache.flink.api.common.io.OutputFormat<T>	getOutputFormat() 已过时。 Returns an OutputFormat for writing the data of the table.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

configure, getConsumedDataType, getFieldNames, getFieldTypes, getOutputType, getTableSchema

构造器详细资料

OutputFormatTableSink

public OutputFormatTableSink()

已过时。

方法详细资料

getOutputFormat

public abstract org.apache.flink.api.common.io.OutputFormat<T> getOutputFormat()

已过时。

Returns an OutputFormat for writing the data of the table.

consumeDataStream

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

已过时。

从接口复制的说明: StreamTableSink

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

指定者:

consumeDataStream 在接口中 StreamTableSink<T>