本文整理了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
[英]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());
内容来源于网络,如有侵权,请联系作者删除!