private QueryInfo checkPermissionsAndGetQuery(QueryIdentifier queryId) throws IOException {
    QueryInfo queryInfo = queryInfoMap.get(queryId);
    if (queryInfo == null) return null;
    LlapTokenChecker.checkPermissions(clusterId, queryInfo.getTokenUserName(),
        queryInfo.getTokenAppId(), queryInfo.getQueryIdentifier());
    return queryInfo;
  }
Register an update to a source within an executing dag
@param queryIdentifier
@param sourceName
@param sourceState
llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/QueryTracker.java