org.apache.flink.table.sources

Class CsvAppendTableSourceFactory

java.lang.Object

org.apache.flink.table.sources.CsvTableSourceFactoryBase

org.apache.flink.table.sources.CsvAppendTableSourceFactory

All Implemented Interfaces:

StreamTableSourceFactory<Row>, TableFactory, TableSourceFactory<Row>

Deprecated.

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

@Internal
public class CsvAppendTableSourceFactory
extends CsvTableSourceFactoryBase
implements StreamTableSourceFactory<Row>

Factory for creating configured instances of CsvTableSource in a stream environment.

Nested Class Summary

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

TableSourceFactory.Context

Constructor Summary

Constructors

Constructor and Description
CsvAppendTableSourceFactory() Deprecated.

Method Summary

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

Methods inherited from class org.apache.flink.table.sources.CsvTableSourceFactoryBase

createTableSource, getFieldLogicalTypes, 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.StreamTableSourceFactory

createTableSource

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

createTableSource, createTableSource

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

supportedProperties

Constructor Detail

CsvAppendTableSourceFactory

public CsvAppendTableSourceFactory()

Deprecated.

Method Detail

requiredContext

public Map<String,String> requiredContext()

Deprecated.

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 CsvTableSourceFactoryBase

createStreamTableSource

public StreamTableSource<Row> createStreamTableSource(Map<String,String> properties)

Deprecated.

Description copied from interface: StreamTableSourceFactory

Creates and configures a StreamTableSource using the given properties.

Specified by:

createStreamTableSource in interface StreamTableSourceFactory<Row>

Parameters:

properties - normalized properties describing a stream table source.

Returns:

the configured stream table source.