class Impala::Protocol::HiveMetastore::ThriftHiveMetastore::Processor

Public Instance Methods

process_add_index(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1820 def process_add_index(seqid, iprot, oprot)
1821   args = read_args(iprot, Add_index_args)
1822   result = Add_index_result.new()
1823   begin
1824     result.success = @handler.add_index(args.new_index, args.index_table)
1825   rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o1
1826     result.o1 = o1
1827   rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o2
1828     result.o2 = o2
1829   rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
1830     result.o3 = o3
1831   end
1832   write_result(result, oprot, 'add_index', seqid)
1833 end
process_add_partition(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1464 def process_add_partition(seqid, iprot, oprot)
1465   args = read_args(iprot, Add_partition_args)
1466   result = Add_partition_result.new()
1467   begin
1468     result.success = @handler.add_partition(args.new_part)
1469   rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o1
1470     result.o1 = o1
1471   rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o2
1472     result.o2 = o2
1473   rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
1474     result.o3 = o3
1475   end
1476   write_result(result, oprot, 'add_partition', seqid)
1477 end
process_add_partition_with_environment_context(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1479 def process_add_partition_with_environment_context(seqid, iprot, oprot)
1480   args = read_args(iprot, Add_partition_with_environment_context_args)
1481   result = Add_partition_with_environment_context_result.new()
1482   begin
1483     result.success = @handler.add_partition_with_environment_context(args.new_part, args.environment_context)
1484   rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o1
1485     result.o1 = o1
1486   rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o2
1487     result.o2 = o2
1488   rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
1489     result.o3 = o3
1490   end
1491   write_result(result, oprot, 'add_partition_with_environment_context', seqid)
1492 end
process_add_partitions(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1494 def process_add_partitions(seqid, iprot, oprot)
1495   args = read_args(iprot, Add_partitions_args)
1496   result = Add_partitions_result.new()
1497   begin
1498     result.success = @handler.add_partitions(args.new_parts)
1499   rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o1
1500     result.o1 = o1
1501   rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o2
1502     result.o2 = o2
1503   rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
1504     result.o3 = o3
1505   end
1506   write_result(result, oprot, 'add_partitions', seqid)
1507 end
process_alter_database(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1231 def process_alter_database(seqid, iprot, oprot)
1232   args = read_args(iprot, Alter_database_args)
1233   result = Alter_database_result.new()
1234   begin
1235     @handler.alter_database(args.dbname, args.db)
1236   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1237     result.o1 = o1
1238   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
1239     result.o2 = o2
1240   end
1241   write_result(result, oprot, 'alter_database', seqid)
1242 end
process_alter_index(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1835 def process_alter_index(seqid, iprot, oprot)
1836   args = read_args(iprot, Alter_index_args)
1837   result = Alter_index_result.new()
1838   begin
1839     @handler.alter_index(args.dbname, args.base_tbl_name, args.idx_name, args.new_idx)
1840   rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o1
1841     result.o1 = o1
1842   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1843     result.o2 = o2
1844   end
1845   write_result(result, oprot, 'alter_index', seqid)
1846 end
process_alter_partition(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1706 def process_alter_partition(seqid, iprot, oprot)
1707   args = read_args(iprot, Alter_partition_args)
1708   result = Alter_partition_result.new()
1709   begin
1710     @handler.alter_partition(args.db_name, args.tbl_name, args.new_part)
1711   rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o1
1712     result.o1 = o1
1713   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1714     result.o2 = o2
1715   end
1716   write_result(result, oprot, 'alter_partition', seqid)
1717 end
process_alter_partition_with_environment_context(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1719 def process_alter_partition_with_environment_context(seqid, iprot, oprot)
1720   args = read_args(iprot, Alter_partition_with_environment_context_args)
1721   result = Alter_partition_with_environment_context_result.new()
1722   begin
1723     @handler.alter_partition_with_environment_context(args.db_name, args.tbl_name, args.new_part, args.environment_context)
1724   rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o1
1725     result.o1 = o1
1726   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1727     result.o2 = o2
1728   end
1729   write_result(result, oprot, 'alter_partition_with_environment_context', seqid)
1730 end
process_alter_table(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1438 def process_alter_table(seqid, iprot, oprot)
1439   args = read_args(iprot, Alter_table_args)
1440   result = Alter_table_result.new()
1441   begin
1442     @handler.alter_table(args.dbname, args.tbl_name, args.new_tbl)
1443   rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o1
1444     result.o1 = o1
1445   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1446     result.o2 = o2
1447   end
1448   write_result(result, oprot, 'alter_table', seqid)
1449 end
process_alter_table_with_environment_context(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1451 def process_alter_table_with_environment_context(seqid, iprot, oprot)
1452   args = read_args(iprot, Alter_table_with_environment_context_args)
1453   result = Alter_table_with_environment_context_result.new()
1454   begin
1455     @handler.alter_table_with_environment_context(args.dbname, args.tbl_name, args.new_tbl, args.environment_context)
1456   rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o1
1457     result.o1 = o1
1458   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1459     result.o2 = o2
1460   end
1461   write_result(result, oprot, 'alter_table_with_environment_context', seqid)
1462 end
process_append_partition(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1509 def process_append_partition(seqid, iprot, oprot)
1510   args = read_args(iprot, Append_partition_args)
1511   result = Append_partition_result.new()
1512   begin
1513     result.success = @handler.append_partition(args.db_name, args.tbl_name, args.part_vals)
1514   rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o1
1515     result.o1 = o1
1516   rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o2
1517     result.o2 = o2
1518   rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
1519     result.o3 = o3
1520   end
1521   write_result(result, oprot, 'append_partition', seqid)
1522 end
process_append_partition_by_name(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1524 def process_append_partition_by_name(seqid, iprot, oprot)
1525   args = read_args(iprot, Append_partition_by_name_args)
1526   result = Append_partition_by_name_result.new()
1527   begin
1528     result.success = @handler.append_partition_by_name(args.db_name, args.tbl_name, args.part_name)
1529   rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o1
1530     result.o1 = o1
1531   rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o2
1532     result.o2 = o2
1533   rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
1534     result.o3 = o3
1535   end
1536   write_result(result, oprot, 'append_partition_by_name', seqid)
1537 end
process_cancel_delegation_token(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
2041 def process_cancel_delegation_token(seqid, iprot, oprot)
2042   args = read_args(iprot, Cancel_delegation_token_args)
2043   result = Cancel_delegation_token_result.new()
2044   begin
2045     @handler.cancel_delegation_token(args.token_str_form)
2046   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
2047     result.o1 = o1
2048   end
2049   write_result(result, oprot, 'cancel_delegation_token', seqid)
2050 end
process_create_database(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1166 def process_create_database(seqid, iprot, oprot)
1167   args = read_args(iprot, Create_database_args)
1168   result = Create_database_result.new()
1169   begin
1170     @handler.create_database(args.database)
1171   rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o1
1172     result.o1 = o1
1173   rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o2
1174     result.o2 = o2
1175   rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
1176     result.o3 = o3
1177   end
1178   write_result(result, oprot, 'create_database', seqid)
1179 end
process_create_role(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1898 def process_create_role(seqid, iprot, oprot)
1899   args = read_args(iprot, Create_role_args)
1900   result = Create_role_result.new()
1901   begin
1902     result.success = @handler.create_role(args.role)
1903   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1904     result.o1 = o1
1905   end
1906   write_result(result, oprot, 'create_role', seqid)
1907 end
process_create_table(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1326 def process_create_table(seqid, iprot, oprot)
1327   args = read_args(iprot, Create_table_args)
1328   result = Create_table_result.new()
1329   begin
1330     @handler.create_table(args.tbl)
1331   rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o1
1332     result.o1 = o1
1333   rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o2
1334     result.o2 = o2
1335   rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
1336     result.o3 = o3
1337   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o4
1338     result.o4 = o4
1339   end
1340   write_result(result, oprot, 'create_table', seqid)
1341 end
process_create_table_with_environment_context(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1343 def process_create_table_with_environment_context(seqid, iprot, oprot)
1344   args = read_args(iprot, Create_table_with_environment_context_args)
1345   result = Create_table_with_environment_context_result.new()
1346   begin
1347     @handler.create_table_with_environment_context(args.tbl, args.environment_context)
1348   rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o1
1349     result.o1 = o1
1350   rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o2
1351     result.o2 = o2
1352   rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
1353     result.o3 = o3
1354   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o4
1355     result.o4 = o4
1356   end
1357   write_result(result, oprot, 'create_table_with_environment_context', seqid)
1358 end
process_create_type(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1257 def process_create_type(seqid, iprot, oprot)
1258   args = read_args(iprot, Create_type_args)
1259   result = Create_type_result.new()
1260   begin
1261     result.success = @handler.create_type(args.type)
1262   rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o1
1263     result.o1 = o1
1264   rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o2
1265     result.o2 = o2
1266   rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
1267     result.o3 = o3
1268   end
1269   write_result(result, oprot, 'create_type', seqid)
1270 end
process_drop_database(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1194 def process_drop_database(seqid, iprot, oprot)
1195   args = read_args(iprot, Drop_database_args)
1196   result = Drop_database_result.new()
1197   begin
1198     @handler.drop_database(args.name, args.deleteData, args.cascade)
1199   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
1200     result.o1 = o1
1201   rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o2
1202     result.o2 = o2
1203   rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
1204     result.o3 = o3
1205   end
1206   write_result(result, oprot, 'drop_database', seqid)
1207 end
process_drop_index_by_name(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1848 def process_drop_index_by_name(seqid, iprot, oprot)
1849   args = read_args(iprot, Drop_index_by_name_args)
1850   result = Drop_index_by_name_result.new()
1851   begin
1852     result.success = @handler.drop_index_by_name(args.db_name, args.tbl_name, args.index_name, args.deleteData)
1853   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
1854     result.o1 = o1
1855   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1856     result.o2 = o2
1857   end
1858   write_result(result, oprot, 'drop_index_by_name', seqid)
1859 end
process_drop_partition(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1539 def process_drop_partition(seqid, iprot, oprot)
1540   args = read_args(iprot, Drop_partition_args)
1541   result = Drop_partition_result.new()
1542   begin
1543     result.success = @handler.drop_partition(args.db_name, args.tbl_name, args.part_vals, args.deleteData)
1544   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
1545     result.o1 = o1
1546   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1547     result.o2 = o2
1548   end
1549   write_result(result, oprot, 'drop_partition', seqid)
1550 end
process_drop_partition_by_name(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1552 def process_drop_partition_by_name(seqid, iprot, oprot)
1553   args = read_args(iprot, Drop_partition_by_name_args)
1554   result = Drop_partition_by_name_result.new()
1555   begin
1556     result.success = @handler.drop_partition_by_name(args.db_name, args.tbl_name, args.part_name, args.deleteData)
1557   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
1558     result.o1 = o1
1559   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1560     result.o2 = o2
1561   end
1562   write_result(result, oprot, 'drop_partition_by_name', seqid)
1563 end
process_drop_role(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1909 def process_drop_role(seqid, iprot, oprot)
1910   args = read_args(iprot, Drop_role_args)
1911   result = Drop_role_result.new()
1912   begin
1913     result.success = @handler.drop_role(args.role_name)
1914   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1915     result.o1 = o1
1916   end
1917   write_result(result, oprot, 'drop_role', seqid)
1918 end
process_drop_table(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1360 def process_drop_table(seqid, iprot, oprot)
1361   args = read_args(iprot, Drop_table_args)
1362   result = Drop_table_result.new()
1363   begin
1364     @handler.drop_table(args.dbname, args.name, args.deleteData)
1365   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
1366     result.o1 = o1
1367   rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
1368     result.o3 = o3
1369   end
1370   write_result(result, oprot, 'drop_table', seqid)
1371 end
process_drop_type(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1272 def process_drop_type(seqid, iprot, oprot)
1273   args = read_args(iprot, Drop_type_args)
1274   result = Drop_type_result.new()
1275   begin
1276     result.success = @handler.drop_type(args.type)
1277   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1278     result.o1 = o1
1279   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
1280     result.o2 = o2
1281   end
1282   write_result(result, oprot, 'drop_type', seqid)
1283 end
process_get_all_databases(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1220 def process_get_all_databases(seqid, iprot, oprot)
1221   args = read_args(iprot, Get_all_databases_args)
1222   result = Get_all_databases_result.new()
1223   begin
1224     result.success = @handler.get_all_databases()
1225   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1226     result.o1 = o1
1227   end
1228   write_result(result, oprot, 'get_all_databases', seqid)
1229 end
process_get_all_tables(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1384 def process_get_all_tables(seqid, iprot, oprot)
1385   args = read_args(iprot, Get_all_tables_args)
1386   result = Get_all_tables_result.new()
1387   begin
1388     result.success = @handler.get_all_tables(args.db_name)
1389   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1390     result.o1 = o1
1391   end
1392   write_result(result, oprot, 'get_all_tables', seqid)
1393 end
process_get_config_value(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1745 def process_get_config_value(seqid, iprot, oprot)
1746   args = read_args(iprot, Get_config_value_args)
1747   result = Get_config_value_result.new()
1748   begin
1749     result.success = @handler.get_config_value(args.name, args.defaultValue)
1750   rescue ::Impala::Protocol::HiveMetastore::ConfigValSecurityException => o1
1751     result.o1 = o1
1752   end
1753   write_result(result, oprot, 'get_config_value', seqid)
1754 end
process_get_database(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1181 def process_get_database(seqid, iprot, oprot)
1182   args = read_args(iprot, Get_database_args)
1183   result = Get_database_result.new()
1184   begin
1185     result.success = @handler.get_database(args.name)
1186   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
1187     result.o1 = o1
1188   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1189     result.o2 = o2
1190   end
1191   write_result(result, oprot, 'get_database', seqid)
1192 end
process_get_databases(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1209 def process_get_databases(seqid, iprot, oprot)
1210   args = read_args(iprot, Get_databases_args)
1211   result = Get_databases_result.new()
1212   begin
1213     result.success = @handler.get_databases(args.pattern)
1214   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1215     result.o1 = o1
1216   end
1217   write_result(result, oprot, 'get_databases', seqid)
1218 end
process_get_delegation_token(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
2019 def process_get_delegation_token(seqid, iprot, oprot)
2020   args = read_args(iprot, Get_delegation_token_args)
2021   result = Get_delegation_token_result.new()
2022   begin
2023     result.success = @handler.get_delegation_token(args.token_owner, args.renewer_kerberos_principal_name)
2024   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
2025     result.o1 = o1
2026   end
2027   write_result(result, oprot, 'get_delegation_token', seqid)
2028 end
process_get_fields(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1296 def process_get_fields(seqid, iprot, oprot)
1297   args = read_args(iprot, Get_fields_args)
1298   result = Get_fields_result.new()
1299   begin
1300     result.success = @handler.get_fields(args.db_name, args.table_name)
1301   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1302     result.o1 = o1
1303   rescue ::Impala::Protocol::HiveMetastore::UnknownTableException => o2
1304     result.o2 = o2
1305   rescue ::Impala::Protocol::HiveMetastore::UnknownDBException => o3
1306     result.o3 = o3
1307   end
1308   write_result(result, oprot, 'get_fields', seqid)
1309 end
process_get_index_by_name(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1861 def process_get_index_by_name(seqid, iprot, oprot)
1862   args = read_args(iprot, Get_index_by_name_args)
1863   result = Get_index_by_name_result.new()
1864   begin
1865     result.success = @handler.get_index_by_name(args.db_name, args.tbl_name, args.index_name)
1866   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1867     result.o1 = o1
1868   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
1869     result.o2 = o2
1870   end
1871   write_result(result, oprot, 'get_index_by_name', seqid)
1872 end
process_get_index_names(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1887 def process_get_index_names(seqid, iprot, oprot)
1888   args = read_args(iprot, Get_index_names_args)
1889   result = Get_index_names_result.new()
1890   begin
1891     result.success = @handler.get_index_names(args.db_name, args.tbl_name, args.max_indexes)
1892   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1893     result.o2 = o2
1894   end
1895   write_result(result, oprot, 'get_index_names', seqid)
1896 end
process_get_indexes(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1874 def process_get_indexes(seqid, iprot, oprot)
1875   args = read_args(iprot, Get_indexes_args)
1876   result = Get_indexes_result.new()
1877   begin
1878     result.success = @handler.get_indexes(args.db_name, args.tbl_name, args.max_indexes)
1879   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
1880     result.o1 = o1
1881   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1882     result.o2 = o2
1883   end
1884   write_result(result, oprot, 'get_indexes', seqid)
1885 end
process_get_partition(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1565 def process_get_partition(seqid, iprot, oprot)
1566   args = read_args(iprot, Get_partition_args)
1567   result = Get_partition_result.new()
1568   begin
1569     result.success = @handler.get_partition(args.db_name, args.tbl_name, args.part_vals)
1570   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1571     result.o1 = o1
1572   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
1573     result.o2 = o2
1574   end
1575   write_result(result, oprot, 'get_partition', seqid)
1576 end
process_get_partition_by_name(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1591 def process_get_partition_by_name(seqid, iprot, oprot)
1592   args = read_args(iprot, Get_partition_by_name_args)
1593   result = Get_partition_by_name_result.new()
1594   begin
1595     result.success = @handler.get_partition_by_name(args.db_name, args.tbl_name, args.part_name)
1596   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1597     result.o1 = o1
1598   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
1599     result.o2 = o2
1600   end
1601   write_result(result, oprot, 'get_partition_by_name', seqid)
1602 end
process_get_partition_names(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1630 def process_get_partition_names(seqid, iprot, oprot)
1631   args = read_args(iprot, Get_partition_names_args)
1632   result = Get_partition_names_result.new()
1633   begin
1634     result.success = @handler.get_partition_names(args.db_name, args.tbl_name, args.max_parts)
1635   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1636     result.o2 = o2
1637   end
1638   write_result(result, oprot, 'get_partition_names', seqid)
1639 end
process_get_partition_names_ps(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1667 def process_get_partition_names_ps(seqid, iprot, oprot)
1668   args = read_args(iprot, Get_partition_names_ps_args)
1669   result = Get_partition_names_ps_result.new()
1670   begin
1671     result.success = @handler.get_partition_names_ps(args.db_name, args.tbl_name, args.part_vals, args.max_parts)
1672   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1673     result.o1 = o1
1674   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
1675     result.o2 = o2
1676   end
1677   write_result(result, oprot, 'get_partition_names_ps', seqid)
1678 end
process_get_partition_with_auth(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1578 def process_get_partition_with_auth(seqid, iprot, oprot)
1579   args = read_args(iprot, Get_partition_with_auth_args)
1580   result = Get_partition_with_auth_result.new()
1581   begin
1582     result.success = @handler.get_partition_with_auth(args.db_name, args.tbl_name, args.part_vals, args.user_name, args.group_names)
1583   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1584     result.o1 = o1
1585   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
1586     result.o2 = o2
1587   end
1588   write_result(result, oprot, 'get_partition_with_auth', seqid)
1589 end
process_get_partitions(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1604 def process_get_partitions(seqid, iprot, oprot)
1605   args = read_args(iprot, Get_partitions_args)
1606   result = Get_partitions_result.new()
1607   begin
1608     result.success = @handler.get_partitions(args.db_name, args.tbl_name, args.max_parts)
1609   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
1610     result.o1 = o1
1611   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1612     result.o2 = o2
1613   end
1614   write_result(result, oprot, 'get_partitions', seqid)
1615 end
process_get_partitions_by_filter(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1680 def process_get_partitions_by_filter(seqid, iprot, oprot)
1681   args = read_args(iprot, Get_partitions_by_filter_args)
1682   result = Get_partitions_by_filter_result.new()
1683   begin
1684     result.success = @handler.get_partitions_by_filter(args.db_name, args.tbl_name, args.filter, args.max_parts)
1685   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1686     result.o1 = o1
1687   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
1688     result.o2 = o2
1689   end
1690   write_result(result, oprot, 'get_partitions_by_filter', seqid)
1691 end
process_get_partitions_by_names(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1693 def process_get_partitions_by_names(seqid, iprot, oprot)
1694   args = read_args(iprot, Get_partitions_by_names_args)
1695   result = Get_partitions_by_names_result.new()
1696   begin
1697     result.success = @handler.get_partitions_by_names(args.db_name, args.tbl_name, args.names)
1698   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1699     result.o1 = o1
1700   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
1701     result.o2 = o2
1702   end
1703   write_result(result, oprot, 'get_partitions_by_names', seqid)
1704 end
process_get_partitions_ps(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1641 def process_get_partitions_ps(seqid, iprot, oprot)
1642   args = read_args(iprot, Get_partitions_ps_args)
1643   result = Get_partitions_ps_result.new()
1644   begin
1645     result.success = @handler.get_partitions_ps(args.db_name, args.tbl_name, args.part_vals, args.max_parts)
1646   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1647     result.o1 = o1
1648   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
1649     result.o2 = o2
1650   end
1651   write_result(result, oprot, 'get_partitions_ps', seqid)
1652 end
process_get_partitions_ps_with_auth(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1654 def process_get_partitions_ps_with_auth(seqid, iprot, oprot)
1655   args = read_args(iprot, Get_partitions_ps_with_auth_args)
1656   result = Get_partitions_ps_with_auth_result.new()
1657   begin
1658     result.success = @handler.get_partitions_ps_with_auth(args.db_name, args.tbl_name, args.part_vals, args.max_parts, args.user_name, args.group_names)
1659   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
1660     result.o1 = o1
1661   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1662     result.o2 = o2
1663   end
1664   write_result(result, oprot, 'get_partitions_ps_with_auth', seqid)
1665 end
process_get_partitions_with_auth(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1617 def process_get_partitions_with_auth(seqid, iprot, oprot)
1618   args = read_args(iprot, Get_partitions_with_auth_args)
1619   result = Get_partitions_with_auth_result.new()
1620   begin
1621     result.success = @handler.get_partitions_with_auth(args.db_name, args.tbl_name, args.max_parts, args.user_name, args.group_names)
1622   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
1623     result.o1 = o1
1624   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1625     result.o2 = o2
1626   end
1627   write_result(result, oprot, 'get_partitions_with_auth', seqid)
1628 end
process_get_privilege_set(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1964 def process_get_privilege_set(seqid, iprot, oprot)
1965   args = read_args(iprot, Get_privilege_set_args)
1966   result = Get_privilege_set_result.new()
1967   begin
1968     result.success = @handler.get_privilege_set(args.hiveObject, args.user_name, args.group_names)
1969   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1970     result.o1 = o1
1971   end
1972   write_result(result, oprot, 'get_privilege_set', seqid)
1973 end
process_get_role_names(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1920 def process_get_role_names(seqid, iprot, oprot)
1921   args = read_args(iprot, Get_role_names_args)
1922   result = Get_role_names_result.new()
1923   begin
1924     result.success = @handler.get_role_names()
1925   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1926     result.o1 = o1
1927   end
1928   write_result(result, oprot, 'get_role_names', seqid)
1929 end
process_get_schema(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1311 def process_get_schema(seqid, iprot, oprot)
1312   args = read_args(iprot, Get_schema_args)
1313   result = Get_schema_result.new()
1314   begin
1315     result.success = @handler.get_schema(args.db_name, args.table_name)
1316   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1317     result.o1 = o1
1318   rescue ::Impala::Protocol::HiveMetastore::UnknownTableException => o2
1319     result.o2 = o2
1320   rescue ::Impala::Protocol::HiveMetastore::UnknownDBException => o3
1321     result.o3 = o3
1322   end
1323   write_result(result, oprot, 'get_schema', seqid)
1324 end
process_get_table(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1395 def process_get_table(seqid, iprot, oprot)
1396   args = read_args(iprot, Get_table_args)
1397   result = Get_table_result.new()
1398   begin
1399     result.success = @handler.get_table(args.dbname, args.tbl_name)
1400   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1401     result.o1 = o1
1402   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
1403     result.o2 = o2
1404   end
1405   write_result(result, oprot, 'get_table', seqid)
1406 end
process_get_table_names_by_filter(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1423 def process_get_table_names_by_filter(seqid, iprot, oprot)
1424   args = read_args(iprot, Get_table_names_by_filter_args)
1425   result = Get_table_names_by_filter_result.new()
1426   begin
1427     result.success = @handler.get_table_names_by_filter(args.dbname, args.filter, args.max_tables)
1428   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1429     result.o1 = o1
1430   rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o2
1431     result.o2 = o2
1432   rescue ::Impala::Protocol::HiveMetastore::UnknownDBException => o3
1433     result.o3 = o3
1434   end
1435   write_result(result, oprot, 'get_table_names_by_filter', seqid)
1436 end
process_get_table_objects_by_name(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1408 def process_get_table_objects_by_name(seqid, iprot, oprot)
1409   args = read_args(iprot, Get_table_objects_by_name_args)
1410   result = Get_table_objects_by_name_result.new()
1411   begin
1412     result.success = @handler.get_table_objects_by_name(args.dbname, args.tbl_names)
1413   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1414     result.o1 = o1
1415   rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o2
1416     result.o2 = o2
1417   rescue ::Impala::Protocol::HiveMetastore::UnknownDBException => o3
1418     result.o3 = o3
1419   end
1420   write_result(result, oprot, 'get_table_objects_by_name', seqid)
1421 end
process_get_tables(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1373 def process_get_tables(seqid, iprot, oprot)
1374   args = read_args(iprot, Get_tables_args)
1375   result = Get_tables_result.new()
1376   begin
1377     result.success = @handler.get_tables(args.db_name, args.pattern)
1378   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1379     result.o1 = o1
1380   end
1381   write_result(result, oprot, 'get_tables', seqid)
1382 end
process_get_type(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1244 def process_get_type(seqid, iprot, oprot)
1245   args = read_args(iprot, Get_type_args)
1246   result = Get_type_result.new()
1247   begin
1248     result.success = @handler.get_type(args.name)
1249   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1250     result.o1 = o1
1251   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
1252     result.o2 = o2
1253   end
1254   write_result(result, oprot, 'get_type', seqid)
1255 end
process_get_type_all(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1285 def process_get_type_all(seqid, iprot, oprot)
1286   args = read_args(iprot, Get_type_all_args)
1287   result = Get_type_all_result.new()
1288   begin
1289     result.success = @handler.get_type_all(args.name)
1290   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1291     result.o2 = o2
1292   end
1293   write_result(result, oprot, 'get_type_all', seqid)
1294 end
process_grant_privileges(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1986 def process_grant_privileges(seqid, iprot, oprot)
1987   args = read_args(iprot, Grant_privileges_args)
1988   result = Grant_privileges_result.new()
1989   begin
1990     result.success = @handler.grant_privileges(args.privileges)
1991   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1992     result.o1 = o1
1993   end
1994   write_result(result, oprot, 'grant_privileges', seqid)
1995 end
process_grant_role(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1931 def process_grant_role(seqid, iprot, oprot)
1932   args = read_args(iprot, Grant_role_args)
1933   result = Grant_role_result.new()
1934   begin
1935     result.success = @handler.grant_role(args.role_name, args.principal_name, args.principal_type, args.grantor, args.grantorType, args.grant_option)
1936   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1937     result.o1 = o1
1938   end
1939   write_result(result, oprot, 'grant_role', seqid)
1940 end
process_isPartitionMarkedForEvent(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1799 def process_isPartitionMarkedForEvent(seqid, iprot, oprot)
1800   args = read_args(iprot, IsPartitionMarkedForEvent_args)
1801   result = IsPartitionMarkedForEvent_result.new()
1802   begin
1803     result.success = @handler.isPartitionMarkedForEvent(args.db_name, args.tbl_name, args.part_vals, args.eventType)
1804   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1805     result.o1 = o1
1806   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
1807     result.o2 = o2
1808   rescue ::Impala::Protocol::HiveMetastore::UnknownDBException => o3
1809     result.o3 = o3
1810   rescue ::Impala::Protocol::HiveMetastore::UnknownTableException => o4
1811     result.o4 = o4
1812   rescue ::Impala::Protocol::HiveMetastore::UnknownPartitionException => o5
1813     result.o5 = o5
1814   rescue ::Impala::Protocol::HiveMetastore::InvalidPartitionException => o6
1815     result.o6 = o6
1816   end
1817   write_result(result, oprot, 'isPartitionMarkedForEvent', seqid)
1818 end
process_list_privileges(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1975 def process_list_privileges(seqid, iprot, oprot)
1976   args = read_args(iprot, List_privileges_args)
1977   result = List_privileges_result.new()
1978   begin
1979     result.success = @handler.list_privileges(args.principal_name, args.principal_type, args.hiveObject)
1980   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1981     result.o1 = o1
1982   end
1983   write_result(result, oprot, 'list_privileges', seqid)
1984 end
process_list_roles(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1953 def process_list_roles(seqid, iprot, oprot)
1954   args = read_args(iprot, List_roles_args)
1955   result = List_roles_result.new()
1956   begin
1957     result.success = @handler.list_roles(args.principal_name, args.principal_type)
1958   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1959     result.o1 = o1
1960   end
1961   write_result(result, oprot, 'list_roles', seqid)
1962 end
process_markPartitionForEvent(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1778 def process_markPartitionForEvent(seqid, iprot, oprot)
1779   args = read_args(iprot, MarkPartitionForEvent_args)
1780   result = MarkPartitionForEvent_result.new()
1781   begin
1782     @handler.markPartitionForEvent(args.db_name, args.tbl_name, args.part_vals, args.eventType)
1783   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1784     result.o1 = o1
1785   rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
1786     result.o2 = o2
1787   rescue ::Impala::Protocol::HiveMetastore::UnknownDBException => o3
1788     result.o3 = o3
1789   rescue ::Impala::Protocol::HiveMetastore::UnknownTableException => o4
1790     result.o4 = o4
1791   rescue ::Impala::Protocol::HiveMetastore::UnknownPartitionException => o5
1792     result.o5 = o5
1793   rescue ::Impala::Protocol::HiveMetastore::InvalidPartitionException => o6
1794     result.o6 = o6
1795   end
1796   write_result(result, oprot, 'markPartitionForEvent', seqid)
1797 end
process_partition_name_to_spec(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1767 def process_partition_name_to_spec(seqid, iprot, oprot)
1768   args = read_args(iprot, Partition_name_to_spec_args)
1769   result = Partition_name_to_spec_result.new()
1770   begin
1771     result.success = @handler.partition_name_to_spec(args.part_name)
1772   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1773     result.o1 = o1
1774   end
1775   write_result(result, oprot, 'partition_name_to_spec', seqid)
1776 end
process_partition_name_to_vals(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1756 def process_partition_name_to_vals(seqid, iprot, oprot)
1757   args = read_args(iprot, Partition_name_to_vals_args)
1758   result = Partition_name_to_vals_result.new()
1759   begin
1760     result.success = @handler.partition_name_to_vals(args.part_name)
1761   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1762     result.o1 = o1
1763   end
1764   write_result(result, oprot, 'partition_name_to_vals', seqid)
1765 end
process_rename_partition(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1732 def process_rename_partition(seqid, iprot, oprot)
1733   args = read_args(iprot, Rename_partition_args)
1734   result = Rename_partition_result.new()
1735   begin
1736     @handler.rename_partition(args.db_name, args.tbl_name, args.part_vals, args.new_part)
1737   rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o1
1738     result.o1 = o1
1739   rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
1740     result.o2 = o2
1741   end
1742   write_result(result, oprot, 'rename_partition', seqid)
1743 end
process_renew_delegation_token(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
2030 def process_renew_delegation_token(seqid, iprot, oprot)
2031   args = read_args(iprot, Renew_delegation_token_args)
2032   result = Renew_delegation_token_result.new()
2033   begin
2034     result.success = @handler.renew_delegation_token(args.token_str_form)
2035   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
2036     result.o1 = o1
2037   end
2038   write_result(result, oprot, 'renew_delegation_token', seqid)
2039 end
process_revoke_privileges(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1997 def process_revoke_privileges(seqid, iprot, oprot)
1998   args = read_args(iprot, Revoke_privileges_args)
1999   result = Revoke_privileges_result.new()
2000   begin
2001     result.success = @handler.revoke_privileges(args.privileges)
2002   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
2003     result.o1 = o1
2004   end
2005   write_result(result, oprot, 'revoke_privileges', seqid)
2006 end
process_revoke_role(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
1942 def process_revoke_role(seqid, iprot, oprot)
1943   args = read_args(iprot, Revoke_role_args)
1944   result = Revoke_role_result.new()
1945   begin
1946     result.success = @handler.revoke_role(args.role_name, args.principal_name, args.principal_type)
1947   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
1948     result.o1 = o1
1949   end
1950   write_result(result, oprot, 'revoke_role', seqid)
1951 end
process_set_ugi(seqid, iprot, oprot) click to toggle source
     # File lib/impala/protocol/thrift_hive_metastore.rb
2008 def process_set_ugi(seqid, iprot, oprot)
2009   args = read_args(iprot, Set_ugi_args)
2010   result = Set_ugi_result.new()
2011   begin
2012     result.success = @handler.set_ugi(args.user_name, args.group_names)
2013   rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
2014     result.o1 = o1
2015   end
2016   write_result(result, oprot, 'set_ugi', seqid)
2017 end