org.apache.hadoop.hive.ql.metadata.Hive.createIndex()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(3.5k)|赞(0)|评价(0)|浏览(103)

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

Hive.createIndex介绍

暂无

代码示例

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

private int createIndex(Hive db, CreateIndexDesc crtIndex) throws HiveException {
 if (HiveConf.getVar(conf, HiveConf.ConfVars.HIVE_EXECUTION_ENGINE).equals("tez")) {
  throw new UnsupportedOperationException("Indexes unsupported for Tez execution engine");
 }
 if( crtIndex.getSerde() != null) {
  validateSerDe(crtIndex.getSerde());
 }
 String indexTableName = crtIndex.getIndexTableName();
 if (!Utilities.isDefaultNameNode(conf)) {
  // If location is specified - ensure that it is a full qualified name
  makeLocationQualified(crtIndex, indexTableName);
 }
 db
 .createIndex(
   crtIndex.getTableName(), crtIndex.getIndexName(), crtIndex.getIndexTypeHandlerClass(),
   crtIndex.getIndexedCols(), crtIndex.getIndexTableName(), crtIndex.getDeferredRebuild(),
   crtIndex.getInputFormat(), crtIndex.getOutputFormat(), crtIndex.getSerde(),
   crtIndex.getStorageHandler(), crtIndex.getLocation(), crtIndex.getIdxProps(), crtIndex.getTblProps(),
   crtIndex.getSerdeProps(), crtIndex.getCollItemDelim(), crtIndex.getFieldDelim(), crtIndex.getFieldEscape(),
   crtIndex.getLineDelim(), crtIndex.getMapKeyDelim(), crtIndex.getIndexComment()
   );
 if (HiveUtils.getIndexHandler(conf, crtIndex.getIndexTypeHandlerClass()).usesIndexTable()) {
    Table indexTable = db.getTable(indexTableName);
    addIfAbsentByName(new WriteEntity(indexTable, WriteEntity.WriteType.DDL_NO_LOCK));
 }
 return 0;
}

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

private int createIndex(Hive db, CreateIndexDesc crtIndex) throws HiveException {
 if( crtIndex.getSerde() != null) {
  validateSerDe(crtIndex.getSerde());
 }
 db
   .createIndex(
   crtIndex.getTableName(), crtIndex.getIndexName(), crtIndex.getIndexTypeHandlerClass(),
   crtIndex.getIndexedCols(), crtIndex.getIndexTableName(), crtIndex.getDeferredRebuild(),
   crtIndex.getInputFormat(), crtIndex.getOutputFormat(), crtIndex.getSerde(),
   crtIndex.getStorageHandler(), crtIndex.getLocation(), crtIndex.getIdxProps(), crtIndex.getTblProps(),
   crtIndex.getSerdeProps(), crtIndex.getCollItemDelim(), crtIndex.getFieldDelim(), crtIndex.getFieldEscape(),
   crtIndex.getLineDelim(), crtIndex.getMapKeyDelim(), crtIndex.getIndexComment()
   );
 return 0;
}

代码示例来源:origin: com.facebook.presto.hive/hive-apache

private int createIndex(Hive db, CreateIndexDesc crtIndex) throws HiveException {
 if( crtIndex.getSerde() != null) {
  validateSerDe(crtIndex.getSerde());
 }
 String indexTableName = crtIndex.getIndexTableName();
 if (!Utilities.isDefaultNameNode(conf)) {
  // If location is specified - ensure that it is a full qualified name
  makeLocationQualified(crtIndex, indexTableName);
 }
 db
 .createIndex(
   crtIndex.getTableName(), crtIndex.getIndexName(), crtIndex.getIndexTypeHandlerClass(),
   crtIndex.getIndexedCols(), crtIndex.getIndexTableName(), crtIndex.getDeferredRebuild(),
   crtIndex.getInputFormat(), crtIndex.getOutputFormat(), crtIndex.getSerde(),
   crtIndex.getStorageHandler(), crtIndex.getLocation(), crtIndex.getIdxProps(), crtIndex.getTblProps(),
   crtIndex.getSerdeProps(), crtIndex.getCollItemDelim(), crtIndex.getFieldDelim(), crtIndex.getFieldEscape(),
   crtIndex.getLineDelim(), crtIndex.getMapKeyDelim(), crtIndex.getIndexComment()
   );
 if (HiveUtils.getIndexHandler(conf, crtIndex.getIndexTypeHandlerClass()).usesIndexTable()) {
    Table indexTable = db.getTable(indexTableName);
    work.getOutputs().add(new WriteEntity(indexTable, WriteEntity.WriteType.DDL_NO_LOCK));
 }
 return 0;
}

相关文章

微信公众号

最新文章

更多

Hive类方法