public static void completeBaseRow(ResultFuture<BaseRow> resultFuture, List<BaseRow> rowList) {
        List<BaseRow> baseRowList = Lists.newArrayList();
        for (BaseRow baseRow : rowList) {
            baseRowList.add(RowDataConvert.convertToBaseRow(baseRow));
        }
        resultFuture.complete(baseRowList);
    }
Company: www.dtstack.com

@author xuchao
@date 2020-05-20
core/src/main/java/com/dtstack/flink/sql/util/RowDataComplete.java