Class: Impala::Protocol::HiveMetastore::ThriftHiveMetastore::Processor

Inherits:
Fb303::FacebookService::Processor show all
Includes:
Thrift::Processor
Defined in:
lib/impala/protocol/thrift_hive_metastore.rb

Instance Method Summary collapse

Methods inherited from Fb303::FacebookService::Processor

#process_aliveSince, #process_getCounter, #process_getCounters, #process_getCpuProfile, #process_getName, #process_getOption, #process_getOptions, #process_getStatus, #process_getStatusDetails, #process_getVersion, #process_reinitialize, #process_setOption, #process_shutdown

Instance Method Details

#process_add_index(seqid, iprot, oprot) ⇒ Object 



1820
1821
1822
1823
1824
1825
1826
1827
1828
1829
1830
1831
1832
1833
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1820

def process_add_index(seqid, iprot, oprot)
  args = read_args(iprot, Add_index_args)
  result = Add_index_result.new()
  begin
    result.success = @handler.add_index(args.new_index, args.index_table)
  rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
    result.o3 = o3
  end
  write_result(result, oprot, 'add_index', seqid)
end

#process_add_partition(seqid, iprot, oprot) ⇒ Object 



1464
1465
1466
1467
1468
1469
1470
1471
1472
1473
1474
1475
1476
1477
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1464

def process_add_partition(seqid, iprot, oprot)
  args = read_args(iprot, Add_partition_args)
  result = Add_partition_result.new()
  begin
    result.success = @handler.add_partition(args.new_part)
  rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
    result.o3 = o3
  end
  write_result(result, oprot, 'add_partition', seqid)
end

#process_add_partition_with_environment_context(seqid, iprot, oprot) ⇒ Object 



1479
1480
1481
1482
1483
1484
1485
1486
1487
1488
1489
1490
1491
1492
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1479

def process_add_partition_with_environment_context(seqid, iprot, oprot)
  args = read_args(iprot, Add_partition_with_environment_context_args)
  result = Add_partition_with_environment_context_result.new()
  begin
    result.success = @handler.add_partition_with_environment_context(args.new_part, args.environment_context)
  rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
    result.o3 = o3
  end
  write_result(result, oprot, 'add_partition_with_environment_context', seqid)
end

#process_add_partitions(seqid, iprot, oprot) ⇒ Object 



1494
1495
1496
1497
1498
1499
1500
1501
1502
1503
1504
1505
1506
1507
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1494

def process_add_partitions(seqid, iprot, oprot)
  args = read_args(iprot, Add_partitions_args)
  result = Add_partitions_result.new()
  begin
    result.success = @handler.add_partitions(args.new_parts)
  rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
    result.o3 = o3
  end
  write_result(result, oprot, 'add_partitions', seqid)
end

#process_alter_database(seqid, iprot, oprot) ⇒ Object 



1231
1232
1233
1234
1235
1236
1237
1238
1239
1240
1241
1242
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1231

def process_alter_database(seqid, iprot, oprot)
  args = read_args(iprot, Alter_database_args)
  result = Alter_database_result.new()
  begin
    @handler.alter_database(args.dbname, args.db)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'alter_database', seqid)
end

#process_alter_index(seqid, iprot, oprot) ⇒ Object 



1835
1836
1837
1838
1839
1840
1841
1842
1843
1844
1845
1846
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1835

def process_alter_index(seqid, iprot, oprot)
  args = read_args(iprot, Alter_index_args)
  result = Alter_index_result.new()
  begin
    @handler.alter_index(args.dbname, args.base_tbl_name, args.idx_name, args.new_idx)
  rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'alter_index', seqid)
end

#process_alter_partition(seqid, iprot, oprot) ⇒ Object 



1706
1707
1708
1709
1710
1711
1712
1713
1714
1715
1716
1717
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1706

def process_alter_partition(seqid, iprot, oprot)
  args = read_args(iprot, Alter_partition_args)
  result = Alter_partition_result.new()
  begin
    @handler.alter_partition(args.db_name, args.tbl_name, args.new_part)
  rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'alter_partition', seqid)
end

#process_alter_partition_with_environment_context(seqid, iprot, oprot) ⇒ Object 



1719
1720
1721
1722
1723
1724
1725
1726
1727
1728
1729
1730
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1719

def process_alter_partition_with_environment_context(seqid, iprot, oprot)
  args = read_args(iprot, Alter_partition_with_environment_context_args)
  result = Alter_partition_with_environment_context_result.new()
  begin
    @handler.alter_partition_with_environment_context(args.db_name, args.tbl_name, args.new_part, args.environment_context)
  rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'alter_partition_with_environment_context', seqid)
end

#process_alter_table(seqid, iprot, oprot) ⇒ Object 



1438
1439
1440
1441
1442
1443
1444
1445
1446
1447
1448
1449
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1438

def process_alter_table(seqid, iprot, oprot)
  args = read_args(iprot, Alter_table_args)
  result = Alter_table_result.new()
  begin
    @handler.alter_table(args.dbname, args.tbl_name, args.new_tbl)
  rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'alter_table', seqid)
end

#process_alter_table_with_environment_context(seqid, iprot, oprot) ⇒ Object 



1451
1452
1453
1454
1455
1456
1457
1458
1459
1460
1461
1462
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1451

def process_alter_table_with_environment_context(seqid, iprot, oprot)
  args = read_args(iprot, Alter_table_with_environment_context_args)
  result = Alter_table_with_environment_context_result.new()
  begin
    @handler.alter_table_with_environment_context(args.dbname, args.tbl_name, args.new_tbl, args.environment_context)
  rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'alter_table_with_environment_context', seqid)
end

#process_append_partition(seqid, iprot, oprot) ⇒ Object 



1509
1510
1511
1512
1513
1514
1515
1516
1517
1518
1519
1520
1521
1522
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1509

def process_append_partition(seqid, iprot, oprot)
  args = read_args(iprot, Append_partition_args)
  result = Append_partition_result.new()
  begin
    result.success = @handler.append_partition(args.db_name, args.tbl_name, args.part_vals)
  rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
    result.o3 = o3
  end
  write_result(result, oprot, 'append_partition', seqid)
end

#process_append_partition_by_name(seqid, iprot, oprot) ⇒ Object 



1524
1525
1526
1527
1528
1529
1530
1531
1532
1533
1534
1535
1536
1537
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1524

def process_append_partition_by_name(seqid, iprot, oprot)
  args = read_args(iprot, Append_partition_by_name_args)
  result = Append_partition_by_name_result.new()
  begin
    result.success = @handler.append_partition_by_name(args.db_name, args.tbl_name, args.part_name)
  rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
    result.o3 = o3
  end
  write_result(result, oprot, 'append_partition_by_name', seqid)
end

#process_cancel_delegation_token(seqid, iprot, oprot) ⇒ Object 



2041
2042
2043
2044
2045
2046
2047
2048
2049
2050
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 2041

def process_cancel_delegation_token(seqid, iprot, oprot)
  args = read_args(iprot, Cancel_delegation_token_args)
  result = Cancel_delegation_token_result.new()
  begin
    @handler.cancel_delegation_token(args.token_str_form)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'cancel_delegation_token', seqid)
end

#process_create_database(seqid, iprot, oprot) ⇒ Object 



1166
1167
1168
1169
1170
1171
1172
1173
1174
1175
1176
1177
1178
1179
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1166

def process_create_database(seqid, iprot, oprot)
  args = read_args(iprot, Create_database_args)
  result = Create_database_result.new()
  begin
    @handler.create_database(args.database)
  rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
    result.o3 = o3
  end
  write_result(result, oprot, 'create_database', seqid)
end

#process_create_role(seqid, iprot, oprot) ⇒ Object 



1898
1899
1900
1901
1902
1903
1904
1905
1906
1907
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1898

def process_create_role(seqid, iprot, oprot)
  args = read_args(iprot, Create_role_args)
  result = Create_role_result.new()
  begin
    result.success = @handler.create_role(args.role)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'create_role', seqid)
end

#process_create_table(seqid, iprot, oprot) ⇒ Object 



1326
1327
1328
1329
1330
1331
1332
1333
1334
1335
1336
1337
1338
1339
1340
1341
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1326

def process_create_table(seqid, iprot, oprot)
  args = read_args(iprot, Create_table_args)
  result = Create_table_result.new()
  begin
    @handler.create_table(args.tbl)
  rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
    result.o3 = o3
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o4
    result.o4 = o4
  end
  write_result(result, oprot, 'create_table', seqid)
end

#process_create_table_with_environment_context(seqid, iprot, oprot) ⇒ Object 



1343
1344
1345
1346
1347
1348
1349
1350
1351
1352
1353
1354
1355
1356
1357
1358
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1343

def process_create_table_with_environment_context(seqid, iprot, oprot)
  args = read_args(iprot, Create_table_with_environment_context_args)
  result = Create_table_with_environment_context_result.new()
  begin
    @handler.create_table_with_environment_context(args.tbl, args.environment_context)
  rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
    result.o3 = o3
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o4
    result.o4 = o4
  end
  write_result(result, oprot, 'create_table_with_environment_context', seqid)
end

#process_create_type(seqid, iprot, oprot) ⇒ Object 



1257
1258
1259
1260
1261
1262
1263
1264
1265
1266
1267
1268
1269
1270
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1257

def process_create_type(seqid, iprot, oprot)
  args = read_args(iprot, Create_type_args)
  result = Create_type_result.new()
  begin
    result.success = @handler.create_type(args.type)
  rescue ::Impala::Protocol::HiveMetastore::AlreadyExistsException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::InvalidObjectException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
    result.o3 = o3
  end
  write_result(result, oprot, 'create_type', seqid)
end

#process_drop_database(seqid, iprot, oprot) ⇒ Object 



1194
1195
1196
1197
1198
1199
1200
1201
1202
1203
1204
1205
1206
1207
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1194

def process_drop_database(seqid, iprot, oprot)
  args = read_args(iprot, Drop_database_args)
  result = Drop_database_result.new()
  begin
    @handler.drop_database(args.name, args.deleteData, args.cascade)
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
    result.o3 = o3
  end
  write_result(result, oprot, 'drop_database', seqid)
end

#process_drop_index_by_name(seqid, iprot, oprot) ⇒ Object 



1848
1849
1850
1851
1852
1853
1854
1855
1856
1857
1858
1859
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1848

def process_drop_index_by_name(seqid, iprot, oprot)
  args = read_args(iprot, Drop_index_by_name_args)
  result = Drop_index_by_name_result.new()
  begin
    result.success = @handler.drop_index_by_name(args.db_name, args.tbl_name, args.index_name, args.deleteData)
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'drop_index_by_name', seqid)
end

#process_drop_partition(seqid, iprot, oprot) ⇒ Object 



1539
1540
1541
1542
1543
1544
1545
1546
1547
1548
1549
1550
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1539

def process_drop_partition(seqid, iprot, oprot)
  args = read_args(iprot, Drop_partition_args)
  result = Drop_partition_result.new()
  begin
    result.success = @handler.drop_partition(args.db_name, args.tbl_name, args.part_vals, args.deleteData)
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'drop_partition', seqid)
end

#process_drop_partition_by_name(seqid, iprot, oprot) ⇒ Object 



1552
1553
1554
1555
1556
1557
1558
1559
1560
1561
1562
1563
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1552

def process_drop_partition_by_name(seqid, iprot, oprot)
  args = read_args(iprot, Drop_partition_by_name_args)
  result = Drop_partition_by_name_result.new()
  begin
    result.success = @handler.drop_partition_by_name(args.db_name, args.tbl_name, args.part_name, args.deleteData)
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'drop_partition_by_name', seqid)
end

#process_drop_role(seqid, iprot, oprot) ⇒ Object 



1909
1910
1911
1912
1913
1914
1915
1916
1917
1918
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1909

def process_drop_role(seqid, iprot, oprot)
  args = read_args(iprot, Drop_role_args)
  result = Drop_role_result.new()
  begin
    result.success = @handler.drop_role(args.role_name)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'drop_role', seqid)
end

#process_drop_table(seqid, iprot, oprot) ⇒ Object 



1360
1361
1362
1363
1364
1365
1366
1367
1368
1369
1370
1371
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1360

def process_drop_table(seqid, iprot, oprot)
  args = read_args(iprot, Drop_table_args)
  result = Drop_table_result.new()
  begin
    @handler.drop_table(args.dbname, args.name, args.deleteData)
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o3
    result.o3 = o3
  end
  write_result(result, oprot, 'drop_table', seqid)
end

#process_drop_type(seqid, iprot, oprot) ⇒ Object 



1272
1273
1274
1275
1276
1277
1278
1279
1280
1281
1282
1283
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1272

def process_drop_type(seqid, iprot, oprot)
  args = read_args(iprot, Drop_type_args)
  result = Drop_type_result.new()
  begin
    result.success = @handler.drop_type(args.type)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'drop_type', seqid)
end

#process_get_all_databases(seqid, iprot, oprot) ⇒ Object 



1220
1221
1222
1223
1224
1225
1226
1227
1228
1229
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1220

def process_get_all_databases(seqid, iprot, oprot)
  args = read_args(iprot, Get_all_databases_args)
  result = Get_all_databases_result.new()
  begin
    result.success = @handler.get_all_databases()
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'get_all_databases', seqid)
end

#process_get_all_tables(seqid, iprot, oprot) ⇒ Object 



1384
1385
1386
1387
1388
1389
1390
1391
1392
1393
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1384

def process_get_all_tables(seqid, iprot, oprot)
  args = read_args(iprot, Get_all_tables_args)
  result = Get_all_tables_result.new()
  begin
    result.success = @handler.get_all_tables(args.db_name)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'get_all_tables', seqid)
end

#process_get_config_value(seqid, iprot, oprot) ⇒ Object 



1745
1746
1747
1748
1749
1750
1751
1752
1753
1754
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1745

def process_get_config_value(seqid, iprot, oprot)
  args = read_args(iprot, Get_config_value_args)
  result = Get_config_value_result.new()
  begin
    result.success = @handler.get_config_value(args.name, args.defaultValue)
  rescue ::Impala::Protocol::HiveMetastore::ConfigValSecurityException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'get_config_value', seqid)
end

#process_get_database(seqid, iprot, oprot) ⇒ Object 



1181
1182
1183
1184
1185
1186
1187
1188
1189
1190
1191
1192
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1181

def process_get_database(seqid, iprot, oprot)
  args = read_args(iprot, Get_database_args)
  result = Get_database_result.new()
  begin
    result.success = @handler.get_database(args.name)
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_database', seqid)
end

#process_get_databases(seqid, iprot, oprot) ⇒ Object 



1209
1210
1211
1212
1213
1214
1215
1216
1217
1218
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1209

def process_get_databases(seqid, iprot, oprot)
  args = read_args(iprot, Get_databases_args)
  result = Get_databases_result.new()
  begin
    result.success = @handler.get_databases(args.pattern)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'get_databases', seqid)
end

#process_get_delegation_token(seqid, iprot, oprot) ⇒ Object 



2019
2020
2021
2022
2023
2024
2025
2026
2027
2028
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 2019

def process_get_delegation_token(seqid, iprot, oprot)
  args = read_args(iprot, Get_delegation_token_args)
  result = Get_delegation_token_result.new()
  begin
    result.success = @handler.get_delegation_token(args.token_owner, args.renewer_kerberos_principal_name)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'get_delegation_token', seqid)
end

#process_get_fields(seqid, iprot, oprot) ⇒ Object 



1296
1297
1298
1299
1300
1301
1302
1303
1304
1305
1306
1307
1308
1309
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1296

def process_get_fields(seqid, iprot, oprot)
  args = read_args(iprot, Get_fields_args)
  result = Get_fields_result.new()
  begin
    result.success = @handler.get_fields(args.db_name, args.table_name)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::UnknownTableException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::UnknownDBException => o3
    result.o3 = o3
  end
  write_result(result, oprot, 'get_fields', seqid)
end

#process_get_index_by_name(seqid, iprot, oprot) ⇒ Object 



1861
1862
1863
1864
1865
1866
1867
1868
1869
1870
1871
1872
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1861

def process_get_index_by_name(seqid, iprot, oprot)
  args = read_args(iprot, Get_index_by_name_args)
  result = Get_index_by_name_result.new()
  begin
    result.success = @handler.get_index_by_name(args.db_name, args.tbl_name, args.index_name)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_index_by_name', seqid)
end

#process_get_index_names(seqid, iprot, oprot) ⇒ Object 



1887
1888
1889
1890
1891
1892
1893
1894
1895
1896
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1887

def process_get_index_names(seqid, iprot, oprot)
  args = read_args(iprot, Get_index_names_args)
  result = Get_index_names_result.new()
  begin
    result.success = @handler.get_index_names(args.db_name, args.tbl_name, args.max_indexes)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_index_names', seqid)
end

#process_get_indexes(seqid, iprot, oprot) ⇒ Object 



1874
1875
1876
1877
1878
1879
1880
1881
1882
1883
1884
1885
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1874

def process_get_indexes(seqid, iprot, oprot)
  args = read_args(iprot, Get_indexes_args)
  result = Get_indexes_result.new()
  begin
    result.success = @handler.get_indexes(args.db_name, args.tbl_name, args.max_indexes)
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_indexes', seqid)
end

#process_get_partition(seqid, iprot, oprot) ⇒ Object 



1565
1566
1567
1568
1569
1570
1571
1572
1573
1574
1575
1576
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1565

def process_get_partition(seqid, iprot, oprot)
  args = read_args(iprot, Get_partition_args)
  result = Get_partition_result.new()
  begin
    result.success = @handler.get_partition(args.db_name, args.tbl_name, args.part_vals)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_partition', seqid)
end

#process_get_partition_by_name(seqid, iprot, oprot) ⇒ Object 



1591
1592
1593
1594
1595
1596
1597
1598
1599
1600
1601
1602
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1591

def process_get_partition_by_name(seqid, iprot, oprot)
  args = read_args(iprot, Get_partition_by_name_args)
  result = Get_partition_by_name_result.new()
  begin
    result.success = @handler.get_partition_by_name(args.db_name, args.tbl_name, args.part_name)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_partition_by_name', seqid)
end

#process_get_partition_names(seqid, iprot, oprot) ⇒ Object 



1630
1631
1632
1633
1634
1635
1636
1637
1638
1639
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1630

def process_get_partition_names(seqid, iprot, oprot)
  args = read_args(iprot, Get_partition_names_args)
  result = Get_partition_names_result.new()
  begin
    result.success = @handler.get_partition_names(args.db_name, args.tbl_name, args.max_parts)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_partition_names', seqid)
end

#process_get_partition_names_ps(seqid, iprot, oprot) ⇒ Object 



1667
1668
1669
1670
1671
1672
1673
1674
1675
1676
1677
1678
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1667

def process_get_partition_names_ps(seqid, iprot, oprot)
  args = read_args(iprot, Get_partition_names_ps_args)
  result = Get_partition_names_ps_result.new()
  begin
    result.success = @handler.get_partition_names_ps(args.db_name, args.tbl_name, args.part_vals, args.max_parts)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_partition_names_ps', seqid)
end

#process_get_partition_with_auth(seqid, iprot, oprot) ⇒ Object 



1578
1579
1580
1581
1582
1583
1584
1585
1586
1587
1588
1589
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1578

def process_get_partition_with_auth(seqid, iprot, oprot)
  args = read_args(iprot, Get_partition_with_auth_args)
  result = Get_partition_with_auth_result.new()
  begin
    result.success = @handler.get_partition_with_auth(args.db_name, args.tbl_name, args.part_vals, args.user_name, args.group_names)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_partition_with_auth', seqid)
end

#process_get_partitions(seqid, iprot, oprot) ⇒ Object 



1604
1605
1606
1607
1608
1609
1610
1611
1612
1613
1614
1615
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1604

def process_get_partitions(seqid, iprot, oprot)
  args = read_args(iprot, Get_partitions_args)
  result = Get_partitions_result.new()
  begin
    result.success = @handler.get_partitions(args.db_name, args.tbl_name, args.max_parts)
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_partitions', seqid)
end

#process_get_partitions_by_filter(seqid, iprot, oprot) ⇒ Object 



1680
1681
1682
1683
1684
1685
1686
1687
1688
1689
1690
1691
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1680

def process_get_partitions_by_filter(seqid, iprot, oprot)
  args = read_args(iprot, Get_partitions_by_filter_args)
  result = Get_partitions_by_filter_result.new()
  begin
    result.success = @handler.get_partitions_by_filter(args.db_name, args.tbl_name, args.filter, args.max_parts)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_partitions_by_filter', seqid)
end

#process_get_partitions_by_names(seqid, iprot, oprot) ⇒ Object 



1693
1694
1695
1696
1697
1698
1699
1700
1701
1702
1703
1704
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1693

def process_get_partitions_by_names(seqid, iprot, oprot)
  args = read_args(iprot, Get_partitions_by_names_args)
  result = Get_partitions_by_names_result.new()
  begin
    result.success = @handler.get_partitions_by_names(args.db_name, args.tbl_name, args.names)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_partitions_by_names', seqid)
end

#process_get_partitions_ps(seqid, iprot, oprot) ⇒ Object 



1641
1642
1643
1644
1645
1646
1647
1648
1649
1650
1651
1652
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1641

def process_get_partitions_ps(seqid, iprot, oprot)
  args = read_args(iprot, Get_partitions_ps_args)
  result = Get_partitions_ps_result.new()
  begin
    result.success = @handler.get_partitions_ps(args.db_name, args.tbl_name, args.part_vals, args.max_parts)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_partitions_ps', seqid)
end

#process_get_partitions_ps_with_auth(seqid, iprot, oprot) ⇒ Object 



1654
1655
1656
1657
1658
1659
1660
1661
1662
1663
1664
1665
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1654

def process_get_partitions_ps_with_auth(seqid, iprot, oprot)
  args = read_args(iprot, Get_partitions_ps_with_auth_args)
  result = Get_partitions_ps_with_auth_result.new()
  begin
    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)
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_partitions_ps_with_auth', seqid)
end

#process_get_partitions_with_auth(seqid, iprot, oprot) ⇒ Object 



1617
1618
1619
1620
1621
1622
1623
1624
1625
1626
1627
1628
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1617

def process_get_partitions_with_auth(seqid, iprot, oprot)
  args = read_args(iprot, Get_partitions_with_auth_args)
  result = Get_partitions_with_auth_result.new()
  begin
    result.success = @handler.get_partitions_with_auth(args.db_name, args.tbl_name, args.max_parts, args.user_name, args.group_names)
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_partitions_with_auth', seqid)
end

#process_get_privilege_set(seqid, iprot, oprot) ⇒ Object 



1964
1965
1966
1967
1968
1969
1970
1971
1972
1973
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1964

def process_get_privilege_set(seqid, iprot, oprot)
  args = read_args(iprot, Get_privilege_set_args)
  result = Get_privilege_set_result.new()
  begin
    result.success = @handler.get_privilege_set(args.hiveObject, args.user_name, args.group_names)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'get_privilege_set', seqid)
end

#process_get_role_names(seqid, iprot, oprot) ⇒ Object 



1920
1921
1922
1923
1924
1925
1926
1927
1928
1929
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1920

def process_get_role_names(seqid, iprot, oprot)
  args = read_args(iprot, Get_role_names_args)
  result = Get_role_names_result.new()
  begin
    result.success = @handler.get_role_names()
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'get_role_names', seqid)
end

#process_get_schema(seqid, iprot, oprot) ⇒ Object 



1311
1312
1313
1314
1315
1316
1317
1318
1319
1320
1321
1322
1323
1324
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1311

def process_get_schema(seqid, iprot, oprot)
  args = read_args(iprot, Get_schema_args)
  result = Get_schema_result.new()
  begin
    result.success = @handler.get_schema(args.db_name, args.table_name)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::UnknownTableException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::UnknownDBException => o3
    result.o3 = o3
  end
  write_result(result, oprot, 'get_schema', seqid)
end

#process_get_table(seqid, iprot, oprot) ⇒ Object 



1395
1396
1397
1398
1399
1400
1401
1402
1403
1404
1405
1406
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1395

def process_get_table(seqid, iprot, oprot)
  args = read_args(iprot, Get_table_args)
  result = Get_table_result.new()
  begin
    result.success = @handler.get_table(args.dbname, args.tbl_name)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_table', seqid)
end

#process_get_table_names_by_filter(seqid, iprot, oprot) ⇒ Object 



1423
1424
1425
1426
1427
1428
1429
1430
1431
1432
1433
1434
1435
1436
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1423

def process_get_table_names_by_filter(seqid, iprot, oprot)
  args = read_args(iprot, Get_table_names_by_filter_args)
  result = Get_table_names_by_filter_result.new()
  begin
    result.success = @handler.get_table_names_by_filter(args.dbname, args.filter, args.max_tables)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::UnknownDBException => o3
    result.o3 = o3
  end
  write_result(result, oprot, 'get_table_names_by_filter', seqid)
end

#process_get_table_objects_by_name(seqid, iprot, oprot) ⇒ Object 



1408
1409
1410
1411
1412
1413
1414
1415
1416
1417
1418
1419
1420
1421
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1408

def process_get_table_objects_by_name(seqid, iprot, oprot)
  args = read_args(iprot, Get_table_objects_by_name_args)
  result = Get_table_objects_by_name_result.new()
  begin
    result.success = @handler.get_table_objects_by_name(args.dbname, args.tbl_names)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::UnknownDBException => o3
    result.o3 = o3
  end
  write_result(result, oprot, 'get_table_objects_by_name', seqid)
end

#process_get_tables(seqid, iprot, oprot) ⇒ Object 



1373
1374
1375
1376
1377
1378
1379
1380
1381
1382
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1373

def process_get_tables(seqid, iprot, oprot)
  args = read_args(iprot, Get_tables_args)
  result = Get_tables_result.new()
  begin
    result.success = @handler.get_tables(args.db_name, args.pattern)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'get_tables', seqid)
end

#process_get_type(seqid, iprot, oprot) ⇒ Object 



1244
1245
1246
1247
1248
1249
1250
1251
1252
1253
1254
1255
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1244

def process_get_type(seqid, iprot, oprot)
  args = read_args(iprot, Get_type_args)
  result = Get_type_result.new()
  begin
    result.success = @handler.get_type(args.name)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_type', seqid)
end

#process_get_type_all(seqid, iprot, oprot) ⇒ Object 



1285
1286
1287
1288
1289
1290
1291
1292
1293
1294
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1285

def process_get_type_all(seqid, iprot, oprot)
  args = read_args(iprot, Get_type_all_args)
  result = Get_type_all_result.new()
  begin
    result.success = @handler.get_type_all(args.name)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'get_type_all', seqid)
end

#process_grant_privileges(seqid, iprot, oprot) ⇒ Object 



1986
1987
1988
1989
1990
1991
1992
1993
1994
1995
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1986

def process_grant_privileges(seqid, iprot, oprot)
  args = read_args(iprot, Grant_privileges_args)
  result = Grant_privileges_result.new()
  begin
    result.success = @handler.grant_privileges(args.privileges)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'grant_privileges', seqid)
end

#process_grant_role(seqid, iprot, oprot) ⇒ Object 



1931
1932
1933
1934
1935
1936
1937
1938
1939
1940
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1931

def process_grant_role(seqid, iprot, oprot)
  args = read_args(iprot, Grant_role_args)
  result = Grant_role_result.new()
  begin
    result.success = @handler.grant_role(args.role_name, args.principal_name, args.principal_type, args.grantor, args.grantorType, args.grant_option)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'grant_role', seqid)
end

#process_isPartitionMarkedForEvent(seqid, iprot, oprot) ⇒ Object 



1799
1800
1801
1802
1803
1804
1805
1806
1807
1808
1809
1810
1811
1812
1813
1814
1815
1816
1817
1818
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1799

def process_isPartitionMarkedForEvent(seqid, iprot, oprot)
  args = read_args(iprot, IsPartitionMarkedForEvent_args)
  result = IsPartitionMarkedForEvent_result.new()
  begin
    result.success = @handler.isPartitionMarkedForEvent(args.db_name, args.tbl_name, args.part_vals, args.eventType)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::UnknownDBException => o3
    result.o3 = o3
  rescue ::Impala::Protocol::HiveMetastore::UnknownTableException => o4
    result.o4 = o4
  rescue ::Impala::Protocol::HiveMetastore::UnknownPartitionException => o5
    result.o5 = o5
  rescue ::Impala::Protocol::HiveMetastore::InvalidPartitionException => o6
    result.o6 = o6
  end
  write_result(result, oprot, 'isPartitionMarkedForEvent', seqid)
end

#process_list_privileges(seqid, iprot, oprot) ⇒ Object 



1975
1976
1977
1978
1979
1980
1981
1982
1983
1984
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1975

def process_list_privileges(seqid, iprot, oprot)
  args = read_args(iprot, List_privileges_args)
  result = List_privileges_result.new()
  begin
    result.success = @handler.list_privileges(args.principal_name, args.principal_type, args.hiveObject)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'list_privileges', seqid)
end

#process_list_roles(seqid, iprot, oprot) ⇒ Object 



1953
1954
1955
1956
1957
1958
1959
1960
1961
1962
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1953

def process_list_roles(seqid, iprot, oprot)
  args = read_args(iprot, List_roles_args)
  result = List_roles_result.new()
  begin
    result.success = @handler.list_roles(args.principal_name, args.principal_type)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'list_roles', seqid)
end

#process_markPartitionForEvent(seqid, iprot, oprot) ⇒ Object 



1778
1779
1780
1781
1782
1783
1784
1785
1786
1787
1788
1789
1790
1791
1792
1793
1794
1795
1796
1797
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1778

def process_markPartitionForEvent(seqid, iprot, oprot)
  args = read_args(iprot, MarkPartitionForEvent_args)
  result = MarkPartitionForEvent_result.new()
  begin
    @handler.markPartitionForEvent(args.db_name, args.tbl_name, args.part_vals, args.eventType)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::NoSuchObjectException => o2
    result.o2 = o2
  rescue ::Impala::Protocol::HiveMetastore::UnknownDBException => o3
    result.o3 = o3
  rescue ::Impala::Protocol::HiveMetastore::UnknownTableException => o4
    result.o4 = o4
  rescue ::Impala::Protocol::HiveMetastore::UnknownPartitionException => o5
    result.o5 = o5
  rescue ::Impala::Protocol::HiveMetastore::InvalidPartitionException => o6
    result.o6 = o6
  end
  write_result(result, oprot, 'markPartitionForEvent', seqid)
end

#process_partition_name_to_spec(seqid, iprot, oprot) ⇒ Object 



1767
1768
1769
1770
1771
1772
1773
1774
1775
1776
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1767

def process_partition_name_to_spec(seqid, iprot, oprot)
  args = read_args(iprot, Partition_name_to_spec_args)
  result = Partition_name_to_spec_result.new()
  begin
    result.success = @handler.partition_name_to_spec(args.part_name)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'partition_name_to_spec', seqid)
end

#process_partition_name_to_vals(seqid, iprot, oprot) ⇒ Object 



1756
1757
1758
1759
1760
1761
1762
1763
1764
1765
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1756

def process_partition_name_to_vals(seqid, iprot, oprot)
  args = read_args(iprot, Partition_name_to_vals_args)
  result = Partition_name_to_vals_result.new()
  begin
    result.success = @handler.partition_name_to_vals(args.part_name)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'partition_name_to_vals', seqid)
end

#process_rename_partition(seqid, iprot, oprot) ⇒ Object 



1732
1733
1734
1735
1736
1737
1738
1739
1740
1741
1742
1743
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1732

def process_rename_partition(seqid, iprot, oprot)
  args = read_args(iprot, Rename_partition_args)
  result = Rename_partition_result.new()
  begin
    @handler.rename_partition(args.db_name, args.tbl_name, args.part_vals, args.new_part)
  rescue ::Impala::Protocol::HiveMetastore::InvalidOperationException => o1
    result.o1 = o1
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o2
    result.o2 = o2
  end
  write_result(result, oprot, 'rename_partition', seqid)
end

#process_renew_delegation_token(seqid, iprot, oprot) ⇒ Object 



2030
2031
2032
2033
2034
2035
2036
2037
2038
2039
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 2030

def process_renew_delegation_token(seqid, iprot, oprot)
  args = read_args(iprot, Renew_delegation_token_args)
  result = Renew_delegation_token_result.new()
  begin
    result.success = @handler.renew_delegation_token(args.token_str_form)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'renew_delegation_token', seqid)
end

#process_revoke_privileges(seqid, iprot, oprot) ⇒ Object 



1997
1998
1999
2000
2001
2002
2003
2004
2005
2006
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1997

def process_revoke_privileges(seqid, iprot, oprot)
  args = read_args(iprot, Revoke_privileges_args)
  result = Revoke_privileges_result.new()
  begin
    result.success = @handler.revoke_privileges(args.privileges)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'revoke_privileges', seqid)
end

#process_revoke_role(seqid, iprot, oprot) ⇒ Object 



1942
1943
1944
1945
1946
1947
1948
1949
1950
1951
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 1942

def process_revoke_role(seqid, iprot, oprot)
  args = read_args(iprot, Revoke_role_args)
  result = Revoke_role_result.new()
  begin
    result.success = @handler.revoke_role(args.role_name, args.principal_name, args.principal_type)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'revoke_role', seqid)
end

#process_set_ugi(seqid, iprot, oprot) ⇒ Object 



2008
2009
2010
2011
2012
2013
2014
2015
2016
2017
 
# File 'lib/impala/protocol/thrift_hive_metastore.rb', line 2008

def process_set_ugi(seqid, iprot, oprot)
  args = read_args(iprot, Set_ugi_args)
  result = Set_ugi_result.new()
  begin
    result.success = @handler.set_ugi(args.user_name, args.group_names)
  rescue ::Impala::Protocol::HiveMetastore::MetaException => o1
    result.o1 = o1
  end
  write_result(result, oprot, 'set_ugi', seqid)
end