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

x33g5p2x  于2022-01-29 转载在 其他  
字(2.7k)|赞(0)|评价(0)|浏览(190)

本文整理了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

Table.setParameters介绍

暂无

代码示例

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

  1. /** Adds entities for create table/create view. */
  2. private void addDbAndTabToOutputs(String[] qualifiedTabName, TableType type,
  3. boolean isTemporary, Map<String, String> tblProps) throws SemanticException {
  4. Database database = getDatabase(qualifiedTabName[0]);
  5. outputs.add(new WriteEntity(database, WriteEntity.WriteType.DDL_SHARED));
  6. Table t = new Table(qualifiedTabName[0], qualifiedTabName[1]);
  7. t.setParameters(tblProps);
  8. t.setTableType(type);
  9. t.setTemporary(isTemporary);
  10. outputs.add(new WriteEntity(t, WriteEntity.WriteType.DDL_NO_LOCK));
  11. }

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

  1. private Table newTable(boolean isPartitioned) {
  2. Table t = new Table("default", "table" + Integer.toString(nextInput++));
  3. if (isPartitioned) {
  4. FieldSchema fs = new FieldSchema();
  5. fs.setName("version");
  6. fs.setType("String");
  7. List<FieldSchema> partCols = new ArrayList<FieldSchema>(1);
  8. partCols.add(fs);
  9. t.setPartCols(partCols);
  10. }
  11. Map<String, String> tblProps = t.getParameters();
  12. if(tblProps == null) {
  13. tblProps = new HashMap<>();
  14. }
  15. tblProps.put(hive_metastoreConstants.TABLE_IS_TRANSACTIONAL, "true");
  16. t.setParameters(tblProps);
  17. return t;
  18. }

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

  1. tbl.setBucketCols(bucketCols);
  2. if (parameters != null) {
  3. tbl.setParameters(parameters);

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

  1. private static Table createNewTableMetadataObject(ImportTableDesc tblDesc, boolean isRepl)
  2. throws SemanticException {
  3. Table newTable = new Table(tblDesc.getDatabaseName(), tblDesc.getTableName());
  4. //so that we know the type of table we are creating: acid/MM to match what was exported
  5. newTable.setParameters(tblDesc.getTblProps());
  6. if(tblDesc.isExternal() && AcidUtils.isTransactionalTable(newTable)) {
  7. if (isRepl) {
  8. throw new SemanticException("External tables may not be transactional: " +
  9. Warehouse.getQualifiedName(tblDesc.getDatabaseName(), tblDesc.getTableName()));
  10. } else {
  11. throw new AssertionError("Internal error: transactional properties not set properly"
  12. + tblDesc.getTblProps());
  13. }
  14. }
  15. return newTable;
  16. }

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

  1. tbl.setBucketCols(bucketCols);
  2. if (parameters != null) {
  3. tbl.setParameters(parameters);

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

  1. tempTableObj.setParameters(new HashMap<>());

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

  1. tbl.setParameters(tblProps);
  2. tbl.setParameters(tblProps);
  3. } else {
  4. cols = Hive.getFieldsFromDeserializer(colPath, deserializer);

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

  1. tbl.setParameters(tblProps);
  2. tbl.setParameters(tblProps);
  3. } else {
  4. cols = Hive.getFieldsFromDeserializer(colPath, deserializer);

相关文章

Table类方法