in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/function/lookup/KuduRowDataLookupFunction.java [68:80]
public KuduRowDataLookupFunction(
String[] keyNames,
KuduTableInfo tableInfo,
KuduReaderConfig kuduReaderConfig,
List<String> projectedFields,
int maxRetryTimes) {
this.tableInfo = tableInfo;
this.projectedFields = projectedFields;
this.keyNames = keyNames;
this.kuduReaderConfig = kuduReaderConfig;
this.maxRetryTimes = maxRetryTimes;
convertor = new RowResultRowDataConverter();
}