@Override
    public void asyncInvoke(BaseRow row, ResultFuture<BaseRow> resultFuture) throws Exception {
        preInvoke(row, resultFuture);
        Map<String, Object> inputParams = parseInputParam(row);
        if (MapUtils.isEmpty(inputParams)) {
            dealMissKey(row, resultFuture);
            return;
        }
        if (isUseCache(inputParams)) {
            invokeWithCache(inputParams, row, resultFuture);
            return;
        }
        handleAsyncInvoke(inputParams, row, resultFuture);
    }
All interfaces inherit naming rules: type + "AsyncReqRow" such as == "MysqlAsyncReqRow
only support Left join / inner join(join),not support right join
Date: 2018/7/9
Company: www.dtstack.com

@author xuchao
core/src/main/java/com/dtstack/flink/sql/side/BaseAsyncReqRow.java