Package org.apache.flink.table.sources
Class CsvTableSourceFactoryBase
- java.lang.Object
-
- org.apache.flink.table.sources.CsvTableSourceFactoryBase
-
- All Implemented Interfaces:
org.apache.flink.table.factories.TableFactory
- Direct Known Subclasses:
CsvAppendTableSourceFactory,CsvBatchTableSourceFactory
@Internal @Deprecated public abstract class CsvTableSourceFactoryBase extends Object implements org.apache.flink.table.factories.TableFactory
Deprecated.The legacy CSV connector has been replaced byFileSource. It is kept only to support tests for the legacy connector stack.Factory base for creating configured instances ofCsvTableSource.
-
-
Constructor Summary
Constructors Constructor Description CsvTableSourceFactoryBase()Deprecated.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description protected CsvTableSourcecreateTableSource(Boolean isStreaming, Map<String,String> properties)Deprecated.static List<org.apache.flink.table.types.logical.LogicalType>getFieldLogicalTypes(org.apache.flink.table.api.TableSchema schema)Deprecated.Map<String,String>requiredContext()Deprecated.List<String>supportedProperties()Deprecated.
-
-
-
Method Detail
-
requiredContext
public Map<String,String> requiredContext()
Deprecated.- Specified by:
requiredContextin interfaceorg.apache.flink.table.factories.TableFactory
-
supportedProperties
public List<String> supportedProperties()
Deprecated.- Specified by:
supportedPropertiesin interfaceorg.apache.flink.table.factories.TableFactory
-
createTableSource
protected CsvTableSource createTableSource(Boolean isStreaming, Map<String,String> properties)
Deprecated.
-
getFieldLogicalTypes
public static List<org.apache.flink.table.types.logical.LogicalType> getFieldLogicalTypes(org.apache.flink.table.api.TableSchema schema)
Deprecated.
-
-