Interface LookupTableSource.LookupContext
-
- All Superinterfaces:
DynamicTableSource.Context
- All Known Implementing Classes:
LookupRuntimeProviderContext
- Enclosing interface:
- LookupTableSource
@PublicEvolving public static interface LookupTableSource.LookupContext extends DynamicTableSource.Context
Context for creating runtime implementation via aLookupTableSource.LookupRuntimeProvider
.It offers utilities by the planner for creating runtime implementation with minimal dependencies to internal data structures.
Methods should be called in
LookupTableSource.getLookupRuntimeProvider(LookupContext)
. Returned instances that areSerializable
can be directly passed into the runtime implementation class.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description int[][]
getKeys()
Returns an array of key index paths that should be used during the lookup.-
Methods inherited from interface org.apache.flink.table.connector.source.DynamicTableSource.Context
createDataStructureConverter, createTypeInformation, createTypeInformation
-
-
-
-
Method Detail
-
getKeys
int[][] getKeys()
Returns an array of key index paths that should be used during the lookup. The indices are 0-based and support composite keys within (possibly nested) structures.For example, given a table with data type
ROW < i INT, s STRING, r ROW < i2 INT, s2 STRING > >
, this method would return[[0], [2, 1]]
wheni
ands2
are used for performing a lookup.- Returns:
- array of key index paths
-
-