org.apache.hadoop.hive.metastore.api.Order.getOrder()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(7.4k)|赞(0)|评价(0)|浏览(132)

本文整理了Java中org.apache.hadoop.hive.metastore.api.Order.getOrder()方法的一些代码示例，展示了Order.getOrder()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Order.getOrder()方法的具体详情如下：
包路径：org.apache.hadoop.hive.metastore.api.Order
类名称：Order
方法名：getOrder

Order.getOrder介绍

暂无

代码示例

代码示例来源：origin: apache/hive

public Object getFieldValue(_Fields field) {
 switch (field) {
 case COL:
  return getCol();
 case ORDER:
  return getOrder();
 }
 throw new IllegalStateException();
}

代码示例来源：origin: apache/drill

public OrderWrapper(Order ord) {
 this.ord = ord;
 this.col = ord.getCol();
 this.order = ord.getOrder();
}

代码示例来源：origin: apache/hive

private List<Integer> getSortOrder(
  List<Order> tabSortCols,
  List<FieldSchema> tabCols) {
 List<Integer> sortOrders = new ArrayList<Integer>();
 for (Order sortCol : tabSortCols) {
  for (FieldSchema tabCol : tabCols) {
   if (sortCol.getCol().equals(tabCol.getName())) {
    sortOrders.add(sortCol.getOrder());
    break;
   }
  }
 }
 return sortOrders;
}

代码示例来源：origin: apache/drill

private List<Integer> getSortOrder(
  List<Order> tabSortCols,
  List<FieldSchema> tabCols) {
 List<Integer> sortOrders = new ArrayList<Integer>();
 for (Order sortCol : tabSortCols) {
  for (FieldSchema tabCol : tabCols) {
   if (sortCol.getCol().equals(tabCol.getName())) {
    sortOrders.add(sortCol.getOrder());
    break;
   }
  }
 }
 return sortOrders;
}

代码示例来源：origin: apache/hive

private List<MOrder> convertToMOrders(List<Order> keys) {
 List<MOrder> mkeys = null;
 if (keys != null) {
  mkeys = new ArrayList<>(keys.size());
  for (Order part : keys) {
   mkeys.add(new MOrder(normalizeIdentifier(part.getCol()), part.getOrder()));
  }
 }
 return mkeys;
}

代码示例来源：origin: apache/hive

if (o.getOrder() != sortColumnsFirstPartition.get(pos).getOrder()) {
 return false;

代码示例来源：origin: apache/hive

/**
 * Get the sort order for the sort columns.
 *
 * @param tabSortCols
 * @param tabCols
 * @return
 */
private List<Integer> getSortOrders(List<Order> tabSortCols,
  List<FieldSchema> tabCols) {
 List<Integer> sortOrders = Lists.newArrayList();
 for (Order sortCol : tabSortCols) {
  for (FieldSchema tabCol : tabCols) {
   if (sortCol.getCol().equals(tabCol.getName())) {
    sortOrders.add(sortCol.getOrder());
    break;
   }
  }
 }
 return sortOrders;
}

代码示例来源：origin: apache/drill

if (o.getOrder() != sortColumnsFirstPartition.get(pos).getOrder()) {
 return false;

代码示例来源：origin: prestodb/presto

public static SortingColumn fromMetastoreApiOrder(org.apache.hadoop.hive.metastore.api.Order order, String tablePartitionName)
{
  return new SortingColumn(order.getCol(), Order.fromMetastoreApiOrder(order.getOrder(), tablePartitionName));
}

代码示例来源：origin: apache/hive

private ArrayList<Integer> getSortOrders(String dest, QB qb, Table tab, Operator input)
  throws SemanticException {
 List<Order> tabSortCols = tab.getSortCols();
 List<FieldSchema> tabCols = tab.getCols();
 ArrayList<Integer> orders = new ArrayList<Integer>();
 for (Order sortCol : tabSortCols) {
  for (FieldSchema tabCol : tabCols) {
   if (sortCol.getCol().equals(tabCol.getName())) {
    orders.add(sortCol.getOrder());
    break;
   }
  }
 }
 return orders;
}

代码示例来源：origin: apache/drill

private ArrayList<Integer> getSortOrders(String dest, QB qb, Table tab, Operator input)
  throws SemanticException {
 List<Order> tabSortCols = tab.getSortCols();
 List<FieldSchema> tabCols = tab.getCols();
 ArrayList<Integer> orders = new ArrayList<Integer>();
 for (Order sortCol : tabSortCols) {
  for (FieldSchema tabCol : tabCols) {
   if (sortCol.getCol().equals(tabCol.getName())) {
    orders.add(sortCol.getOrder());
    break;
   }
  }
 }
 return orders;
}

代码示例来源：origin: apache/drill

/**
 * Get the sort order for the sort columns
 * @param tabSortCols
 * @param tabCols
 * @return
 */
private List<Integer> getSortOrders(List<Order> tabSortCols,
  List<FieldSchema> tabCols) {
 List<Integer> sortOrders = Lists.newArrayList();
 for (Order sortCol : tabSortCols) {
  for (FieldSchema tabCol : tabCols) {
   if (sortCol.getCol().equals(tabCol.getName())) {
    sortOrders.add(sortCol.getOrder());
    break;
   }
  }
 }
 return sortOrders;
}

代码示例来源：origin: apache/hive

@Override
public List<RelCollation> getCollationList() {
 ImmutableList.Builder<RelFieldCollation> collationList = new ImmutableList.Builder<RelFieldCollation>();
 for (Order sortColumn : this.hiveTblMetadata.getSortCols()) {
  for (int i=0; i<this.hiveTblMetadata.getSd().getCols().size(); i++) {
   FieldSchema field = this.hiveTblMetadata.getSd().getCols().get(i);
   if (field.getName().equals(sortColumn.getCol())) {
    Direction direction;
    NullDirection nullDirection;
    if (sortColumn.getOrder() == BaseSemanticAnalyzer.HIVE_COLUMN_ORDER_ASC) {
     direction = Direction.ASCENDING;
     nullDirection = NullDirection.FIRST;
    } else {
     direction = Direction.DESCENDING;
     nullDirection = NullDirection.LAST;
    }
    collationList.add(new RelFieldCollation(i, direction, nullDirection));
    break;
   }
  }
 }
 return new ImmutableList.Builder<RelCollation>()
     .add(RelCollationTraitDef.INSTANCE.canonize(
         new HiveRelCollation(collationList.build())))
     .build();
}

代码示例来源：origin: apache/hive

if (sortCol.getOrder() == BaseSemanticAnalyzer.HIVE_COLUMN_ORDER_ASC) {
 query.append("ASC");
} else if (sortCol.getOrder() == BaseSemanticAnalyzer.HIVE_COLUMN_ORDER_DESC) {
 query.append("DESC");

代码示例来源：origin: apache/hive

for (Order order : orders) {
 md.update(order.getCol().getBytes(ENCODING));
 md.update(Integer.toString(order.getOrder()).getBytes(ENCODING));

代码示例来源：origin: apache/hive

for (Order sortCol : sortCols) {
 String sortKeyDesc = "  " + sortCol.getCol() + " ";
 if (sortCol.getOrder() == BaseSemanticAnalyzer.HIVE_COLUMN_ORDER_ASC) {
  sortKeyDesc = sortKeyDesc + "ASC";
 else if (sortCol.getOrder() == BaseSemanticAnalyzer.HIVE_COLUMN_ORDER_DESC) {
  sortKeyDesc = sortKeyDesc + "DESC";

代码示例来源：origin: apache/drill

for (Order sortCol : sortCols) {
 String sortKeyDesc = "  " + sortCol.getCol() + " ";
 if (sortCol.getOrder() == BaseSemanticAnalyzer.HIVE_COLUMN_ORDER_ASC) {
  sortKeyDesc = sortKeyDesc + "ASC";
 else if (sortCol.getOrder() == BaseSemanticAnalyzer.HIVE_COLUMN_ORDER_DESC) {
  sortKeyDesc = sortKeyDesc + "DESC";

代码示例来源：origin: apache/drill

@Override
public List<RelCollation> getCollationList() {
 ImmutableList.Builder<RelFieldCollation> collationList = new ImmutableList.Builder<RelFieldCollation>();
 for (Order sortColumn : this.hiveTblMetadata.getSortCols()) {
  for (int i=0; i<this.hiveTblMetadata.getSd().getCols().size(); i++) {
   FieldSchema field = this.hiveTblMetadata.getSd().getCols().get(i);
   if (field.getName().equals(sortColumn.getCol())) {
    Direction direction;
    NullDirection nullDirection;
    if (sortColumn.getOrder() == BaseSemanticAnalyzer.HIVE_COLUMN_ORDER_ASC) {
     direction = Direction.ASCENDING;
     nullDirection = NullDirection.FIRST;
    }
    else {
     direction = Direction.DESCENDING;
     nullDirection = NullDirection.LAST;
    }
    collationList.add(new RelFieldCollation(i,direction,nullDirection));
    break;
   }
  }
 }
 return new ImmutableList.Builder<RelCollation>()
     .add(RelCollationTraitDef.INSTANCE.canonize(
         new HiveRelCollation(collationList.build())))
     .build();
}

代码示例来源：origin: org.apache.hadoop.hive/hive-exec

private boolean checkSortColsAndJoinCols(List<Order> sortCols,
   List<String> joinCols) {
  // require all sort columns are asc, right now only support asc
  List<String> sortColNames = new ArrayList<String>();
  for (Order o : sortCols) {
   if (o.getOrder() != BaseSemanticAnalyzer.HIVE_COLUMN_ORDER_ASC) {
    return false;
   }
   sortColNames.add(o.getCol());
  }
  return sortColNames.containsAll(joinCols)
    && sortColNames.size() == joinCols.size();
 }
}

代码示例来源：origin: org.apache.hadoop.hive/hive-metastore

private List<MOrder> convertToMOrders(List<Order> keys) {
 List<MOrder> mkeys = null;
 if (keys != null) {
  mkeys = new ArrayList<MOrder>(keys.size());
  for (Order part : keys) {
   mkeys.add(new MOrder(part.getCol().toLowerCase(), part.getOrder()));
  }
 }
 return mkeys;
}

内容来源于网络，如有侵权，请联系作者删除！

Order

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com