Class FlinkDynamicTableFactory

  • 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

    public class FlinkDynamicTableFactory
    extends java.lang.Object
    implements org.apache.flink.table.factories.DynamicTableSinkFactory, org.apache.flink.table.factories.DynamicTableSourceFactory
    • Nested Class Summary

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

        org.apache.flink.table.factories.DynamicTableFactory.Context
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.flink.table.connector.sink.DynamicTableSink createDynamicTableSink​(org.apache.flink.table.factories.DynamicTableFactory.Context context)  
      org.apache.flink.table.connector.source.DynamicTableSource createDynamicTableSource​(org.apache.flink.table.factories.DynamicTableFactory.Context context)  
      java.lang.String factoryIdentifier()  
      java.util.Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()  
      java.util.Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()  
      • 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.DynamicTableFactory

        forwardOptions
    • Constructor Detail

      • FlinkDynamicTableFactory

        public FlinkDynamicTableFactory()
      • FlinkDynamicTableFactory

        public FlinkDynamicTableFactory​(FlinkCatalog catalog)
    • 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
      • 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 java.util.Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()
        Specified by:
        requiredOptions in interface org.apache.flink.table.factories.Factory
      • optionalOptions

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

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