Package org.apache.flink.connector.file.table

Class FileSystemTableFactory

  • All Implemented Interfaces:
    org.apache.flink.table.factories.DynamicTableFactory, org.apache.flink.table.factories.DynamicTableSinkFactory, org.apache.flink.table.factories.DynamicTableSourceFactory, org.apache.flink.table.factories.Factory
    @Internal
public class FileSystemTableFactory
extends Object
implements org.apache.flink.table.factories.DynamicTableSourceFactory, org.apache.flink.table.factories.DynamicTableSinkFactory
    File system TableFactory.

    1.The partition information should be in the file system path, whether it's a temporary table or a catalog table. 2.Support insert into (append) and insert overwrite. 3.Support static and dynamic partition inserting.

    • Constructor Detail

      • FileSystemTableFactory

        public FileSystemTableFactory()

    • Method Detail

      • factoryIdentifier

        public String factoryIdentifier()
        Specified by:
        factoryIdentifier in interface org.apache.flink.table.factories.Factory

      • createDynamicTableSource

        public org.apache.flink.table.connector.source.DynamicTableSource createDynamicTableSource​(org.apache.flink.table.factories.DynamicTableFactory.Context context)
        Specified by:
        createDynamicTableSource in interface org.apache.flink.table.factories.DynamicTableSourceFactory

      • createDynamicTableSink

        public org.apache.flink.table.connector.sink.DynamicTableSink createDynamicTableSink​(org.apache.flink.table.factories.DynamicTableFactory.Context context)
        Specified by:
        createDynamicTableSink in interface org.apache.flink.table.factories.DynamicTableSinkFactory

      • requiredOptions

        public Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()
        Specified by:
        requiredOptions in interface org.apache.flink.table.factories.Factory

      • optionalOptions

        public Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()
        Specified by:
        optionalOptions in interface org.apache.flink.table.factories.Factory

      • forwardOptions

        public Set<org.apache.flink.configuration.ConfigOption<?>> forwardOptions()
        Specified by:
        forwardOptions in interface org.apache.flink.table.factories.DynamicTableFactory

      • validate

        protected void validate​(org.apache.flink.table.factories.FactoryUtil.TableFactoryHelper helper)

      • discoverDecodingFormat

        protected <I,​F extends org.apache.flink.table.factories.DecodingFormatFactory<I>> org.apache.flink.table.connector.format.DecodingFormat<I> discoverDecodingFormat​(org.apache.flink.table.factories.DynamicTableFactory.Context context,
                                                                                                                                                                         Class<F> formatFactoryClass)

      • validateTimeZone

        protected void validateTimeZone​(String zone)
        Similar logic as for TableConfig.