@Internal public class JdbcRowDataLookupFunction extends LookupFunction
JdbcDynamicTableSource
.Constructor and Description |
---|
JdbcRowDataLookupFunction(JdbcConnectorOptions options,
int maxRetryTimes,
String[] fieldNames,
DataType[] fieldTypes,
String[] keyNames,
RowType rowType) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Tear-down method for user-defined function.
|
Connection |
getDbConnection() |
Collection<RowData> |
lookup(RowData keyRow)
This is a lookup method which is called by Flink framework in runtime.
|
void |
open(FunctionContext context)
Setup method for user-defined function.
|
eval
collect, finish, getKind, getParameterTypes, getResultType, getTypeInference, setCollector
functionIdentifier, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getRequirements, isDeterministic
public JdbcRowDataLookupFunction(JdbcConnectorOptions options, int maxRetryTimes, String[] fieldNames, DataType[] fieldTypes, String[] keyNames, RowType rowType)
public void open(FunctionContext context) throws Exception
UserDefinedFunction
open
in class UserDefinedFunction
Exception
public Collection<RowData> lookup(RowData keyRow)
lookup
in class LookupFunction
keyRow
- lookup keyspublic void close() throws IOException
UserDefinedFunction
close
in class UserDefinedFunction
IOException
@VisibleForTesting public Connection getDbConnection()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.