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