本文整理了Java中org.apache.hadoop.hive.ql.metadata.Table.setParameters()
方法的一些代码示例,展示了Table.setParameters()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Table.setParameters()
方法的具体详情如下:
包路径:org.apache.hadoop.hive.ql.metadata.Table
类名称:Table
方法名:setParameters
暂无
代码示例来源:origin: apache/hive
/** Adds entities for create table/create view. */
private void addDbAndTabToOutputs(String[] qualifiedTabName, TableType type,
boolean isTemporary, Map<String, String> tblProps) throws SemanticException {
Database database = getDatabase(qualifiedTabName[0]);
outputs.add(new WriteEntity(database, WriteEntity.WriteType.DDL_SHARED));
Table t = new Table(qualifiedTabName[0], qualifiedTabName[1]);
t.setParameters(tblProps);
t.setTableType(type);
t.setTemporary(isTemporary);
outputs.add(new WriteEntity(t, WriteEntity.WriteType.DDL_NO_LOCK));
}
代码示例来源:origin: apache/hive
private Table newTable(boolean isPartitioned) {
Table t = new Table("default", "table" + Integer.toString(nextInput++));
if (isPartitioned) {
FieldSchema fs = new FieldSchema();
fs.setName("version");
fs.setType("String");
List<FieldSchema> partCols = new ArrayList<FieldSchema>(1);
partCols.add(fs);
t.setPartCols(partCols);
}
Map<String, String> tblProps = t.getParameters();
if(tblProps == null) {
tblProps = new HashMap<>();
}
tblProps.put(hive_metastoreConstants.TABLE_IS_TRANSACTIONAL, "true");
t.setParameters(tblProps);
return t;
}
代码示例来源:origin: apache/hive
tbl.setBucketCols(bucketCols);
if (parameters != null) {
tbl.setParameters(parameters);
代码示例来源:origin: apache/hive
private static Table createNewTableMetadataObject(ImportTableDesc tblDesc, boolean isRepl)
throws SemanticException {
Table newTable = new Table(tblDesc.getDatabaseName(), tblDesc.getTableName());
//so that we know the type of table we are creating: acid/MM to match what was exported
newTable.setParameters(tblDesc.getTblProps());
if(tblDesc.isExternal() && AcidUtils.isTransactionalTable(newTable)) {
if (isRepl) {
throw new SemanticException("External tables may not be transactional: " +
Warehouse.getQualifiedName(tblDesc.getDatabaseName(), tblDesc.getTableName()));
} else {
throw new AssertionError("Internal error: transactional properties not set properly"
+ tblDesc.getTblProps());
}
}
return newTable;
}
代码示例来源:origin: apache/drill
tbl.setBucketCols(bucketCols);
if (parameters != null) {
tbl.setParameters(parameters);
代码示例来源:origin: apache/hive
tempTableObj.setParameters(new HashMap<>());
代码示例来源:origin: apache/drill
tbl.setParameters(tblProps);
tbl.setParameters(tblProps);
} else {
cols = Hive.getFieldsFromDeserializer(colPath, deserializer);
代码示例来源:origin: apache/hive
tbl.setParameters(tblProps);
tbl.setParameters(tblProps);
} else {
cols = Hive.getFieldsFromDeserializer(colPath, deserializer);
内容来源于网络,如有侵权,请联系作者删除!