tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/worker/dataserver/retriever/AdvancedDataRetriever.java [88:126]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        RetrieverHandler handler = handlerMap.get(attemptId.toString());
        FileChunk chunk = handler.get(params);
        chunks.add(chunk);
      }
      return chunks.toArray(new FileChunk[chunks.size()]);
    } else {
      RetrieverHandler handler = handlerMap.get(params.get("qid").get(0));
      FileChunk chunk = handler.get(params);
      if (chunk == null) {
        if (params.containsKey("qid")) { // if there is no content corresponding to the query
          return null;
        } else { // if there is no
          throw new FileNotFoundException("No such a file corresponding to " + params.get("qid"));
        }
      }

      File file = chunk.getFile();
      if (file.isHidden() || !file.exists()) {
        throw new FileNotFoundException("No such file: " + file.getAbsolutePath());
      }
      if (!file.isFile()) {
        throw new FileAccessForbiddenException(file.getAbsolutePath() + " is not file");
      }

      return new FileChunk[] {chunk};
    }
  }

  private List<String> splitMaps(List<String> qids) {
    if (null == qids) {
      LOG.error("QueryUnitId is EMPTY");
      return null;
    }

    final List<String> ret = new ArrayList<String>();
    for (String qid : qids) {
      Collections.addAll(ret, qid.split(","));
    }
    return ret;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tajo-core/tajo-core-pullserver/src/main/java/org/apache/tajo/pullserver/retriever/AdvancedDataRetriever.java [86:124]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        RetrieverHandler handler = handlerMap.get(attemptId.toString());
        FileChunk chunk = handler.get(params);
        chunks.add(chunk);
      }
      return chunks.toArray(new FileChunk[chunks.size()]);
    } else {
      RetrieverHandler handler = handlerMap.get(params.get("qid").get(0));
      FileChunk chunk = handler.get(params);
      if (chunk == null) {
        if (params.containsKey("qid")) { // if there is no content corresponding to the query
          return null;
        } else { // if there is no
          throw new FileNotFoundException("No such a file corresponding to " + params.get("qid"));
        }
      }

      File file = chunk.getFile();
      if (file.isHidden() || !file.exists()) {
        throw new FileNotFoundException("No such file: " + file.getAbsolutePath());
      }
      if (!file.isFile()) {
        throw new FileAccessForbiddenException(file.getAbsolutePath() + " is not file");
      }

      return new FileChunk[] {chunk};
    }
  }

  private List<String> splitMaps(List<String> qids) {
    if (null == qids) {
      LOG.error("QueryUnitId is EMPTY");
      return null;
    }

    final List<String> ret = new ArrayList<String>();
    for (String qid : qids) {
      Collections.addAll(ret, qid.split(","));
    }
    return ret;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -