Class LookupRuntimeProviderContext

  • All Implemented Interfaces:
    org.apache.flink.table.connector.source.DynamicTableSource.Context, org.apache.flink.table.connector.source.LookupTableSource.LookupContext

    @Internal
    public final class LookupRuntimeProviderContext
    extends Object
    implements org.apache.flink.table.connector.source.LookupTableSource.LookupContext
    Implementation of DynamicTableSource.Context.
    • Constructor Detail

      • LookupRuntimeProviderContext

        public LookupRuntimeProviderContext​(int[][] lookupKeys)
    • Method Detail

      • getKeys

        public int[][] getKeys()
        Specified by:
        getKeys in interface org.apache.flink.table.connector.source.LookupTableSource.LookupContext
      • createTypeInformation

        public org.apache.flink.api.common.typeinfo.TypeInformation<?> createTypeInformation​(org.apache.flink.table.types.DataType producedDataType)
        Specified by:
        createTypeInformation in interface org.apache.flink.table.connector.source.DynamicTableSource.Context
      • createTypeInformation

        public org.apache.flink.api.common.typeinfo.TypeInformation<?> createTypeInformation​(org.apache.flink.table.types.logical.LogicalType producedLogicalType)
        Specified by:
        createTypeInformation in interface org.apache.flink.table.connector.source.DynamicTableSource.Context
      • createDataStructureConverter

        public org.apache.flink.table.connector.source.DynamicTableSource.DataStructureConverter createDataStructureConverter​(org.apache.flink.table.types.DataType producedDataType)
        Specified by:
        createDataStructureConverter in interface org.apache.flink.table.connector.source.DynamicTableSource.Context