org.apache.flink.table.sinks

Class CsvAppendTableSinkFactory

java.lang.Object

org.apache.flink.table.sinks.CsvTableSinkFactoryBase

org.apache.flink.table.sinks.CsvAppendTableSinkFactory

All Implemented Interfaces:

StreamTableSinkFactory<Row>, TableFactory, TableSinkFactory<Row>

@PublicEvolving
public class CsvAppendTableSinkFactory
extends CsvTableSinkFactoryBase
implements StreamTableSinkFactory<Row>

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

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.factories.TableSinkFactory

TableSinkFactory.Context

Constructor Summary

Constructors

Constructor and Description
CsvAppendTableSinkFactory()

Method Summary

Modifier and Type	Method and Description
StreamTableSink<Row>	createStreamTableSink(Map<String,String> properties) Creates and configures a StreamTableSink using the given properties.
Map<String,String>	requiredContext() Specifies the context that this factory has been implemented for.

Methods inherited from class org.apache.flink.table.sinks.CsvTableSinkFactoryBase

createTableSink, supportedProperties

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.factories.StreamTableSinkFactory

createTableSink

Methods inherited from interface org.apache.flink.table.factories.TableSinkFactory

createTableSink, createTableSink

Methods inherited from interface org.apache.flink.table.factories.TableFactory

supportedProperties

Constructor Detail

CsvAppendTableSinkFactory

public CsvAppendTableSinkFactory()

Method Detail

requiredContext

public Map<String,String> requiredContext()

Description copied from interface: TableFactory

Specifies the context that this factory has been implemented for. The framework guarantees to only match for this factory if the specified set of properties and values are met.

Typical properties might be: - connector.type - format.type

Specified property versions allow the framework to provide backwards compatible properties in case of string format changes: - connector.property-version - format.property-version

An empty context means that the factory matches for all requests.

Specified by:

requiredContext in interface TableFactory

Overrides:

requiredContext in class CsvTableSinkFactoryBase

createStreamTableSink

public StreamTableSink<Row> createStreamTableSink(Map<String,String> properties)

Description copied from interface: StreamTableSinkFactory

Creates and configures a StreamTableSink using the given properties.

Specified by:

createStreamTableSink in interface StreamTableSinkFactory<Row>

Parameters:

properties - normalized properties describing a table sink.

Returns:

the configured table sink.