@Override
    protected void asyncQueryData(Map<String, Object> inputParams,
                                  BaseRow input,
                          ResultFuture<BaseRow> resultFuture,
                          SQLClient rdbSqlClient,
                          AtomicLong failCounter,
                          AtomicBoolean finishFlag,
                          CountDownLatch latch) {
        if (ugi == null) {
            doAsyncQueryData(inputParams,
                input, resultFuture,
                rdbSqlClient,
                failCounter,
                finishFlag,
                latch);
        } else {
            // Kerberos
            ugi.doAs(new PrivilegedAction<Object>() {
                @Override
                public Object run() {
                    doAsyncQueryData(inputParams,
                        input, resultFuture,
                        rdbSqlClient,
                        failCounter,
                        finishFlag,
                        latch);
                    return null;
                }
            });
        }
    }
Date: 2019/11/12
Company: www.dtstack.com

@author xiuzhu
impala/impala-side/impala-async-side/src/main/java/com/dtstack/flink/sql/side/impala/ImpalaAsyncReqRow.java