org.apache.hadoop.hive.metastore.api.Table.setCreationMetadata()方法的使用及代码示例

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

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

Table.setCreationMetadata介绍

暂无

代码示例

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

  1. /**
  2. * @param creationMetadata
  3. * the creation metadata (only for materialized views)
  4. */
  5. public void setCreationMetadata(CreationMetadata creationMetadata) {
  6. tTable.setCreationMetadata(creationMetadata);
  7. }

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

  1. tbl.setCreationMetadata(
  2. convertToCreationMetadata(
  3. getCreationMetadata(tbl.getCatName(), tbl.getDbName(), tbl.getTableName())));

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

  1. public Table build(Configuration conf) throws MetaException {
  2. if (tableName == null) {
  3. throw new MetaException("You must set the table name");
  4. }
  5. if (ownerType == null) {
  6. ownerType = PrincipalType.USER;
  7. }
  8. if (owner == null) {
  9. try {
  10. owner = SecurityUtils.getUser();
  11. } catch (IOException e) {
  12. throw MetaStoreUtils.newMetaException(e);
  13. }
  14. }
  15. if (catName == null) catName = MetaStoreUtils.getDefaultCatalog(conf);
  16. Table t = new Table(tableName, dbName, owner, createTime, lastAccessTime, retention, buildSd(),
  17. partCols, tableParams, viewOriginalText, viewExpandedText, type);
  18. if (rewriteEnabled) t.setRewriteEnabled(true);
  19. if (temporary) t.setTemporary(temporary);
  20. t.setCatName(catName);
  21. if (!mvReferencedTables.isEmpty()) {
  22. CreationMetadata cm = new CreationMetadata(catName, dbName, tableName, mvReferencedTables);
  23. if (mvValidTxnList != null) cm.setValidTxnList(mvValidTxnList);
  24. t.setCreationMetadata(cm);
  25. }
  26. return t;
  27. }

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

  1. tbl.setCreationMetadata(
  2. convertToCreationMetadata(getCreationMetadata(catName, dbName, tableName)));

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

  1. private Table createTable(String dbName, String tableName, TableType type)
  2. throws Exception {
  3. TableBuilder builder = new TableBuilder()
  4. .setCatName("hive")
  5. .setDbName(dbName)
  6. .setTableName(tableName)
  7. .addCol("id", "int")
  8. .addCol("name", "string")
  9. .setType(type.name());
  10. Table table = builder.build(metaStore.getConf());
  11. if (type == TableType.MATERIALIZED_VIEW) {
  12. CreationMetadata cm = new CreationMetadata(
  13. MetaStoreUtils.getDefaultCatalog(metaStore.getConf()), dbName, tableName, ImmutableSet.of());
  14. table.setCreationMetadata(cm);
  15. }
  16. if (type == TableType.EXTERNAL_TABLE) {
  17. table.getParameters().put("EXTERNAL", "true");
  18. }
  19. return table;
  20. }

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

  1. @Test
  2. public void testAlterTable() throws Exception {
  3. Table originalTable = testTables[2];
  4. String originalTableName = originalTable.getTableName();
  5. String originalDatabase = originalTable.getDbName();
  6. Table newTable = getTableWithAllParametersSet();
  7. newTable.setTableName(originalTableName);
  8. newTable.setDbName(originalDatabase);
  9. // Partition keys can not be set, but getTableWithAllParametersSet is added one, so remove for
  10. // this test
  11. newTable.setPartitionKeys(originalTable.getPartitionKeys());
  12. client.alter_table(originalDatabase, originalTableName, newTable);
  13. Table alteredTable = client.getTable(originalDatabase, originalTableName);
  14. // The extra parameters will be added on server side, so check that the required ones are
  15. // present
  16. for(String key: newTable.getParameters().keySet()) {
  17. Assert.assertEquals("parameters are present", newTable.getParameters().get(key),
  18. alteredTable.getParameters().get(key));
  19. }
  20. // The parameters are checked manually, so do not check them
  21. newTable.setParameters(alteredTable.getParameters());
  22. // Some of the data is set on the server side, so reset those
  23. newTable.setCreateTime(alteredTable.getCreateTime());
  24. newTable.setCreationMetadata(alteredTable.getCreationMetadata());
  25. newTable.setWriteId(alteredTable.getWriteId());
  26. Assert.assertTrue(alteredTable.isSetId());
  27. alteredTable.unsetId();
  28. Assert.assertEquals("The table data should be the same", newTable, alteredTable);
  29. }

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

  1. table.setCreationMetadata(createdTable.getCreationMetadata());
  2. table.setWriteId(createdTable.getWriteId());

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

  1. tbl.getTableName(), ImmutableSet.copyOf(crtView.getTablesUsed()));
  2. cm.setValidTxnList(conf.get(ValidTxnWriteIdList.VALID_TABLES_WRITEIDS_KEY));
  3. tbl.getTTable().setCreationMetadata(cm);

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

  1. unsetCreationMetadata();
  2. } else {
  3. setCreationMetadata((CreationMetadata)value);

代码示例来源:origin: org.apache.hive/hive-standalone-metastore

  1. @Override
  2. public Table getTable(String catName, String dbName, String tableName) throws MetaException {
  3. boolean commited = false;
  4. Table tbl = null;
  5. try {
  6. openTransaction();
  7. tbl = convertToTable(getMTable(catName, dbName, tableName));
  8. // Retrieve creation metadata if needed
  9. if (tbl != null && TableType.MATERIALIZED_VIEW.toString().equals(tbl.getTableType())) {
  10. tbl.setCreationMetadata(
  11. convertToCreationMetadata(getCreationMetadata(catName, dbName, tableName)));
  12. }
  13. commited = commitTransaction();
  14. } finally {
  15. if (!commited) {
  16. rollbackTransaction();
  17. }
  18. }
  19. return tbl;
  20. }

代码示例来源:origin: org.apache.hive/hive-standalone-metastore

  1. tbl.setCreationMetadata(
  2. convertToCreationMetadata(
  3. getCreationMetadata(tbl.getCatName(), tbl.getDbName(), tbl.getTableName())));

代码示例来源:origin: org.apache.hive/hive-standalone-metastore

  1. public Table build(Configuration conf) throws MetaException {
  2. if (tableName == null) {
  3. throw new MetaException("You must set the table name");
  4. }
  5. if (owner == null) {
  6. try {
  7. owner = SecurityUtils.getUser();
  8. } catch (IOException e) {
  9. throw MetaStoreUtils.newMetaException(e);
  10. }
  11. }
  12. if (catName == null) catName = MetaStoreUtils.getDefaultCatalog(conf);
  13. Table t = new Table(tableName, dbName, owner, createTime, lastAccessTime, retention, buildSd(),
  14. partCols, tableParams, viewOriginalText, viewExpandedText, type);
  15. if (rewriteEnabled) t.setRewriteEnabled(true);
  16. if (temporary) t.setTemporary(temporary);
  17. t.setCatName(catName);
  18. if (!mvReferencedTables.isEmpty()) {
  19. CreationMetadata cm = new CreationMetadata(catName, dbName, tableName, mvReferencedTables);
  20. if (mvValidTxnList != null) cm.setValidTxnList(mvValidTxnList);
  21. t.setCreationMetadata(cm);
  22. }
  23. return t;
  24. }

代码示例来源:origin: org.apache.hive/hive-standalone-metastore

  1. unsetCreationMetadata();
  2. } else {
  3. setCreationMetadata((CreationMetadata)value);

相关文章

Table类方法