Class: Impala::Protocol::HiveMetastore::ThriftHiveMetastore::Processor
Instance Method Summary
collapse
-
#process_add_index(seqid, iprot, oprot) ⇒ Object
-
#process_add_partition(seqid, iprot, oprot) ⇒ Object
-
#process_add_partition_with_environment_context(seqid, iprot, oprot) ⇒ Object
-
#process_add_partitions(seqid, iprot, oprot) ⇒ Object
-
#process_alter_database(seqid, iprot, oprot) ⇒ Object
-
#process_alter_index(seqid, iprot, oprot) ⇒ Object
-
#process_alter_partition(seqid, iprot, oprot) ⇒ Object
-
#process_alter_partition_with_environment_context(seqid, iprot, oprot) ⇒ Object
-
#process_alter_table(seqid, iprot, oprot) ⇒ Object
-
#process_alter_table_with_environment_context(seqid, iprot, oprot) ⇒ Object
-
#process_append_partition(seqid, iprot, oprot) ⇒ Object
-
#process_append_partition_by_name(seqid, iprot, oprot) ⇒ Object
-
#process_cancel_delegation_token(seqid, iprot, oprot) ⇒ Object
-
#process_create_database(seqid, iprot, oprot) ⇒ Object
-
#process_create_role(seqid, iprot, oprot) ⇒ Object
-
#process_create_table(seqid, iprot, oprot) ⇒ Object
-
#process_create_table_with_environment_context(seqid, iprot, oprot) ⇒ Object
-
#process_create_type(seqid, iprot, oprot) ⇒ Object
-
#process_drop_database(seqid, iprot, oprot) ⇒ Object
-
#process_drop_index_by_name(seqid, iprot, oprot) ⇒ Object
-
#process_drop_partition(seqid, iprot, oprot) ⇒ Object
-
#process_drop_partition_by_name(seqid, iprot, oprot) ⇒ Object
-
#process_drop_role(seqid, iprot, oprot) ⇒ Object
-
#process_drop_table(seqid, iprot, oprot) ⇒ Object
-
#process_drop_type(seqid, iprot, oprot) ⇒ Object
-
#process_get_all_databases(seqid, iprot, oprot) ⇒ Object
-
#process_get_all_tables(seqid, iprot, oprot) ⇒ Object
-
#process_get_config_value(seqid, iprot, oprot) ⇒ Object
-
#process_get_database(seqid, iprot, oprot) ⇒ Object
-
#process_get_databases(seqid, iprot, oprot) ⇒ Object
-
#process_get_delegation_token(seqid, iprot, oprot) ⇒ Object
-
#process_get_fields(seqid, iprot, oprot) ⇒ Object
-
#process_get_index_by_name(seqid, iprot, oprot) ⇒ Object
-
#process_get_index_names(seqid, iprot, oprot) ⇒ Object
-
#process_get_indexes(seqid, iprot, oprot) ⇒ Object
-
#process_get_partition(seqid, iprot, oprot) ⇒ Object
-
#process_get_partition_by_name(seqid, iprot, oprot) ⇒ Object
-
#process_get_partition_names(seqid, iprot, oprot) ⇒ Object
-
#process_get_partition_names_ps(seqid, iprot, oprot) ⇒ Object
-
#process_get_partition_with_auth(seqid, iprot, oprot) ⇒ Object
-
#process_get_partitions(seqid, iprot, oprot) ⇒ Object
-
#process_get_partitions_by_filter(seqid, iprot, oprot) ⇒ Object
-
#process_get_partitions_by_names(seqid, iprot, oprot) ⇒ Object
-
#process_get_partitions_ps(seqid, iprot, oprot) ⇒ Object
-
#process_get_partitions_ps_with_auth(seqid, iprot, oprot) ⇒ Object
-
#process_get_partitions_with_auth(seqid, iprot, oprot) ⇒ Object
-
#process_get_privilege_set(seqid, iprot, oprot) ⇒ Object
-
#process_get_role_names(seqid, iprot, oprot) ⇒ Object
-
#process_get_schema(seqid, iprot, oprot) ⇒ Object
-
#process_get_table(seqid, iprot, oprot) ⇒ Object
-
#process_get_table_names_by_filter(seqid, iprot, oprot) ⇒ Object
-
#process_get_table_objects_by_name(seqid, iprot, oprot) ⇒ Object
-
#process_get_tables(seqid, iprot, oprot) ⇒ Object
-
#process_get_type(seqid, iprot, oprot) ⇒ Object
-
#process_get_type_all(seqid, iprot, oprot) ⇒ Object
-
#process_grant_privileges(seqid, iprot, oprot) ⇒ Object
-
#process_grant_role(seqid, iprot, oprot) ⇒ Object
-
#process_isPartitionMarkedForEvent(seqid, iprot, oprot) ⇒ Object
-
#process_list_privileges(seqid, iprot, oprot) ⇒ Object
-
#process_list_roles(seqid, iprot, oprot) ⇒ Object
-
#process_markPartitionForEvent(seqid, iprot, oprot) ⇒ Object
-
#process_partition_name_to_spec(seqid, iprot, oprot) ⇒ Object
-
#process_partition_name_to_vals(seqid, iprot, oprot) ⇒ Object
-
#process_rename_partition(seqid, iprot, oprot) ⇒ Object
-
#process_renew_delegation_token(seqid, iprot, oprot) ⇒ Object
-
#process_revoke_privileges(seqid, iprot, oprot) ⇒ Object
-
#process_revoke_role(seqid, iprot, oprot) ⇒ Object
-
#process_set_ugi(seqid, iprot, oprot) ⇒ Object
#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
#process_add_partition(seqid, iprot, oprot) ⇒ Object
#process_add_partition_with_environment_context(seqid, iprot, oprot) ⇒ Object
#process_add_partitions(seqid, iprot, oprot) ⇒ Object
#process_alter_database(seqid, iprot, oprot) ⇒ Object
#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
#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
#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
#process_append_partition_by_name(seqid, iprot, oprot) ⇒ Object
#process_cancel_delegation_token(seqid, iprot, oprot) ⇒ Object
#process_create_database(seqid, iprot, oprot) ⇒ Object
#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
#process_create_table_with_environment_context(seqid, iprot, oprot) ⇒ Object
#process_create_type(seqid, iprot, oprot) ⇒ Object
#process_drop_database(seqid, iprot, oprot) ⇒ Object
#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
#process_drop_type(seqid, iprot, oprot) ⇒ Object
#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
#process_get_database(seqid, iprot, oprot) ⇒ Object
#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
#process_get_index_by_name(seqid, iprot, oprot) ⇒ Object
#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
#process_get_partition(seqid, iprot, oprot) ⇒ Object
#process_get_partition_by_name(seqid, iprot, oprot) ⇒ Object
#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
#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
#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
#process_get_table(seqid, iprot, oprot) ⇒ Object
#process_get_table_names_by_filter(seqid, iprot, oprot) ⇒ Object
#process_get_table_objects_by_name(seqid, iprot, oprot) ⇒ Object
#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
#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
|