T
- type of the resultDynamicTableSource
. Use LookupTableSource
instead. See FLIP-95 for more information.@Deprecated @Experimental public interface LookupableTableSource<T> extends TableSource<T>
TableSource
which supports for lookup accessing via key column(s). For example, MySQL
TableSource can implement this interface to support lookup accessing. When temporal join this
MySQL table, the runtime behavior could be in a lookup fashion.Modifier and Type | Method and Description |
---|---|
AsyncTableFunction<T> |
getAsyncLookupFunction(String[] lookupKeys)
Deprecated.
Gets the
AsyncTableFunction which supports async lookup one key at a time. |
TableFunction<T> |
getLookupFunction(String[] lookupKeys)
Deprecated.
Gets the
TableFunction which supports lookup one key at a time. |
boolean |
isAsyncEnabled()
Deprecated.
Returns true if async lookup is enabled.
|
explainSource, getProducedDataType, getReturnType, getTableSchema
TableFunction<T> getLookupFunction(String[] lookupKeys)
TableFunction
which supports lookup one key at a time.lookupKeys
- the chosen field names as lookup keys, it is in the defined orderAsyncTableFunction<T> getAsyncLookupFunction(String[] lookupKeys)
AsyncTableFunction
which supports async lookup one key at a time.lookupKeys
- the chosen field names as lookup keys, it is in the defined orderboolean isAsyncEnabled()
The lookup function returned by getAsyncLookupFunction(String[])
will be used if
returns true. Otherwise, the lookup function returned by getLookupFunction(String[])
will be used.
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.