org.apache.flink.table.sinks

类 CsvBatchTableSinkFactory

java.lang.Object

org.apache.flink.table.sinks.CsvTableSinkFactoryBase

org.apache.flink.table.sinks.CsvBatchTableSinkFactory

所有已实现的接口:

StreamTableSinkFactory<org.apache.flink.types.Row>, org.apache.flink.table.factories.TableFactory, org.apache.flink.table.factories.TableSinkFactory<org.apache.flink.types.Row>

已过时。

The legacy CSV connector has been replaced by FileSink. It is kept only to support tests for the legacy connector stack.

@Internal
 @Deprecated
public class CsvBatchTableSinkFactory
extends CsvTableSinkFactoryBase
implements StreamTableSinkFactory<org.apache.flink.types.Row>

Factory base for creating configured instances of CsvTableSink in a batch environment.

嵌套类概要

从接口继承的嵌套类/接口 org.apache.flink.table.factories.TableSinkFactory

org.apache.flink.table.factories.TableSinkFactory.Context

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
StreamTableSink<org.apache.flink.types.Row>	createStreamTableSink(Map<String,String> properties) 已过时。 Creates and configures a StreamTableSink using the given properties.

从类继承的方法 org.apache.flink.table.sinks.CsvTableSinkFactoryBase

createTableSink, requiredContext, supportedProperties

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

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

从接口继承的方法 org.apache.flink.table.factories.StreamTableSinkFactory

createTableSink

从接口继承的方法 org.apache.flink.table.factories.TableSinkFactory

createTableSink, createTableSink

从接口继承的方法 org.apache.flink.table.factories.TableFactory

requiredContext, supportedProperties

构造器详细资料

CsvBatchTableSinkFactory

public CsvBatchTableSinkFactory()

已过时。

方法详细资料

createStreamTableSink

public StreamTableSink<org.apache.flink.types.Row> createStreamTableSink(Map<String,String> properties)

已过时。

从接口复制的说明: StreamTableSinkFactory

Creates and configures a StreamTableSink using the given properties.

指定者:

createStreamTableSink 在接口中 StreamTableSinkFactory<org.apache.flink.types.Row>

参数:

properties - normalized properties describing a table sink.

返回:

the configured table sink.