本文整理了Java中org.apache.hadoop.hive.metastore.api.Table.setRewriteEnabled()
方法的一些代码示例,展示了Table.setRewriteEnabled()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Table.setRewriteEnabled()
方法的具体详情如下:
包路径:org.apache.hadoop.hive.metastore.api.Table
类名称:Table
方法名:setRewriteEnabled
暂无
代码示例来源:origin: apache/hive
/**
* @param rewriteEnabled
* whether this view can be used for rewriting queries
*/
public void setRewriteEnabled(boolean rewriteEnabled) {
tTable.setRewriteEnabled(rewriteEnabled);
}
代码示例来源:origin: apache/drill
/**
* @param rewriteEnabled
* whether this view can be used for rewriting queries
*/
public void setRewriteEnabled(boolean rewriteEnabled) {
tTable.setRewriteEnabled(rewriteEnabled);
}
代码示例来源:origin: apache/hive
public Table build(Configuration conf) throws MetaException {
if (tableName == null) {
throw new MetaException("You must set the table name");
}
if (ownerType == null) {
ownerType = PrincipalType.USER;
}
if (owner == null) {
try {
owner = SecurityUtils.getUser();
} catch (IOException e) {
throw MetaStoreUtils.newMetaException(e);
}
}
if (catName == null) catName = MetaStoreUtils.getDefaultCatalog(conf);
Table t = new Table(tableName, dbName, owner, createTime, lastAccessTime, retention, buildSd(),
partCols, tableParams, viewOriginalText, viewExpandedText, type);
if (rewriteEnabled) t.setRewriteEnabled(true);
if (temporary) t.setTemporary(temporary);
t.setCatName(catName);
if (!mvReferencedTables.isEmpty()) {
CreationMetadata cm = new CreationMetadata(catName, dbName, tableName, mvReferencedTables);
if (mvValidTxnList != null) cm.setValidTxnList(mvValidTxnList);
t.setCreationMetadata(cm);
}
return t;
}
代码示例来源:origin: apache/hive
tbl.setRewriteEnabled(tbl.isRewriteEnabled());
if (tbl.getPartitionKeys() == null) {
代码示例来源:origin: apache/hive
t.setRewriteEnabled(mtbl.isRewriteEnabled());
t.setCatName(mtbl.getDatabase().getCatalogName());
t.setWriteId(mtbl.getWriteId());
代码示例来源:origin: apache/hive
view.setViewExpandedText("SELECT `" + tblName + "`.`income`, `" + tblName +
"`.`name` FROM `" + dbName + "`.`" + tblName + "`");
view.setRewriteEnabled(false);
StorageDescriptor viewSd = new StorageDescriptor();
view.setSd(viewSd);
代码示例来源:origin: apache/hive
unsetRewriteEnabled();
} else {
setRewriteEnabled((Boolean)value);
代码示例来源:origin: org.apache.hive/hive-standalone-metastore
public Table build(Configuration conf) throws MetaException {
if (tableName == null) {
throw new MetaException("You must set the table name");
}
if (owner == null) {
try {
owner = SecurityUtils.getUser();
} catch (IOException e) {
throw MetaStoreUtils.newMetaException(e);
}
}
if (catName == null) catName = MetaStoreUtils.getDefaultCatalog(conf);
Table t = new Table(tableName, dbName, owner, createTime, lastAccessTime, retention, buildSd(),
partCols, tableParams, viewOriginalText, viewExpandedText, type);
if (rewriteEnabled) t.setRewriteEnabled(true);
if (temporary) t.setTemporary(temporary);
t.setCatName(catName);
if (!mvReferencedTables.isEmpty()) {
CreationMetadata cm = new CreationMetadata(catName, dbName, tableName, mvReferencedTables);
if (mvValidTxnList != null) cm.setValidTxnList(mvValidTxnList);
t.setCreationMetadata(cm);
}
return t;
}
代码示例来源:origin: org.apache.hive/hive-standalone-metastore
@Override
public Table getTable(String catName, String dbName, String tblName) throws MetaException {
catName = normalizeIdentifier(catName);
dbName = StringUtils.normalizeIdentifier(dbName);
tblName = StringUtils.normalizeIdentifier(tblName);
if (!shouldCacheTable(catName, dbName, tblName)) {
return rawStore.getTable(catName, dbName, tblName);
}
Table tbl = sharedCache.getTableFromCache(catName, dbName, tblName);
if (tbl == null) {
// This table is not yet loaded in cache
// If the prewarm thread is working on this table's database,
// let's move this table to the top of tblNamesBeingPrewarmed stack,
// so that it gets loaded to the cache faster and is available for subsequent requests
tblsPendingPrewarm.prioritizeTableForPrewarm(tblName);
return rawStore.getTable(catName, dbName, tblName);
}
if (tbl != null) {
tbl.unsetPrivileges();
tbl.setRewriteEnabled(tbl.isRewriteEnabled());
}
return tbl;
}
代码示例来源:origin: org.apache.hive/hive-standalone-metastore
t.setRewriteEnabled(mtbl.isRewriteEnabled());
t.setCatName(mtbl.getDatabase().getCatalogName());
return t;
代码示例来源:origin: org.apache.hive/hive-standalone-metastore
unsetRewriteEnabled();
} else {
setRewriteEnabled((Boolean)value);
内容来源于网络,如有侵权,请联系作者删除!