Class LookupRuntimeProviderContext
- java.lang.Object
-
- org.apache.flink.table.runtime.connector.source.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 ofDynamicTableSource.Context.
-
-
Constructor Summary
Constructors Constructor Description LookupRuntimeProviderContext(int[][] lookupKeys)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.flink.table.connector.source.DynamicTableSource.DataStructureConvertercreateDataStructureConverter(org.apache.flink.table.types.DataType producedDataType)org.apache.flink.api.common.typeinfo.TypeInformation<?>createTypeInformation(org.apache.flink.table.types.DataType producedDataType)org.apache.flink.api.common.typeinfo.TypeInformation<?>createTypeInformation(org.apache.flink.table.types.logical.LogicalType producedLogicalType)int[][]getKeys()
-
-
-
Method Detail
-
getKeys
public int[][] getKeys()
- Specified by:
getKeysin interfaceorg.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:
createTypeInformationin interfaceorg.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:
createTypeInformationin interfaceorg.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:
createDataStructureConverterin interfaceorg.apache.flink.table.connector.source.DynamicTableSource.Context
-
-