org.apache.flink.table.sinks

类 CsvAppendTableSinkFactory

java.lang.Object

org.apache.flink.table.sinks.CsvTableSinkFactoryBase

org.apache.flink.table.sinks.CsvAppendTableSinkFactory

所有已实现的接口:

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 CsvAppendTableSinkFactory
extends CsvTableSinkFactoryBase
implements StreamTableSinkFactory<org.apache.flink.types.Row>

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

嵌套类概要

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

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

构造器概要

构造器

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

方法概要

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

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

createTableSink, 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

supportedProperties

构造器详细资料

CsvAppendTableSinkFactory

public CsvAppendTableSinkFactory()

已过时。

方法详细资料

requiredContext

public Map<String,String> requiredContext()

已过时。

指定者:

requiredContext 在接口中 org.apache.flink.table.factories.TableFactory

覆盖:

requiredContext 在类中 CsvTableSinkFactoryBase

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.