org.apache.hadoop.hive.ql.exec.Utilities.getTableName()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(4.8k)|赞(0)|评价(0)|浏览(92)

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

Utilities.getTableName介绍

[英]Accepts qualified name which is in the form of dbname.tablename and returns tablename from it
[中]接受dbname形式的限定名。tablename并从中返回tablename

代码示例

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

/**
 * Make qualified location for an index .
 *
 * @param crtIndex
 *          Create index descriptor.
 * @param name
 *          Object name.
 */
private void makeLocationQualified(CreateIndexDesc crtIndex, String name) throws HiveException
{
 Path path = null;
 if (crtIndex.getLocation() == null) {
  // Location is not set, leave it as-is if index doesn't belong to default DB
  // Currently all indexes are created in current DB only
  if (Utilities.getDatabaseName(name).equalsIgnoreCase(MetaStoreUtils.DEFAULT_DATABASE_NAME)) {
   // Default database name path is always ignored, use METASTOREWAREHOUSE and object name
   // instead
   String warehouse = HiveConf.getVar(conf, ConfVars.METASTOREWAREHOUSE);
   String tableName = Utilities.getTableName(name);
   path = new Path(warehouse, tableName.toLowerCase());
  }
 }
 else {
  path = new Path(crtIndex.getLocation());
 }
 if (path != null) {
  crtIndex.setLocation(Utilities.getQualifiedPath(conf, path));
 }
}

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

private int dropConstraint(Hive db, AlterTableDesc alterTbl)
    throws SemanticException, HiveException {
 try {
  db.dropConstraint(Utilities.getDatabaseName(alterTbl.getOldName()),
   Utilities.getTableName(alterTbl.getOldName()),
    alterTbl.getConstraintName());
  } catch (NoSuchObjectException e) {
   throw new HiveException(e);
  }
 return 0;
}

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

private int dropConstraint(Hive db, AlterTableDesc alterTbl)
throws SemanticException, HiveException {
 try {
 db.dropConstraint(Utilities.getDatabaseName(alterTbl.getOldName()),
  Utilities.getTableName(alterTbl.getOldName()),
   alterTbl.getConstraintName());
 } catch (NoSuchObjectException e) {
  throw new HiveException(e);
 }
 return 0;
}

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

HiveIndexHandler indexHandler = HiveUtils.getIndexHandler(this.getConf(), indexHandlerClass);
String itname = Utilities.getTableName(indexTblName);
if (indexHandler.usesIndexTable()) {
 tt = new org.apache.hadoop.hive.ql.metadata.Table(idname, itname).getTTable();
String ttname = Utilities.getTableName(tableName);
Index indexDesc = new Index(indexName, indexHandlerClass, tdname, ttname, time, time, itname,
  indexSd, new HashMap<String,String>(), deferredRebuild);

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

TableDesc tableInfo = desc.getTableInfo();
 long writeId = queryTxnMgr.getTableWriteId(Utilities.getDatabaseName(tableInfo.getTableName()),
     Utilities.getTableName(tableInfo.getTableName()));
 desc.setTableWriteId(writeId);
String fqTableName = acidDdlDesc.getFullTableName();
long writeId = queryTxnMgr.getTableWriteId(
  Utilities.getDatabaseName(fqTableName), Utilities.getTableName(fqTableName));
acidDdlDesc.setWriteId(writeId);

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

tbl.setTableName(Utilities.getTableName(alterTbl.getNewName()));
} else if (alterTbl.getOp() == AlterTableDesc.AlterTableTypes.ADDCOLS) {
 StorageDescriptor sd = retrieveStorageDescriptor(tbl, part);

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

tbl.setTableName(Utilities.getTableName(alterTbl.getNewName()));
} else if (alterTbl.getOp() == AlterTableDesc.AlterTableTypes.ADDCOLS) {
 StorageDescriptor sd = retrieveStorageDescriptor(tbl, part);

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

/**
 * Make qualified location for an index .
 *
 * @param crtIndex
 *          Create index descriptor.
 * @param name
 *          Object name.
 */
private void makeLocationQualified(CreateIndexDesc crtIndex, String name) throws HiveException
{
 Path path = null;
 if (crtIndex.getLocation() == null) {
  // Location is not set, leave it as-is if index doesn't belong to default DB
  // Currently all indexes are created in current DB only
  if (Utilities.getDatabaseName(name).equalsIgnoreCase(MetaStoreUtils.DEFAULT_DATABASE_NAME)) {
   // Default database name path is always ignored, use METASTOREWAREHOUSE and object name
   // instead
   String warehouse = HiveConf.getVar(conf, ConfVars.METASTOREWAREHOUSE);
   String tableName = Utilities.getTableName(name);
   path = new Path(warehouse, tableName.toLowerCase());
  }
 }
 else {
  path = new Path(crtIndex.getLocation());
 }
 if (path != null) {
  crtIndex.setLocation(Utilities.getQualifiedPath(conf, path));
 }
}

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

HiveIndexHandler indexHandler = HiveUtils.getIndexHandler(this.getConf(), indexHandlerClass);
String itname = Utilities.getTableName(indexTblName);
if (indexHandler.usesIndexTable()) {
 tt = new org.apache.hadoop.hive.ql.metadata.Table(idname, itname).getTTable();
String ttname = Utilities.getTableName(tableName);
Index indexDesc = new Index(indexName, indexHandlerClass, tdname, ttname, time, time, itname,
  indexSd, new HashMap<String,String>(), deferredRebuild);

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

tbl.setTableName(Utilities.getTableName(alterTbl.getNewName()));
} else if (alterTbl.getOp() == AlterTableDesc.AlterTableTypes.ADDCOLS) {
 List<FieldSchema> oldCols = (part == null ? tbl.getCols() : part.getCols());

相关文章

微信公众号

最新文章

更多

Utilities类方法