class ThriftHiveMetastore::Processor
Public Instance Methods
process_add_index(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1444 def process_add_index(seqid, iprot, oprot) 1445 args = read_args(iprot, Add_index_args) 1446 result = Add_index_result.new() 1447 begin 1448 result.success = @handler.add_index(args.new_index, args.index_table) 1449 rescue ::InvalidObjectException => o1 1450 result.o1 = o1 1451 rescue ::AlreadyExistsException => o2 1452 result.o2 = o2 1453 rescue ::MetaException => o3 1454 result.o3 = o3 1455 end 1456 write_result(result, oprot, 'add_index', seqid) 1457 end
process_add_partition(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1203 def process_add_partition(seqid, iprot, oprot) 1204 args = read_args(iprot, Add_partition_args) 1205 result = Add_partition_result.new() 1206 begin 1207 result.success = @handler.add_partition(args.new_part) 1208 rescue ::InvalidObjectException => o1 1209 result.o1 = o1 1210 rescue ::AlreadyExistsException => o2 1211 result.o2 = o2 1212 rescue ::MetaException => o3 1213 result.o3 = o3 1214 end 1215 write_result(result, oprot, 'add_partition', seqid) 1216 end
process_alter_database(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1030 def process_alter_database(seqid, iprot, oprot) 1031 args = read_args(iprot, Alter_database_args) 1032 result = Alter_database_result.new() 1033 begin 1034 @handler.alter_database(args.dbname, args.db) 1035 rescue ::MetaException => o1 1036 result.o1 = o1 1037 rescue ::NoSuchObjectException => o2 1038 result.o2 = o2 1039 end 1040 write_result(result, oprot, 'alter_database', seqid) 1041 end
process_alter_index(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1459 def process_alter_index(seqid, iprot, oprot) 1460 args = read_args(iprot, Alter_index_args) 1461 result = Alter_index_result.new() 1462 begin 1463 @handler.alter_index(args.dbname, args.base_tbl_name, args.idx_name, args.new_idx) 1464 rescue ::InvalidOperationException => o1 1465 result.o1 = o1 1466 rescue ::MetaException => o2 1467 result.o2 = o2 1468 end 1469 write_result(result, oprot, 'alter_index', seqid) 1470 end
process_alter_partition(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1398 def process_alter_partition(seqid, iprot, oprot) 1399 args = read_args(iprot, Alter_partition_args) 1400 result = Alter_partition_result.new() 1401 begin 1402 @handler.alter_partition(args.db_name, args.tbl_name, args.new_part) 1403 rescue ::InvalidOperationException => o1 1404 result.o1 = o1 1405 rescue ::MetaException => o2 1406 result.o2 = o2 1407 end 1408 write_result(result, oprot, 'alter_partition', seqid) 1409 end
process_alter_table(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1190 def process_alter_table(seqid, iprot, oprot) 1191 args = read_args(iprot, Alter_table_args) 1192 result = Alter_table_result.new() 1193 begin 1194 @handler.alter_table(args.dbname, args.tbl_name, args.new_tbl) 1195 rescue ::InvalidOperationException => o1 1196 result.o1 = o1 1197 rescue ::MetaException => o2 1198 result.o2 = o2 1199 end 1200 write_result(result, oprot, 'alter_table', seqid) 1201 end
process_append_partition(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1218 def process_append_partition(seqid, iprot, oprot) 1219 args = read_args(iprot, Append_partition_args) 1220 result = Append_partition_result.new() 1221 begin 1222 result.success = @handler.append_partition(args.db_name, args.tbl_name, args.part_vals) 1223 rescue ::InvalidObjectException => o1 1224 result.o1 = o1 1225 rescue ::AlreadyExistsException => o2 1226 result.o2 = o2 1227 rescue ::MetaException => o3 1228 result.o3 = o3 1229 end 1230 write_result(result, oprot, 'append_partition', seqid) 1231 end
process_append_partition_by_name(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1233 def process_append_partition_by_name(seqid, iprot, oprot) 1234 args = read_args(iprot, Append_partition_by_name_args) 1235 result = Append_partition_by_name_result.new() 1236 begin 1237 result.success = @handler.append_partition_by_name(args.db_name, args.tbl_name, args.part_name) 1238 rescue ::InvalidObjectException => o1 1239 result.o1 = o1 1240 rescue ::AlreadyExistsException => o2 1241 result.o2 = o2 1242 rescue ::MetaException => o3 1243 result.o3 = o3 1244 end 1245 write_result(result, oprot, 'append_partition_by_name', seqid) 1246 end
process_cancel_delegation_token(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1665 def process_cancel_delegation_token(seqid, iprot, oprot) 1666 args = read_args(iprot, Cancel_delegation_token_args) 1667 result = Cancel_delegation_token_result.new() 1668 begin 1669 @handler.cancel_delegation_token(args.token_str_form) 1670 rescue ::MetaException => o1 1671 result.o1 = o1 1672 end 1673 write_result(result, oprot, 'cancel_delegation_token', seqid) 1674 end
process_create_database(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 965 def process_create_database(seqid, iprot, oprot) 966 args = read_args(iprot, Create_database_args) 967 result = Create_database_result.new() 968 begin 969 @handler.create_database(args.database) 970 rescue ::AlreadyExistsException => o1 971 result.o1 = o1 972 rescue ::InvalidObjectException => o2 973 result.o2 = o2 974 rescue ::MetaException => o3 975 result.o3 = o3 976 end 977 write_result(result, oprot, 'create_database', seqid) 978 end
process_create_role(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1522 def process_create_role(seqid, iprot, oprot) 1523 args = read_args(iprot, Create_role_args) 1524 result = Create_role_result.new() 1525 begin 1526 result.success = @handler.create_role(args.role) 1527 rescue ::MetaException => o1 1528 result.o1 = o1 1529 end 1530 write_result(result, oprot, 'create_role', seqid) 1531 end
process_create_table(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1125 def process_create_table(seqid, iprot, oprot) 1126 args = read_args(iprot, Create_table_args) 1127 result = Create_table_result.new() 1128 begin 1129 @handler.create_table(args.tbl) 1130 rescue ::AlreadyExistsException => o1 1131 result.o1 = o1 1132 rescue ::InvalidObjectException => o2 1133 result.o2 = o2 1134 rescue ::MetaException => o3 1135 result.o3 = o3 1136 rescue ::NoSuchObjectException => o4 1137 result.o4 = o4 1138 end 1139 write_result(result, oprot, 'create_table', seqid) 1140 end
process_create_type(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1056 def process_create_type(seqid, iprot, oprot) 1057 args = read_args(iprot, Create_type_args) 1058 result = Create_type_result.new() 1059 begin 1060 result.success = @handler.create_type(args.type) 1061 rescue ::AlreadyExistsException => o1 1062 result.o1 = o1 1063 rescue ::InvalidObjectException => o2 1064 result.o2 = o2 1065 rescue ::MetaException => o3 1066 result.o3 = o3 1067 end 1068 write_result(result, oprot, 'create_type', seqid) 1069 end
process_drop_database(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 993 def process_drop_database(seqid, iprot, oprot) 994 args = read_args(iprot, Drop_database_args) 995 result = Drop_database_result.new() 996 begin 997 @handler.drop_database(args.name, args.deleteData) 998 rescue ::NoSuchObjectException => o1 999 result.o1 = o1 1000 rescue ::InvalidOperationException => o2 1001 result.o2 = o2 1002 rescue ::MetaException => o3 1003 result.o3 = o3 1004 end 1005 write_result(result, oprot, 'drop_database', seqid) 1006 end
process_drop_index_by_name(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1472 def process_drop_index_by_name(seqid, iprot, oprot) 1473 args = read_args(iprot, Drop_index_by_name_args) 1474 result = Drop_index_by_name_result.new() 1475 begin 1476 result.success = @handler.drop_index_by_name(args.db_name, args.tbl_name, args.index_name, args.deleteData) 1477 rescue ::NoSuchObjectException => o1 1478 result.o1 = o1 1479 rescue ::MetaException => o2 1480 result.o2 = o2 1481 end 1482 write_result(result, oprot, 'drop_index_by_name', seqid) 1483 end
process_drop_partition(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1248 def process_drop_partition(seqid, iprot, oprot) 1249 args = read_args(iprot, Drop_partition_args) 1250 result = Drop_partition_result.new() 1251 begin 1252 result.success = @handler.drop_partition(args.db_name, args.tbl_name, args.part_vals, args.deleteData) 1253 rescue ::NoSuchObjectException => o1 1254 result.o1 = o1 1255 rescue ::MetaException => o2 1256 result.o2 = o2 1257 end 1258 write_result(result, oprot, 'drop_partition', seqid) 1259 end
process_drop_partition_by_name(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1261 def process_drop_partition_by_name(seqid, iprot, oprot) 1262 args = read_args(iprot, Drop_partition_by_name_args) 1263 result = Drop_partition_by_name_result.new() 1264 begin 1265 result.success = @handler.drop_partition_by_name(args.db_name, args.tbl_name, args.part_name, args.deleteData) 1266 rescue ::NoSuchObjectException => o1 1267 result.o1 = o1 1268 rescue ::MetaException => o2 1269 result.o2 = o2 1270 end 1271 write_result(result, oprot, 'drop_partition_by_name', seqid) 1272 end
process_drop_role(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1533 def process_drop_role(seqid, iprot, oprot) 1534 args = read_args(iprot, Drop_role_args) 1535 result = Drop_role_result.new() 1536 begin 1537 result.success = @handler.drop_role(args.role_name) 1538 rescue ::MetaException => o1 1539 result.o1 = o1 1540 end 1541 write_result(result, oprot, 'drop_role', seqid) 1542 end
process_drop_table(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1142 def process_drop_table(seqid, iprot, oprot) 1143 args = read_args(iprot, Drop_table_args) 1144 result = Drop_table_result.new() 1145 begin 1146 @handler.drop_table(args.dbname, args.name, args.deleteData) 1147 rescue ::NoSuchObjectException => o1 1148 result.o1 = o1 1149 rescue ::MetaException => o3 1150 result.o3 = o3 1151 end 1152 write_result(result, oprot, 'drop_table', seqid) 1153 end
process_drop_type(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1071 def process_drop_type(seqid, iprot, oprot) 1072 args = read_args(iprot, Drop_type_args) 1073 result = Drop_type_result.new() 1074 begin 1075 result.success = @handler.drop_type(args.type) 1076 rescue ::MetaException => o1 1077 result.o1 = o1 1078 rescue ::NoSuchObjectException => o2 1079 result.o2 = o2 1080 end 1081 write_result(result, oprot, 'drop_type', seqid) 1082 end
process_get_all_databases(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1019 def process_get_all_databases(seqid, iprot, oprot) 1020 args = read_args(iprot, Get_all_databases_args) 1021 result = Get_all_databases_result.new() 1022 begin 1023 result.success = @handler.get_all_databases() 1024 rescue ::MetaException => o1 1025 result.o1 = o1 1026 end 1027 write_result(result, oprot, 'get_all_databases', seqid) 1028 end
process_get_all_tables(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1166 def process_get_all_tables(seqid, iprot, oprot) 1167 args = read_args(iprot, Get_all_tables_args) 1168 result = Get_all_tables_result.new() 1169 begin 1170 result.success = @handler.get_all_tables(args.db_name) 1171 rescue ::MetaException => o1 1172 result.o1 = o1 1173 end 1174 write_result(result, oprot, 'get_all_tables', seqid) 1175 end
process_get_config_value(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1411 def process_get_config_value(seqid, iprot, oprot) 1412 args = read_args(iprot, Get_config_value_args) 1413 result = Get_config_value_result.new() 1414 begin 1415 result.success = @handler.get_config_value(args.name, args.defaultValue) 1416 rescue ::ConfigValSecurityException => o1 1417 result.o1 = o1 1418 end 1419 write_result(result, oprot, 'get_config_value', seqid) 1420 end
process_get_database(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 980 def process_get_database(seqid, iprot, oprot) 981 args = read_args(iprot, Get_database_args) 982 result = Get_database_result.new() 983 begin 984 result.success = @handler.get_database(args.name) 985 rescue ::NoSuchObjectException => o1 986 result.o1 = o1 987 rescue ::MetaException => o2 988 result.o2 = o2 989 end 990 write_result(result, oprot, 'get_database', seqid) 991 end
process_get_databases(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1008 def process_get_databases(seqid, iprot, oprot) 1009 args = read_args(iprot, Get_databases_args) 1010 result = Get_databases_result.new() 1011 begin 1012 result.success = @handler.get_databases(args.pattern) 1013 rescue ::MetaException => o1 1014 result.o1 = o1 1015 end 1016 write_result(result, oprot, 'get_databases', seqid) 1017 end
process_get_delegation_token(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1632 def process_get_delegation_token(seqid, iprot, oprot) 1633 args = read_args(iprot, Get_delegation_token_args) 1634 result = Get_delegation_token_result.new() 1635 begin 1636 result.success = @handler.get_delegation_token(args.renewer_kerberos_principal_name) 1637 rescue ::MetaException => o1 1638 result.o1 = o1 1639 end 1640 write_result(result, oprot, 'get_delegation_token', seqid) 1641 end
process_get_delegation_token_with_signature(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1643 def process_get_delegation_token_with_signature(seqid, iprot, oprot) 1644 args = read_args(iprot, Get_delegation_token_with_signature_args) 1645 result = Get_delegation_token_with_signature_result.new() 1646 begin 1647 result.success = @handler.get_delegation_token_with_signature(args.renewer_kerberos_principal_name, args.token_signature) 1648 rescue ::MetaException => o1 1649 result.o1 = o1 1650 end 1651 write_result(result, oprot, 'get_delegation_token_with_signature', seqid) 1652 end
process_get_fields(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1095 def process_get_fields(seqid, iprot, oprot) 1096 args = read_args(iprot, Get_fields_args) 1097 result = Get_fields_result.new() 1098 begin 1099 result.success = @handler.get_fields(args.db_name, args.table_name) 1100 rescue ::MetaException => o1 1101 result.o1 = o1 1102 rescue ::UnknownTableException => o2 1103 result.o2 = o2 1104 rescue ::UnknownDBException => o3 1105 result.o3 = o3 1106 end 1107 write_result(result, oprot, 'get_fields', seqid) 1108 end
process_get_index_by_name(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1485 def process_get_index_by_name(seqid, iprot, oprot) 1486 args = read_args(iprot, Get_index_by_name_args) 1487 result = Get_index_by_name_result.new() 1488 begin 1489 result.success = @handler.get_index_by_name(args.db_name, args.tbl_name, args.index_name) 1490 rescue ::MetaException => o1 1491 result.o1 = o1 1492 rescue ::NoSuchObjectException => o2 1493 result.o2 = o2 1494 end 1495 write_result(result, oprot, 'get_index_by_name', seqid) 1496 end
process_get_index_names(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1511 def process_get_index_names(seqid, iprot, oprot) 1512 args = read_args(iprot, Get_index_names_args) 1513 result = Get_index_names_result.new() 1514 begin 1515 result.success = @handler.get_index_names(args.db_name, args.tbl_name, args.max_indexes) 1516 rescue ::MetaException => o2 1517 result.o2 = o2 1518 end 1519 write_result(result, oprot, 'get_index_names', seqid) 1520 end
process_get_indexes(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1498 def process_get_indexes(seqid, iprot, oprot) 1499 args = read_args(iprot, Get_indexes_args) 1500 result = Get_indexes_result.new() 1501 begin 1502 result.success = @handler.get_indexes(args.db_name, args.tbl_name, args.max_indexes) 1503 rescue ::NoSuchObjectException => o1 1504 result.o1 = o1 1505 rescue ::MetaException => o2 1506 result.o2 = o2 1507 end 1508 write_result(result, oprot, 'get_indexes', seqid) 1509 end
process_get_partition(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1274 def process_get_partition(seqid, iprot, oprot) 1275 args = read_args(iprot, Get_partition_args) 1276 result = Get_partition_result.new() 1277 begin 1278 result.success = @handler.get_partition(args.db_name, args.tbl_name, args.part_vals) 1279 rescue ::MetaException => o1 1280 result.o1 = o1 1281 rescue ::NoSuchObjectException => o2 1282 result.o2 = o2 1283 end 1284 write_result(result, oprot, 'get_partition', seqid) 1285 end
process_get_partition_by_name(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1300 def process_get_partition_by_name(seqid, iprot, oprot) 1301 args = read_args(iprot, Get_partition_by_name_args) 1302 result = Get_partition_by_name_result.new() 1303 begin 1304 result.success = @handler.get_partition_by_name(args.db_name, args.tbl_name, args.part_name) 1305 rescue ::MetaException => o1 1306 result.o1 = o1 1307 rescue ::NoSuchObjectException => o2 1308 result.o2 = o2 1309 end 1310 write_result(result, oprot, 'get_partition_by_name', seqid) 1311 end
process_get_partition_names(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1339 def process_get_partition_names(seqid, iprot, oprot) 1340 args = read_args(iprot, Get_partition_names_args) 1341 result = Get_partition_names_result.new() 1342 begin 1343 result.success = @handler.get_partition_names(args.db_name, args.tbl_name, args.max_parts) 1344 rescue ::MetaException => o2 1345 result.o2 = o2 1346 end 1347 write_result(result, oprot, 'get_partition_names', seqid) 1348 end
process_get_partition_names_ps(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1374 def process_get_partition_names_ps(seqid, iprot, oprot) 1375 args = read_args(iprot, Get_partition_names_ps_args) 1376 result = Get_partition_names_ps_result.new() 1377 begin 1378 result.success = @handler.get_partition_names_ps(args.db_name, args.tbl_name, args.part_vals, args.max_parts) 1379 rescue ::MetaException => o1 1380 result.o1 = o1 1381 end 1382 write_result(result, oprot, 'get_partition_names_ps', seqid) 1383 end
process_get_partition_with_auth(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1287 def process_get_partition_with_auth(seqid, iprot, oprot) 1288 args = read_args(iprot, Get_partition_with_auth_args) 1289 result = Get_partition_with_auth_result.new() 1290 begin 1291 result.success = @handler.get_partition_with_auth(args.db_name, args.tbl_name, args.part_vals, args.user_name, args.group_names) 1292 rescue ::MetaException => o1 1293 result.o1 = o1 1294 rescue ::NoSuchObjectException => o2 1295 result.o2 = o2 1296 end 1297 write_result(result, oprot, 'get_partition_with_auth', seqid) 1298 end
process_get_partitions(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1313 def process_get_partitions(seqid, iprot, oprot) 1314 args = read_args(iprot, Get_partitions_args) 1315 result = Get_partitions_result.new() 1316 begin 1317 result.success = @handler.get_partitions(args.db_name, args.tbl_name, args.max_parts) 1318 rescue ::NoSuchObjectException => o1 1319 result.o1 = o1 1320 rescue ::MetaException => o2 1321 result.o2 = o2 1322 end 1323 write_result(result, oprot, 'get_partitions', seqid) 1324 end
process_get_partitions_by_filter(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1385 def process_get_partitions_by_filter(seqid, iprot, oprot) 1386 args = read_args(iprot, Get_partitions_by_filter_args) 1387 result = Get_partitions_by_filter_result.new() 1388 begin 1389 result.success = @handler.get_partitions_by_filter(args.db_name, args.tbl_name, args.filter, args.max_parts) 1390 rescue ::MetaException => o1 1391 result.o1 = o1 1392 rescue ::NoSuchObjectException => o2 1393 result.o2 = o2 1394 end 1395 write_result(result, oprot, 'get_partitions_by_filter', seqid) 1396 end
process_get_partitions_ps(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1350 def process_get_partitions_ps(seqid, iprot, oprot) 1351 args = read_args(iprot, Get_partitions_ps_args) 1352 result = Get_partitions_ps_result.new() 1353 begin 1354 result.success = @handler.get_partitions_ps(args.db_name, args.tbl_name, args.part_vals, args.max_parts) 1355 rescue ::MetaException => o1 1356 result.o1 = o1 1357 end 1358 write_result(result, oprot, 'get_partitions_ps', seqid) 1359 end
process_get_partitions_ps_with_auth(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1361 def process_get_partitions_ps_with_auth(seqid, iprot, oprot) 1362 args = read_args(iprot, Get_partitions_ps_with_auth_args) 1363 result = Get_partitions_ps_with_auth_result.new() 1364 begin 1365 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) 1366 rescue ::NoSuchObjectException => o1 1367 result.o1 = o1 1368 rescue ::MetaException => o2 1369 result.o2 = o2 1370 end 1371 write_result(result, oprot, 'get_partitions_ps_with_auth', seqid) 1372 end
process_get_partitions_with_auth(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1326 def process_get_partitions_with_auth(seqid, iprot, oprot) 1327 args = read_args(iprot, Get_partitions_with_auth_args) 1328 result = Get_partitions_with_auth_result.new() 1329 begin 1330 result.success = @handler.get_partitions_with_auth(args.db_name, args.tbl_name, args.max_parts, args.user_name, args.group_names) 1331 rescue ::NoSuchObjectException => o1 1332 result.o1 = o1 1333 rescue ::MetaException => o2 1334 result.o2 = o2 1335 end 1336 write_result(result, oprot, 'get_partitions_with_auth', seqid) 1337 end
process_get_privilege_set(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1588 def process_get_privilege_set(seqid, iprot, oprot) 1589 args = read_args(iprot, Get_privilege_set_args) 1590 result = Get_privilege_set_result.new() 1591 begin 1592 result.success = @handler.get_privilege_set(args.hiveObject, args.user_name, args.group_names) 1593 rescue ::MetaException => o1 1594 result.o1 = o1 1595 end 1596 write_result(result, oprot, 'get_privilege_set', seqid) 1597 end
process_get_role_names(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1544 def process_get_role_names(seqid, iprot, oprot) 1545 args = read_args(iprot, Get_role_names_args) 1546 result = Get_role_names_result.new() 1547 begin 1548 result.success = @handler.get_role_names() 1549 rescue ::MetaException => o1 1550 result.o1 = o1 1551 end 1552 write_result(result, oprot, 'get_role_names', seqid) 1553 end
process_get_schema(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1110 def process_get_schema(seqid, iprot, oprot) 1111 args = read_args(iprot, Get_schema_args) 1112 result = Get_schema_result.new() 1113 begin 1114 result.success = @handler.get_schema(args.db_name, args.table_name) 1115 rescue ::MetaException => o1 1116 result.o1 = o1 1117 rescue ::UnknownTableException => o2 1118 result.o2 = o2 1119 rescue ::UnknownDBException => o3 1120 result.o3 = o3 1121 end 1122 write_result(result, oprot, 'get_schema', seqid) 1123 end
process_get_table(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1177 def process_get_table(seqid, iprot, oprot) 1178 args = read_args(iprot, Get_table_args) 1179 result = Get_table_result.new() 1180 begin 1181 result.success = @handler.get_table(args.dbname, args.tbl_name) 1182 rescue ::MetaException => o1 1183 result.o1 = o1 1184 rescue ::NoSuchObjectException => o2 1185 result.o2 = o2 1186 end 1187 write_result(result, oprot, 'get_table', seqid) 1188 end
process_get_tables(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1155 def process_get_tables(seqid, iprot, oprot) 1156 args = read_args(iprot, Get_tables_args) 1157 result = Get_tables_result.new() 1158 begin 1159 result.success = @handler.get_tables(args.db_name, args.pattern) 1160 rescue ::MetaException => o1 1161 result.o1 = o1 1162 end 1163 write_result(result, oprot, 'get_tables', seqid) 1164 end
process_get_type(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1043 def process_get_type(seqid, iprot, oprot) 1044 args = read_args(iprot, Get_type_args) 1045 result = Get_type_result.new() 1046 begin 1047 result.success = @handler.get_type(args.name) 1048 rescue ::MetaException => o1 1049 result.o1 = o1 1050 rescue ::NoSuchObjectException => o2 1051 result.o2 = o2 1052 end 1053 write_result(result, oprot, 'get_type', seqid) 1054 end
process_get_type_all(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1084 def process_get_type_all(seqid, iprot, oprot) 1085 args = read_args(iprot, Get_type_all_args) 1086 result = Get_type_all_result.new() 1087 begin 1088 result.success = @handler.get_type_all(args.name) 1089 rescue ::MetaException => o2 1090 result.o2 = o2 1091 end 1092 write_result(result, oprot, 'get_type_all', seqid) 1093 end
process_grant_privileges(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1610 def process_grant_privileges(seqid, iprot, oprot) 1611 args = read_args(iprot, Grant_privileges_args) 1612 result = Grant_privileges_result.new() 1613 begin 1614 result.success = @handler.grant_privileges(args.privileges) 1615 rescue ::MetaException => o1 1616 result.o1 = o1 1617 end 1618 write_result(result, oprot, 'grant_privileges', seqid) 1619 end
process_grant_role(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1555 def process_grant_role(seqid, iprot, oprot) 1556 args = read_args(iprot, Grant_role_args) 1557 result = Grant_role_result.new() 1558 begin 1559 result.success = @handler.grant_role(args.role_name, args.principal_name, args.principal_type, args.grantor, args.grantorType, args.grant_option) 1560 rescue ::MetaException => o1 1561 result.o1 = o1 1562 end 1563 write_result(result, oprot, 'grant_role', seqid) 1564 end
process_list_privileges(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1599 def process_list_privileges(seqid, iprot, oprot) 1600 args = read_args(iprot, List_privileges_args) 1601 result = List_privileges_result.new() 1602 begin 1603 result.success = @handler.list_privileges(args.principal_name, args.principal_type, args.hiveObject) 1604 rescue ::MetaException => o1 1605 result.o1 = o1 1606 end 1607 write_result(result, oprot, 'list_privileges', seqid) 1608 end
process_list_roles(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1577 def process_list_roles(seqid, iprot, oprot) 1578 args = read_args(iprot, List_roles_args) 1579 result = List_roles_result.new() 1580 begin 1581 result.success = @handler.list_roles(args.principal_name, args.principal_type) 1582 rescue ::MetaException => o1 1583 result.o1 = o1 1584 end 1585 write_result(result, oprot, 'list_roles', seqid) 1586 end
process_partition_name_to_spec(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1433 def process_partition_name_to_spec(seqid, iprot, oprot) 1434 args = read_args(iprot, Partition_name_to_spec_args) 1435 result = Partition_name_to_spec_result.new() 1436 begin 1437 result.success = @handler.partition_name_to_spec(args.part_name) 1438 rescue ::MetaException => o1 1439 result.o1 = o1 1440 end 1441 write_result(result, oprot, 'partition_name_to_spec', seqid) 1442 end
process_partition_name_to_vals(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1422 def process_partition_name_to_vals(seqid, iprot, oprot) 1423 args = read_args(iprot, Partition_name_to_vals_args) 1424 result = Partition_name_to_vals_result.new() 1425 begin 1426 result.success = @handler.partition_name_to_vals(args.part_name) 1427 rescue ::MetaException => o1 1428 result.o1 = o1 1429 end 1430 write_result(result, oprot, 'partition_name_to_vals', seqid) 1431 end
process_renew_delegation_token(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1654 def process_renew_delegation_token(seqid, iprot, oprot) 1655 args = read_args(iprot, Renew_delegation_token_args) 1656 result = Renew_delegation_token_result.new() 1657 begin 1658 result.success = @handler.renew_delegation_token(args.token_str_form) 1659 rescue ::MetaException => o1 1660 result.o1 = o1 1661 end 1662 write_result(result, oprot, 'renew_delegation_token', seqid) 1663 end
process_revoke_privileges(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1621 def process_revoke_privileges(seqid, iprot, oprot) 1622 args = read_args(iprot, Revoke_privileges_args) 1623 result = Revoke_privileges_result.new() 1624 begin 1625 result.success = @handler.revoke_privileges(args.privileges) 1626 rescue ::MetaException => o1 1627 result.o1 = o1 1628 end 1629 write_result(result, oprot, 'revoke_privileges', seqid) 1630 end
process_revoke_role(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive_metastore.rb 1566 def process_revoke_role(seqid, iprot, oprot) 1567 args = read_args(iprot, Revoke_role_args) 1568 result = Revoke_role_result.new() 1569 begin 1570 result.success = @handler.revoke_role(args.role_name, args.principal_name, args.principal_type) 1571 rescue ::MetaException => o1 1572 result.o1 = o1 1573 end 1574 write_result(result, oprot, 'revoke_role', seqid) 1575 end