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

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

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

Table.getId介绍

暂无

代码示例

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

  1. this.agentInfo = conn.getAgentInfo();
  2. this.numTxns = conn.getTransactionBatchSize();
  3. this.tableId = conn.getTable().getTTable().getId();

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

  1. "INSERT INTO TABLE_PARAMS(TBL_ID, PARAM_KEY)" + " VALUES(" + tbl.getId() + String.format(", '%smykey')", TxnStore.TXN_KEY_START));
  2. client.commitTxnWithKeyValue(1, tbl.getId(), TxnStore.TXN_KEY_START + "mykey", "myvalue");
  3. ValidTxnList validTxns = client.getValidTxns(1);
  4. Assert.assertTrue(validTxns.isTxnValid(1));
  5. + " FROM TABLE_PARAMS WHERE TBL_ID = " + tbl.getId());
  6. Assert.assertEquals(rs.getLong(1), tbl.getId());
  7. Assert.assertEquals(rs.getString(2), TxnStore.TXN_KEY_START + "mykey");
  8. Assert.assertEquals(rs.getString(3), "myvalue");
  9. client.dropTable(dbName, tblName);
  10. client.dropDatabase(dbName);
  11. stm.execute("DELETE FROM TABLE_PARAMS WHERE TBL_ID = " + tbl.getId() + String.format(
  12. " AND PARAM_KEY = '%smykey'", TxnStore.TXN_KEY_START));

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

  1. throw new InvalidObjectException("Id shouldn't be set but table "
  2. + tbl.getDbName() + "." + tbl.getTableName() + "has the Id set to "
  3. + tbl.getId() + ". It's a read-only option");

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

  1. @Test
  2. public void testCreateAndGetTableWithDriver() throws Exception {
  3. String dbName = "createDb";
  4. String tblName = "createTbl";
  5. client.dropTable(dbName, tblName);
  6. silentDropDatabase(dbName);
  7. new DatabaseBuilder()
  8. .setName(dbName)
  9. .create(client, conf);
  10. createTable(dbName, tblName);
  11. Table tblRead = client.getTable(dbName, tblName);
  12. Assert.assertTrue(tblRead.isSetId());
  13. long firstTableId = tblRead.getId();
  14. createTable(dbName, tblName + "_2");
  15. Table tblRead2 = client.getTable(dbName, tblName + "_2");
  16. Assert.assertTrue(tblRead2.isSetId());
  17. Assert.assertNotEquals(firstTableId, tblRead2.getId());
  18. }

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

  1. @Test
  2. public void testTxNWithKeyWrongPrefix() throws Exception {
  3. String dbName = "mydbKeyValueWrongPrefix";
  4. String tblName = "mytable";
  5. List<Long> tids = client.openTxns("me", 1).getTxn_ids();
  6. Assert.assertEquals(1L, (long) tids.get(0));
  7. try {
  8. Database db = new DatabaseBuilder().setName(dbName).build(conf);
  9. db.unsetCatalogName();
  10. client.createDatabase(db);
  11. Table tbl = new TableBuilder().setDbName(dbName).setTableName(tblName)
  12. .addCol("id", "int").addCol("name", "string")
  13. .setType(TableType.MANAGED_TABLE.name()).build(conf);
  14. client.createTable(tbl);
  15. tbl = client.getTable(dbName, tblName);
  16. client.commitTxnWithKeyValue(1, tbl.getId(), "mykey",
  17. "myvalue");
  18. Assert.fail("Should have raised exception");
  19. } catch (IllegalArgumentException e) {
  20. Assert.assertTrue(e.getMessage().contains("key=mykey"));
  21. Assert.assertTrue(e.getMessage().contains("value=myvalue"));
  22. Assert.assertTrue(e.getMessage().contains("key should start with"));
  23. } finally {
  24. client.dropTable(dbName, tblName);
  25. client.dropDatabase(dbName);
  26. }
  27. ValidTxnList validTxns = client.getValidTxns(1);
  28. Assert.assertTrue(validTxns.isTxnValid(1));
  29. }

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

  1. public Object getFieldValue(_Fields field) {
  2. switch (field) {
  3. case ID:
  4. return getId();

相关文章

Table类方法