Class Db2TableSourceFactory

  • All Implemented Interfaces:
    org.apache.flink.table.factories.DynamicTableFactory, org.apache.flink.table.factories.DynamicTableSourceFactory, org.apache.flink.table.factories.Factory

    public class Db2TableSourceFactory
    extends Object
    implements org.apache.flink.table.factories.DynamicTableSourceFactory
    Table source factory for DB2 CDC connector.
    • Field Detail

      • SCAN_STARTUP_MODE

        public static final org.apache.flink.configuration.ConfigOption<String> SCAN_STARTUP_MODE
    • Constructor Detail

      • Db2TableSourceFactory

        public Db2TableSourceFactory()
    • Method Detail

      • 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
      • factoryIdentifier

        public String factoryIdentifier()
        Specified by:
        factoryIdentifier in interface org.apache.flink.table.factories.Factory
      • 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