hologres-connector-flink-1.17/src/main/java/com/alibaba/ververica/connectors/hologres/source/lookup/Flink117HologresLookUpFunctionFactory.java [15:24]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public AsyncFunction<RowData, RowData> createAsyncFunction(
            String sqlTableName,
            TableSchema tableSchema,
            String[] index,
            CacheStrategy cacheStrategy,
            HologresReader<RowData> hologresReader,
            boolean hasPrimaryKey) {
        return new HologresAsyncLookupFunction(
                sqlTableName, tableSchema, index, cacheStrategy, hologresReader, hasPrimaryKey);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



hologres-connector-flink-1.15/src/main/java/com/alibaba/ververica/connectors/hologres/source/lookup/Flink115HologresLookUpFunctionFactory.java [15:24]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public AsyncFunction<RowData, RowData> createAsyncFunction(
            String sqlTableName,
            TableSchema tableSchema,
            String[] index,
            CacheStrategy cacheStrategy,
            HologresReader<RowData> hologresReader,
            boolean hasPrimaryKey) {
        return new HologresAsyncLookupFunction(
                sqlTableName, tableSchema, index, cacheStrategy, hologresReader, hasPrimaryKey);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -