hologres-connector-flink-1.15/src/main/java/com/alibaba/ververica/connectors/hologres/source/lookup/Flink115HologresLookUpFunctionFactory.java [14:35]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    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);
    }

    @Override
    public FlatMapFunction<RowData, RowData> createFunction(
            String sqlTableName,
            TableSchema tableSchema,
            String[] index,
            CacheStrategy cacheStrategy,
            HologresReader<RowData> hologresReader,
            boolean hasPrimaryKey) {
        return new HologresLookupFunction(
                sqlTableName, tableSchema, index, cacheStrategy, hologresReader, hasPrimaryKey);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



hologres-connector-flink-1.17/src/main/java/com/alibaba/ververica/connectors/hologres/source/lookup/Flink117HologresLookUpFunctionFactory.java [14:35]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    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);
    }

    @Override
    public FlatMapFunction<RowData, RowData> createFunction(
            String sqlTableName,
            TableSchema tableSchema,
            String[] index,
            CacheStrategy cacheStrategy,
            HologresReader<RowData> hologresReader,
            boolean hasPrimaryKey) {
        return new HologresLookupFunction(
                sqlTableName, tableSchema, index, cacheStrategy, hologresReader, hasPrimaryKey);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -