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