odps-sdk-impl/odps-mapred-local/src/main/java/com/aliyun/odps/mapred/local/utils/LocalValidatorFactory.java [67:79]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private static boolean validateColumns(String[] columns, Column[] schema, StringBuilder errorMsg) {
    Set<String> schemaColums = new HashSet<String>();
    for (int i = 0; i < schema.length; ++i) {
      schemaColums.add(schema[i].getName());
    }
    for (int i = 0; i < columns.length; ++i) {
      if (!schemaColums.contains(columns[i])) {
        errorMsg.append("Can't find column " + columns[i] + " from key schema.");
        return false;
      }
    }
    return true;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



odps-sdk-impl/odps-mapred-bridge/src/main/java/com/aliyun/odps/mapred/bridge/utils/ValidatorFactory.java [55:67]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private static boolean validateColumns(String[] columns, Column[] schema, StringBuilder errorMsg) {
    Set<String> schemaColums = new HashSet<String>();
    for (int i = 0; i < schema.length; ++i) {
      schemaColums.add(schema[i].getName());
    }
    for (int i = 0; i < columns.length; ++i) {
      if (!schemaColums.contains(columns[i])) {
        errorMsg.append("Can't find column " + columns[i] + " from key schema.");
        return false;
      }
    }
    return true;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -