소스 검색

HUE-8775 [hive] Regenerate Thrift with older Hive 2 than upstream master

Romain Rigaux 6 년 전
부모
커밋
888a0897ed

+ 44 - 548
apps/beeswax/gen-py/hive_metastore/ThriftHiveMetastore-remote

@@ -26,11 +26,6 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
   print('Functions:')
   print('Functions:')
   print('  string getMetaConf(string key)')
   print('  string getMetaConf(string key)')
   print('  void setMetaConf(string key, string value)')
   print('  void setMetaConf(string key, string value)')
-  print('  void create_catalog(CreateCatalogRequest catalog)')
-  print('  void alter_catalog(AlterCatalogRequest rqst)')
-  print('  GetCatalogResponse get_catalog(GetCatalogRequest catName)')
-  print('  GetCatalogsResponse get_catalogs()')
-  print('  void drop_catalog(DropCatalogRequest catName)')
   print('  void create_database(Database database)')
   print('  void create_database(Database database)')
   print('  Database get_database(string name)')
   print('  Database get_database(string name)')
   print('  void drop_database(string name, bool deleteData, bool cascade)')
   print('  void drop_database(string name, bool deleteData, bool cascade)')
@@ -47,34 +42,21 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
   print('   get_schema_with_environment_context(string db_name, string table_name, EnvironmentContext environment_context)')
   print('   get_schema_with_environment_context(string db_name, string table_name, EnvironmentContext environment_context)')
   print('  void create_table(Table tbl)')
   print('  void create_table(Table tbl)')
   print('  void create_table_with_environment_context(Table tbl, EnvironmentContext environment_context)')
   print('  void create_table_with_environment_context(Table tbl, EnvironmentContext environment_context)')
-  print('  void create_table_with_constraints(Table tbl,  primaryKeys,  foreignKeys,  uniqueConstraints,  notNullConstraints,  defaultConstraints,  checkConstraints)')
+  print('  void create_table_with_constraints(Table tbl,  primaryKeys,  foreignKeys)')
   print('  void drop_constraint(DropConstraintRequest req)')
   print('  void drop_constraint(DropConstraintRequest req)')
   print('  void add_primary_key(AddPrimaryKeyRequest req)')
   print('  void add_primary_key(AddPrimaryKeyRequest req)')
   print('  void add_foreign_key(AddForeignKeyRequest req)')
   print('  void add_foreign_key(AddForeignKeyRequest req)')
-  print('  void add_unique_constraint(AddUniqueConstraintRequest req)')
-  print('  void add_not_null_constraint(AddNotNullConstraintRequest req)')
-  print('  void add_default_constraint(AddDefaultConstraintRequest req)')
-  print('  void add_check_constraint(AddCheckConstraintRequest req)')
   print('  void drop_table(string dbname, string name, bool deleteData)')
   print('  void drop_table(string dbname, string name, bool deleteData)')
   print('  void drop_table_with_environment_context(string dbname, string name, bool deleteData, EnvironmentContext environment_context)')
   print('  void drop_table_with_environment_context(string dbname, string name, bool deleteData, EnvironmentContext environment_context)')
-  print('  void truncate_table(string dbName, string tableName,  partNames)')
-  print('  TruncateTableResponse truncate_table_req(TruncateTableRequest req)')
   print('   get_tables(string db_name, string pattern)')
   print('   get_tables(string db_name, string pattern)')
-  print('   get_tables_by_type(string db_name, string pattern, string tableType)')
-  print('   get_materialized_views_for_rewriting(string db_name)')
   print('   get_table_meta(string db_patterns, string tbl_patterns,  tbl_types)')
   print('   get_table_meta(string db_patterns, string tbl_patterns,  tbl_types)')
   print('   get_all_tables(string db_name)')
   print('   get_all_tables(string db_name)')
   print('  Table get_table(string dbname, string tbl_name)')
   print('  Table get_table(string dbname, string tbl_name)')
   print('   get_table_objects_by_name(string dbname,  tbl_names)')
   print('   get_table_objects_by_name(string dbname,  tbl_names)')
-  print('  GetTableResult get_table_req(GetTableRequest req)')
-  print('  GetTablesResult get_table_objects_by_name_req(GetTablesRequest req)')
-  print('  Materialization get_materialization_invalidation_info(CreationMetadata creation_metadata, string validTxnList)')
-  print('  void update_creation_metadata(string catName, string dbname, string tbl_name, CreationMetadata creation_metadata)')
   print('   get_table_names_by_filter(string dbname, string filter, i16 max_tables)')
   print('   get_table_names_by_filter(string dbname, string filter, i16 max_tables)')
   print('  void alter_table(string dbname, string tbl_name, Table new_tbl)')
   print('  void alter_table(string dbname, string tbl_name, Table new_tbl)')
   print('  void alter_table_with_environment_context(string dbname, string tbl_name, Table new_tbl, EnvironmentContext environment_context)')
   print('  void alter_table_with_environment_context(string dbname, string tbl_name, Table new_tbl, EnvironmentContext environment_context)')
   print('  void alter_table_with_cascade(string dbname, string tbl_name, Table new_tbl, bool cascade)')
   print('  void alter_table_with_cascade(string dbname, string tbl_name, Table new_tbl, bool cascade)')
-  print('  AlterTableResponse alter_table_req(AlterTableRequest req)')
   print('  Partition add_partition(Partition new_part)')
   print('  Partition add_partition(Partition new_part)')
   print('  Partition add_partition_with_environment_context(Partition new_part, EnvironmentContext environment_context)')
   print('  Partition add_partition_with_environment_context(Partition new_part, EnvironmentContext environment_context)')
   print('  i32 add_partitions( new_parts)')
   print('  i32 add_partitions( new_parts)')
@@ -98,7 +80,6 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
   print('   get_partitions_with_auth(string db_name, string tbl_name, i16 max_parts, string user_name,  group_names)')
   print('   get_partitions_with_auth(string db_name, string tbl_name, i16 max_parts, string user_name,  group_names)')
   print('   get_partitions_pspec(string db_name, string tbl_name, i32 max_parts)')
   print('   get_partitions_pspec(string db_name, string tbl_name, i32 max_parts)')
   print('   get_partition_names(string db_name, string tbl_name, i16 max_parts)')
   print('   get_partition_names(string db_name, string tbl_name, i16 max_parts)')
-  print('  PartitionValuesResponse get_partition_values(PartitionValuesRequest request)')
   print('   get_partitions_ps(string db_name, string tbl_name,  part_vals, i16 max_parts)')
   print('   get_partitions_ps(string db_name, string tbl_name,  part_vals, i16 max_parts)')
   print('   get_partitions_ps_with_auth(string db_name, string tbl_name,  part_vals, i16 max_parts, string user_name,  group_names)')
   print('   get_partitions_ps_with_auth(string db_name, string tbl_name,  part_vals, i16 max_parts, string user_name,  group_names)')
   print('   get_partition_names_ps(string db_name, string tbl_name,  part_vals, i16 max_parts)')
   print('   get_partition_names_ps(string db_name, string tbl_name,  part_vals, i16 max_parts)')
@@ -107,30 +88,27 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
   print('  PartitionsByExprResult get_partitions_by_expr(PartitionsByExprRequest req)')
   print('  PartitionsByExprResult get_partitions_by_expr(PartitionsByExprRequest req)')
   print('  i32 get_num_partitions_by_filter(string db_name, string tbl_name, string filter)')
   print('  i32 get_num_partitions_by_filter(string db_name, string tbl_name, string filter)')
   print('   get_partitions_by_names(string db_name, string tbl_name,  names)')
   print('   get_partitions_by_names(string db_name, string tbl_name,  names)')
-  print('  GetPartitionsByNamesResult get_partitions_by_names_req(GetPartitionsByNamesRequest req)')
   print('  void alter_partition(string db_name, string tbl_name, Partition new_part)')
   print('  void alter_partition(string db_name, string tbl_name, Partition new_part)')
   print('  void alter_partitions(string db_name, string tbl_name,  new_parts)')
   print('  void alter_partitions(string db_name, string tbl_name,  new_parts)')
   print('  void alter_partitions_with_environment_context(string db_name, string tbl_name,  new_parts, EnvironmentContext environment_context)')
   print('  void alter_partitions_with_environment_context(string db_name, string tbl_name,  new_parts, EnvironmentContext environment_context)')
-  print('  AlterPartitionsResponse alter_partitions_req(AlterPartitionsRequest req)')
   print('  void alter_partition_with_environment_context(string db_name, string tbl_name, Partition new_part, EnvironmentContext environment_context)')
   print('  void alter_partition_with_environment_context(string db_name, string tbl_name, Partition new_part, EnvironmentContext environment_context)')
   print('  void rename_partition(string db_name, string tbl_name,  part_vals, Partition new_part)')
   print('  void rename_partition(string db_name, string tbl_name,  part_vals, Partition new_part)')
-  print('  RenamePartitionResponse rename_partition_req(RenamePartitionRequest req)')
   print('  bool partition_name_has_valid_characters( part_vals, bool throw_exception)')
   print('  bool partition_name_has_valid_characters( part_vals, bool throw_exception)')
   print('  string get_config_value(string name, string defaultValue)')
   print('  string get_config_value(string name, string defaultValue)')
   print('   partition_name_to_vals(string part_name)')
   print('   partition_name_to_vals(string part_name)')
   print('   partition_name_to_spec(string part_name)')
   print('   partition_name_to_spec(string part_name)')
   print('  void markPartitionForEvent(string db_name, string tbl_name,  part_vals, PartitionEventType eventType)')
   print('  void markPartitionForEvent(string db_name, string tbl_name,  part_vals, PartitionEventType eventType)')
   print('  bool isPartitionMarkedForEvent(string db_name, string tbl_name,  part_vals, PartitionEventType eventType)')
   print('  bool isPartitionMarkedForEvent(string db_name, string tbl_name,  part_vals, PartitionEventType eventType)')
+  print('  Index add_index(Index new_index, Table index_table)')
+  print('  void alter_index(string dbname, string base_tbl_name, string idx_name, Index new_idx)')
+  print('  bool drop_index_by_name(string db_name, string tbl_name, string index_name, bool deleteData)')
+  print('  Index get_index_by_name(string db_name, string tbl_name, string index_name)')
+  print('   get_indexes(string db_name, string tbl_name, i16 max_indexes)')
+  print('   get_index_names(string db_name, string tbl_name, i16 max_indexes)')
   print('  PrimaryKeysResponse get_primary_keys(PrimaryKeysRequest request)')
   print('  PrimaryKeysResponse get_primary_keys(PrimaryKeysRequest request)')
   print('  ForeignKeysResponse get_foreign_keys(ForeignKeysRequest request)')
   print('  ForeignKeysResponse get_foreign_keys(ForeignKeysRequest request)')
-  print('  UniqueConstraintsResponse get_unique_constraints(UniqueConstraintsRequest request)')
-  print('  NotNullConstraintsResponse get_not_null_constraints(NotNullConstraintsRequest request)')
-  print('  DefaultConstraintsResponse get_default_constraints(DefaultConstraintsRequest request)')
-  print('  CheckConstraintsResponse get_check_constraints(CheckConstraintsRequest request)')
   print('  bool update_table_column_statistics(ColumnStatistics stats_obj)')
   print('  bool update_table_column_statistics(ColumnStatistics stats_obj)')
   print('  bool update_partition_column_statistics(ColumnStatistics stats_obj)')
   print('  bool update_partition_column_statistics(ColumnStatistics stats_obj)')
-  print('  SetPartitionsStatsResponse update_table_column_statistics_req(SetPartitionsStatsRequest req)')
-  print('  SetPartitionsStatsResponse update_partition_column_statistics_req(SetPartitionsStatsRequest req)')
   print('  ColumnStatistics get_table_column_statistics(string db_name, string tbl_name, string col_name)')
   print('  ColumnStatistics get_table_column_statistics(string db_name, string tbl_name, string col_name)')
   print('  ColumnStatistics get_partition_column_statistics(string db_name, string tbl_name, string part_name, string col_name)')
   print('  ColumnStatistics get_partition_column_statistics(string db_name, string tbl_name, string part_name, string col_name)')
   print('  TableStatsResult get_table_statistics_req(TableStatsRequest request)')
   print('  TableStatsResult get_table_statistics_req(TableStatsRequest request)')
@@ -159,7 +137,6 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
   print('  bool grant_privileges(PrivilegeBag privileges)')
   print('  bool grant_privileges(PrivilegeBag privileges)')
   print('  bool revoke_privileges(PrivilegeBag privileges)')
   print('  bool revoke_privileges(PrivilegeBag privileges)')
   print('  GrantRevokePrivilegeResponse grant_revoke_privileges(GrantRevokePrivilegeRequest request)')
   print('  GrantRevokePrivilegeResponse grant_revoke_privileges(GrantRevokePrivilegeRequest request)')
-  print('  GrantRevokePrivilegeResponse refresh_privileges(HiveObjectRef objToRefresh, string authorizer, GrantRevokePrivilegeRequest grantRequest)')
   print('   set_ugi(string user_name,  group_names)')
   print('   set_ugi(string user_name,  group_names)')
   print('  string get_delegation_token(string token_owner, string renewer_kerberos_principal_name)')
   print('  string get_delegation_token(string token_owner, string renewer_kerberos_principal_name)')
   print('  i64 renew_delegation_token(string token_str_form)')
   print('  i64 renew_delegation_token(string token_str_form)')
@@ -178,9 +155,6 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
   print('  void abort_txn(AbortTxnRequest rqst)')
   print('  void abort_txn(AbortTxnRequest rqst)')
   print('  void abort_txns(AbortTxnsRequest rqst)')
   print('  void abort_txns(AbortTxnsRequest rqst)')
   print('  void commit_txn(CommitTxnRequest rqst)')
   print('  void commit_txn(CommitTxnRequest rqst)')
-  print('  void repl_tbl_writeid_state(ReplTblWriteIdStateRequest rqst)')
-  print('  GetValidWriteIdsResponse get_valid_write_ids(GetValidWriteIdsRequest rqst)')
-  print('  AllocateTableWriteIdsResponse allocate_table_write_ids(AllocateTableWriteIdsRequest rqst)')
   print('  LockResponse lock(LockRequest rqst)')
   print('  LockResponse lock(LockRequest rqst)')
   print('  LockResponse check_lock(CheckLockRequest rqst)')
   print('  LockResponse check_lock(CheckLockRequest rqst)')
   print('  void unlock(UnlockRequest rqst)')
   print('  void unlock(UnlockRequest rqst)')
@@ -188,64 +162,18 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
   print('  void heartbeat(HeartbeatRequest ids)')
   print('  void heartbeat(HeartbeatRequest ids)')
   print('  HeartbeatTxnRangeResponse heartbeat_txn_range(HeartbeatTxnRangeRequest txns)')
   print('  HeartbeatTxnRangeResponse heartbeat_txn_range(HeartbeatTxnRangeRequest txns)')
   print('  void compact(CompactionRequest rqst)')
   print('  void compact(CompactionRequest rqst)')
-  print('  CompactionResponse compact2(CompactionRequest rqst)')
   print('  ShowCompactResponse show_compact(ShowCompactRequest rqst)')
   print('  ShowCompactResponse show_compact(ShowCompactRequest rqst)')
   print('  void add_dynamic_partitions(AddDynamicPartitions rqst)')
   print('  void add_dynamic_partitions(AddDynamicPartitions rqst)')
-  print('  OptionalCompactionInfoStruct find_next_compact(string workerId)')
-  print('  void update_compactor_state(CompactionInfoStruct cr, i64 txn_id)')
-  print('   find_columns_with_stats(CompactionInfoStruct cr)')
-  print('  void mark_cleaned(CompactionInfoStruct cr)')
-  print('  void mark_compacted(CompactionInfoStruct cr)')
-  print('  void mark_failed(CompactionInfoStruct cr)')
-  print('  void set_hadoop_jobid(string jobId, i64 cq_id)')
   print('  NotificationEventResponse get_next_notification(NotificationEventRequest rqst)')
   print('  NotificationEventResponse get_next_notification(NotificationEventRequest rqst)')
   print('  CurrentNotificationEventId get_current_notificationEventId()')
   print('  CurrentNotificationEventId get_current_notificationEventId()')
-  print('  NotificationEventsCountResponse get_notification_events_count(NotificationEventsCountRequest rqst)')
   print('  FireEventResponse fire_listener_event(FireEventRequest rqst)')
   print('  FireEventResponse fire_listener_event(FireEventRequest rqst)')
   print('  void flushCache()')
   print('  void flushCache()')
-  print('  WriteNotificationLogResponse add_write_notification_log(WriteNotificationLogRequest rqst)')
-  print('  CmRecycleResponse cm_recycle(CmRecycleRequest request)')
   print('  GetFileMetadataByExprResult get_file_metadata_by_expr(GetFileMetadataByExprRequest req)')
   print('  GetFileMetadataByExprResult get_file_metadata_by_expr(GetFileMetadataByExprRequest req)')
   print('  GetFileMetadataResult get_file_metadata(GetFileMetadataRequest req)')
   print('  GetFileMetadataResult get_file_metadata(GetFileMetadataRequest req)')
   print('  PutFileMetadataResult put_file_metadata(PutFileMetadataRequest req)')
   print('  PutFileMetadataResult put_file_metadata(PutFileMetadataRequest req)')
   print('  ClearFileMetadataResult clear_file_metadata(ClearFileMetadataRequest req)')
   print('  ClearFileMetadataResult clear_file_metadata(ClearFileMetadataRequest req)')
   print('  CacheFileMetadataResult cache_file_metadata(CacheFileMetadataRequest req)')
   print('  CacheFileMetadataResult cache_file_metadata(CacheFileMetadataRequest req)')
   print('  string get_metastore_db_uuid()')
   print('  string get_metastore_db_uuid()')
-  print('  WMCreateResourcePlanResponse create_resource_plan(WMCreateResourcePlanRequest request)')
-  print('  WMGetResourcePlanResponse get_resource_plan(WMGetResourcePlanRequest request)')
-  print('  WMGetActiveResourcePlanResponse get_active_resource_plan(WMGetActiveResourcePlanRequest request)')
-  print('  WMGetAllResourcePlanResponse get_all_resource_plans(WMGetAllResourcePlanRequest request)')
-  print('  WMAlterResourcePlanResponse alter_resource_plan(WMAlterResourcePlanRequest request)')
-  print('  WMValidateResourcePlanResponse validate_resource_plan(WMValidateResourcePlanRequest request)')
-  print('  WMDropResourcePlanResponse drop_resource_plan(WMDropResourcePlanRequest request)')
-  print('  WMCreateTriggerResponse create_wm_trigger(WMCreateTriggerRequest request)')
-  print('  WMAlterTriggerResponse alter_wm_trigger(WMAlterTriggerRequest request)')
-  print('  WMDropTriggerResponse drop_wm_trigger(WMDropTriggerRequest request)')
-  print('  WMGetTriggersForResourePlanResponse get_triggers_for_resourceplan(WMGetTriggersForResourePlanRequest request)')
-  print('  WMCreatePoolResponse create_wm_pool(WMCreatePoolRequest request)')
-  print('  WMAlterPoolResponse alter_wm_pool(WMAlterPoolRequest request)')
-  print('  WMDropPoolResponse drop_wm_pool(WMDropPoolRequest request)')
-  print('  WMCreateOrUpdateMappingResponse create_or_update_wm_mapping(WMCreateOrUpdateMappingRequest request)')
-  print('  WMDropMappingResponse drop_wm_mapping(WMDropMappingRequest request)')
-  print('  WMCreateOrDropTriggerToPoolMappingResponse create_or_drop_wm_trigger_to_pool_mapping(WMCreateOrDropTriggerToPoolMappingRequest request)')
-  print('  void create_ischema(ISchema schema)')
-  print('  void alter_ischema(AlterISchemaRequest rqst)')
-  print('  ISchema get_ischema(ISchemaName name)')
-  print('  void drop_ischema(ISchemaName name)')
-  print('  void add_schema_version(SchemaVersion schemaVersion)')
-  print('  SchemaVersion get_schema_version(SchemaVersionDescriptor schemaVersion)')
-  print('  SchemaVersion get_schema_latest_version(ISchemaName schemaName)')
-  print('   get_schema_all_versions(ISchemaName schemaName)')
-  print('  void drop_schema_version(SchemaVersionDescriptor schemaVersion)')
-  print('  FindSchemasByColsResp get_schemas_by_cols(FindSchemasByColsRqst rqst)')
-  print('  void map_schema_version_to_serde(MapSchemaVersionToSerdeRequest rqst)')
-  print('  void set_schema_version_state(SetSchemaVersionStateRequest rqst)')
-  print('  void add_serde(SerDeInfo serde)')
-  print('  SerDeInfo get_serde(GetSerdeRequest rqst)')
-  print('  LockResponse get_lock_materialization_rebuild(string dbName, string tableName, i64 txnId)')
-  print('  bool heartbeat_lock_materialization_rebuild(string dbName, string tableName, i64 txnId)')
-  print('  void add_runtime_stats(RuntimeStat stat)')
-  print('   get_runtime_stats(GetRuntimeStatsRequest rqst)')
   print('  GetPartitionsResponse get_partitions_with_specs(GetPartitionsRequest request)')
   print('  GetPartitionsResponse get_partitions_with_specs(GetPartitionsRequest request)')
   print('  string getName()')
   print('  string getName()')
   print('  string getVersion()')
   print('  string getVersion()')
@@ -328,36 +256,6 @@ elif cmd == 'setMetaConf':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.setMetaConf(args[0],args[1],))
   pp.pprint(client.setMetaConf(args[0],args[1],))
 
 
-elif cmd == 'create_catalog':
-  if len(args) != 1:
-    print('create_catalog requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.create_catalog(eval(args[0]),))
-
-elif cmd == 'alter_catalog':
-  if len(args) != 1:
-    print('alter_catalog requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.alter_catalog(eval(args[0]),))
-
-elif cmd == 'get_catalog':
-  if len(args) != 1:
-    print('get_catalog requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_catalog(eval(args[0]),))
-
-elif cmd == 'get_catalogs':
-  if len(args) != 0:
-    print('get_catalogs requires 0 args')
-    sys.exit(1)
-  pp.pprint(client.get_catalogs())
-
-elif cmd == 'drop_catalog':
-  if len(args) != 1:
-    print('drop_catalog requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.drop_catalog(eval(args[0]),))
-
 elif cmd == 'create_database':
 elif cmd == 'create_database':
   if len(args) != 1:
   if len(args) != 1:
     print('create_database requires 1 args')
     print('create_database requires 1 args')
@@ -455,10 +353,10 @@ elif cmd == 'create_table_with_environment_context':
   pp.pprint(client.create_table_with_environment_context(eval(args[0]),eval(args[1]),))
   pp.pprint(client.create_table_with_environment_context(eval(args[0]),eval(args[1]),))
 
 
 elif cmd == 'create_table_with_constraints':
 elif cmd == 'create_table_with_constraints':
-  if len(args) != 7:
-    print('create_table_with_constraints requires 7 args')
+  if len(args) != 3:
+    print('create_table_with_constraints requires 3 args')
     sys.exit(1)
     sys.exit(1)
-  pp.pprint(client.create_table_with_constraints(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),eval(args[5]),eval(args[6]),))
+  pp.pprint(client.create_table_with_constraints(eval(args[0]),eval(args[1]),eval(args[2]),))
 
 
 elif cmd == 'drop_constraint':
 elif cmd == 'drop_constraint':
   if len(args) != 1:
   if len(args) != 1:
@@ -478,30 +376,6 @@ elif cmd == 'add_foreign_key':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.add_foreign_key(eval(args[0]),))
   pp.pprint(client.add_foreign_key(eval(args[0]),))
 
 
-elif cmd == 'add_unique_constraint':
-  if len(args) != 1:
-    print('add_unique_constraint requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.add_unique_constraint(eval(args[0]),))
-
-elif cmd == 'add_not_null_constraint':
-  if len(args) != 1:
-    print('add_not_null_constraint requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.add_not_null_constraint(eval(args[0]),))
-
-elif cmd == 'add_default_constraint':
-  if len(args) != 1:
-    print('add_default_constraint requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.add_default_constraint(eval(args[0]),))
-
-elif cmd == 'add_check_constraint':
-  if len(args) != 1:
-    print('add_check_constraint requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.add_check_constraint(eval(args[0]),))
-
 elif cmd == 'drop_table':
 elif cmd == 'drop_table':
   if len(args) != 3:
   if len(args) != 3:
     print('drop_table requires 3 args')
     print('drop_table requires 3 args')
@@ -514,36 +388,12 @@ elif cmd == 'drop_table_with_environment_context':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.drop_table_with_environment_context(args[0],args[1],eval(args[2]),eval(args[3]),))
   pp.pprint(client.drop_table_with_environment_context(args[0],args[1],eval(args[2]),eval(args[3]),))
 
 
-elif cmd == 'truncate_table':
-  if len(args) != 3:
-    print('truncate_table requires 3 args')
-    sys.exit(1)
-  pp.pprint(client.truncate_table(args[0],args[1],eval(args[2]),))
-
-elif cmd == 'truncate_table_req':
-  if len(args) != 1:
-    print('truncate_table_req requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.truncate_table_req(eval(args[0]),))
-
 elif cmd == 'get_tables':
 elif cmd == 'get_tables':
   if len(args) != 2:
   if len(args) != 2:
     print('get_tables requires 2 args')
     print('get_tables requires 2 args')
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.get_tables(args[0],args[1],))
   pp.pprint(client.get_tables(args[0],args[1],))
 
 
-elif cmd == 'get_tables_by_type':
-  if len(args) != 3:
-    print('get_tables_by_type requires 3 args')
-    sys.exit(1)
-  pp.pprint(client.get_tables_by_type(args[0],args[1],args[2],))
-
-elif cmd == 'get_materialized_views_for_rewriting':
-  if len(args) != 1:
-    print('get_materialized_views_for_rewriting requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_materialized_views_for_rewriting(args[0],))
-
 elif cmd == 'get_table_meta':
 elif cmd == 'get_table_meta':
   if len(args) != 3:
   if len(args) != 3:
     print('get_table_meta requires 3 args')
     print('get_table_meta requires 3 args')
@@ -568,30 +418,6 @@ elif cmd == 'get_table_objects_by_name':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.get_table_objects_by_name(args[0],eval(args[1]),))
   pp.pprint(client.get_table_objects_by_name(args[0],eval(args[1]),))
 
 
-elif cmd == 'get_table_req':
-  if len(args) != 1:
-    print('get_table_req requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_table_req(eval(args[0]),))
-
-elif cmd == 'get_table_objects_by_name_req':
-  if len(args) != 1:
-    print('get_table_objects_by_name_req requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_table_objects_by_name_req(eval(args[0]),))
-
-elif cmd == 'get_materialization_invalidation_info':
-  if len(args) != 2:
-    print('get_materialization_invalidation_info requires 2 args')
-    sys.exit(1)
-  pp.pprint(client.get_materialization_invalidation_info(eval(args[0]),args[1],))
-
-elif cmd == 'update_creation_metadata':
-  if len(args) != 4:
-    print('update_creation_metadata requires 4 args')
-    sys.exit(1)
-  pp.pprint(client.update_creation_metadata(args[0],args[1],args[2],eval(args[3]),))
-
 elif cmd == 'get_table_names_by_filter':
 elif cmd == 'get_table_names_by_filter':
   if len(args) != 3:
   if len(args) != 3:
     print('get_table_names_by_filter requires 3 args')
     print('get_table_names_by_filter requires 3 args')
@@ -616,12 +442,6 @@ elif cmd == 'alter_table_with_cascade':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.alter_table_with_cascade(args[0],args[1],eval(args[2]),eval(args[3]),))
   pp.pprint(client.alter_table_with_cascade(args[0],args[1],eval(args[2]),eval(args[3]),))
 
 
-elif cmd == 'alter_table_req':
-  if len(args) != 1:
-    print('alter_table_req requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.alter_table_req(eval(args[0]),))
-
 elif cmd == 'add_partition':
 elif cmd == 'add_partition':
   if len(args) != 1:
   if len(args) != 1:
     print('add_partition requires 1 args')
     print('add_partition requires 1 args')
@@ -760,12 +580,6 @@ elif cmd == 'get_partition_names':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.get_partition_names(args[0],args[1],eval(args[2]),))
   pp.pprint(client.get_partition_names(args[0],args[1],eval(args[2]),))
 
 
-elif cmd == 'get_partition_values':
-  if len(args) != 1:
-    print('get_partition_values requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_partition_values(eval(args[0]),))
-
 elif cmd == 'get_partitions_ps':
 elif cmd == 'get_partitions_ps':
   if len(args) != 4:
   if len(args) != 4:
     print('get_partitions_ps requires 4 args')
     print('get_partitions_ps requires 4 args')
@@ -814,12 +628,6 @@ elif cmd == 'get_partitions_by_names':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.get_partitions_by_names(args[0],args[1],eval(args[2]),))
   pp.pprint(client.get_partitions_by_names(args[0],args[1],eval(args[2]),))
 
 
-elif cmd == 'get_partitions_by_names_req':
-  if len(args) != 1:
-    print('get_partitions_by_names_req requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_partitions_by_names_req(eval(args[0]),))
-
 elif cmd == 'alter_partition':
 elif cmd == 'alter_partition':
   if len(args) != 3:
   if len(args) != 3:
     print('alter_partition requires 3 args')
     print('alter_partition requires 3 args')
@@ -838,12 +646,6 @@ elif cmd == 'alter_partitions_with_environment_context':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.alter_partitions_with_environment_context(args[0],args[1],eval(args[2]),eval(args[3]),))
   pp.pprint(client.alter_partitions_with_environment_context(args[0],args[1],eval(args[2]),eval(args[3]),))
 
 
-elif cmd == 'alter_partitions_req':
-  if len(args) != 1:
-    print('alter_partitions_req requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.alter_partitions_req(eval(args[0]),))
-
 elif cmd == 'alter_partition_with_environment_context':
 elif cmd == 'alter_partition_with_environment_context':
   if len(args) != 4:
   if len(args) != 4:
     print('alter_partition_with_environment_context requires 4 args')
     print('alter_partition_with_environment_context requires 4 args')
@@ -856,12 +658,6 @@ elif cmd == 'rename_partition':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.rename_partition(args[0],args[1],eval(args[2]),eval(args[3]),))
   pp.pprint(client.rename_partition(args[0],args[1],eval(args[2]),eval(args[3]),))
 
 
-elif cmd == 'rename_partition_req':
-  if len(args) != 1:
-    print('rename_partition_req requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.rename_partition_req(eval(args[0]),))
-
 elif cmd == 'partition_name_has_valid_characters':
 elif cmd == 'partition_name_has_valid_characters':
   if len(args) != 2:
   if len(args) != 2:
     print('partition_name_has_valid_characters requires 2 args')
     print('partition_name_has_valid_characters requires 2 args')
@@ -898,41 +694,53 @@ elif cmd == 'isPartitionMarkedForEvent':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.isPartitionMarkedForEvent(args[0],args[1],eval(args[2]),eval(args[3]),))
   pp.pprint(client.isPartitionMarkedForEvent(args[0],args[1],eval(args[2]),eval(args[3]),))
 
 
-elif cmd == 'get_primary_keys':
-  if len(args) != 1:
-    print('get_primary_keys requires 1 args')
+elif cmd == 'add_index':
+  if len(args) != 2:
+    print('add_index requires 2 args')
     sys.exit(1)
     sys.exit(1)
-  pp.pprint(client.get_primary_keys(eval(args[0]),))
+  pp.pprint(client.add_index(eval(args[0]),eval(args[1]),))
 
 
-elif cmd == 'get_foreign_keys':
-  if len(args) != 1:
-    print('get_foreign_keys requires 1 args')
+elif cmd == 'alter_index':
+  if len(args) != 4:
+    print('alter_index requires 4 args')
     sys.exit(1)
     sys.exit(1)
-  pp.pprint(client.get_foreign_keys(eval(args[0]),))
+  pp.pprint(client.alter_index(args[0],args[1],args[2],eval(args[3]),))
 
 
-elif cmd == 'get_unique_constraints':
-  if len(args) != 1:
-    print('get_unique_constraints requires 1 args')
+elif cmd == 'drop_index_by_name':
+  if len(args) != 4:
+    print('drop_index_by_name requires 4 args')
     sys.exit(1)
     sys.exit(1)
-  pp.pprint(client.get_unique_constraints(eval(args[0]),))
+  pp.pprint(client.drop_index_by_name(args[0],args[1],args[2],eval(args[3]),))
 
 
-elif cmd == 'get_not_null_constraints':
-  if len(args) != 1:
-    print('get_not_null_constraints requires 1 args')
+elif cmd == 'get_index_by_name':
+  if len(args) != 3:
+    print('get_index_by_name requires 3 args')
+    sys.exit(1)
+  pp.pprint(client.get_index_by_name(args[0],args[1],args[2],))
+
+elif cmd == 'get_indexes':
+  if len(args) != 3:
+    print('get_indexes requires 3 args')
+    sys.exit(1)
+  pp.pprint(client.get_indexes(args[0],args[1],eval(args[2]),))
+
+elif cmd == 'get_index_names':
+  if len(args) != 3:
+    print('get_index_names requires 3 args')
     sys.exit(1)
     sys.exit(1)
-  pp.pprint(client.get_not_null_constraints(eval(args[0]),))
+  pp.pprint(client.get_index_names(args[0],args[1],eval(args[2]),))
 
 
-elif cmd == 'get_default_constraints':
+elif cmd == 'get_primary_keys':
   if len(args) != 1:
   if len(args) != 1:
-    print('get_default_constraints requires 1 args')
+    print('get_primary_keys requires 1 args')
     sys.exit(1)
     sys.exit(1)
-  pp.pprint(client.get_default_constraints(eval(args[0]),))
+  pp.pprint(client.get_primary_keys(eval(args[0]),))
 
 
-elif cmd == 'get_check_constraints':
+elif cmd == 'get_foreign_keys':
   if len(args) != 1:
   if len(args) != 1:
-    print('get_check_constraints requires 1 args')
+    print('get_foreign_keys requires 1 args')
     sys.exit(1)
     sys.exit(1)
-  pp.pprint(client.get_check_constraints(eval(args[0]),))
+  pp.pprint(client.get_foreign_keys(eval(args[0]),))
 
 
 elif cmd == 'update_table_column_statistics':
 elif cmd == 'update_table_column_statistics':
   if len(args) != 1:
   if len(args) != 1:
@@ -946,18 +754,6 @@ elif cmd == 'update_partition_column_statistics':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.update_partition_column_statistics(eval(args[0]),))
   pp.pprint(client.update_partition_column_statistics(eval(args[0]),))
 
 
-elif cmd == 'update_table_column_statistics_req':
-  if len(args) != 1:
-    print('update_table_column_statistics_req requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.update_table_column_statistics_req(eval(args[0]),))
-
-elif cmd == 'update_partition_column_statistics_req':
-  if len(args) != 1:
-    print('update_partition_column_statistics_req requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.update_partition_column_statistics_req(eval(args[0]),))
-
 elif cmd == 'get_table_column_statistics':
 elif cmd == 'get_table_column_statistics':
   if len(args) != 3:
   if len(args) != 3:
     print('get_table_column_statistics requires 3 args')
     print('get_table_column_statistics requires 3 args')
@@ -1126,12 +922,6 @@ elif cmd == 'grant_revoke_privileges':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.grant_revoke_privileges(eval(args[0]),))
   pp.pprint(client.grant_revoke_privileges(eval(args[0]),))
 
 
-elif cmd == 'refresh_privileges':
-  if len(args) != 3:
-    print('refresh_privileges requires 3 args')
-    sys.exit(1)
-  pp.pprint(client.refresh_privileges(eval(args[0]),args[1],eval(args[2]),))
-
 elif cmd == 'set_ugi':
 elif cmd == 'set_ugi':
   if len(args) != 2:
   if len(args) != 2:
     print('set_ugi requires 2 args')
     print('set_ugi requires 2 args')
@@ -1240,24 +1030,6 @@ elif cmd == 'commit_txn':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.commit_txn(eval(args[0]),))
   pp.pprint(client.commit_txn(eval(args[0]),))
 
 
-elif cmd == 'repl_tbl_writeid_state':
-  if len(args) != 1:
-    print('repl_tbl_writeid_state requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.repl_tbl_writeid_state(eval(args[0]),))
-
-elif cmd == 'get_valid_write_ids':
-  if len(args) != 1:
-    print('get_valid_write_ids requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_valid_write_ids(eval(args[0]),))
-
-elif cmd == 'allocate_table_write_ids':
-  if len(args) != 1:
-    print('allocate_table_write_ids requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.allocate_table_write_ids(eval(args[0]),))
-
 elif cmd == 'lock':
 elif cmd == 'lock':
   if len(args) != 1:
   if len(args) != 1:
     print('lock requires 1 args')
     print('lock requires 1 args')
@@ -1300,12 +1072,6 @@ elif cmd == 'compact':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.compact(eval(args[0]),))
   pp.pprint(client.compact(eval(args[0]),))
 
 
-elif cmd == 'compact2':
-  if len(args) != 1:
-    print('compact2 requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.compact2(eval(args[0]),))
-
 elif cmd == 'show_compact':
 elif cmd == 'show_compact':
   if len(args) != 1:
   if len(args) != 1:
     print('show_compact requires 1 args')
     print('show_compact requires 1 args')
@@ -1318,48 +1084,6 @@ elif cmd == 'add_dynamic_partitions':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.add_dynamic_partitions(eval(args[0]),))
   pp.pprint(client.add_dynamic_partitions(eval(args[0]),))
 
 
-elif cmd == 'find_next_compact':
-  if len(args) != 1:
-    print('find_next_compact requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.find_next_compact(args[0],))
-
-elif cmd == 'update_compactor_state':
-  if len(args) != 2:
-    print('update_compactor_state requires 2 args')
-    sys.exit(1)
-  pp.pprint(client.update_compactor_state(eval(args[0]),eval(args[1]),))
-
-elif cmd == 'find_columns_with_stats':
-  if len(args) != 1:
-    print('find_columns_with_stats requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.find_columns_with_stats(eval(args[0]),))
-
-elif cmd == 'mark_cleaned':
-  if len(args) != 1:
-    print('mark_cleaned requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.mark_cleaned(eval(args[0]),))
-
-elif cmd == 'mark_compacted':
-  if len(args) != 1:
-    print('mark_compacted requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.mark_compacted(eval(args[0]),))
-
-elif cmd == 'mark_failed':
-  if len(args) != 1:
-    print('mark_failed requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.mark_failed(eval(args[0]),))
-
-elif cmd == 'set_hadoop_jobid':
-  if len(args) != 2:
-    print('set_hadoop_jobid requires 2 args')
-    sys.exit(1)
-  pp.pprint(client.set_hadoop_jobid(args[0],eval(args[1]),))
-
 elif cmd == 'get_next_notification':
 elif cmd == 'get_next_notification':
   if len(args) != 1:
   if len(args) != 1:
     print('get_next_notification requires 1 args')
     print('get_next_notification requires 1 args')
@@ -1372,12 +1096,6 @@ elif cmd == 'get_current_notificationEventId':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.get_current_notificationEventId())
   pp.pprint(client.get_current_notificationEventId())
 
 
-elif cmd == 'get_notification_events_count':
-  if len(args) != 1:
-    print('get_notification_events_count requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_notification_events_count(eval(args[0]),))
-
 elif cmd == 'fire_listener_event':
 elif cmd == 'fire_listener_event':
   if len(args) != 1:
   if len(args) != 1:
     print('fire_listener_event requires 1 args')
     print('fire_listener_event requires 1 args')
@@ -1390,18 +1108,6 @@ elif cmd == 'flushCache':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.flushCache())
   pp.pprint(client.flushCache())
 
 
-elif cmd == 'add_write_notification_log':
-  if len(args) != 1:
-    print('add_write_notification_log requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.add_write_notification_log(eval(args[0]),))
-
-elif cmd == 'cm_recycle':
-  if len(args) != 1:
-    print('cm_recycle requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.cm_recycle(eval(args[0]),))
-
 elif cmd == 'get_file_metadata_by_expr':
 elif cmd == 'get_file_metadata_by_expr':
   if len(args) != 1:
   if len(args) != 1:
     print('get_file_metadata_by_expr requires 1 args')
     print('get_file_metadata_by_expr requires 1 args')
@@ -1438,216 +1144,6 @@ elif cmd == 'get_metastore_db_uuid':
     sys.exit(1)
     sys.exit(1)
   pp.pprint(client.get_metastore_db_uuid())
   pp.pprint(client.get_metastore_db_uuid())
 
 
-elif cmd == 'create_resource_plan':
-  if len(args) != 1:
-    print('create_resource_plan requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.create_resource_plan(eval(args[0]),))
-
-elif cmd == 'get_resource_plan':
-  if len(args) != 1:
-    print('get_resource_plan requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_resource_plan(eval(args[0]),))
-
-elif cmd == 'get_active_resource_plan':
-  if len(args) != 1:
-    print('get_active_resource_plan requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_active_resource_plan(eval(args[0]),))
-
-elif cmd == 'get_all_resource_plans':
-  if len(args) != 1:
-    print('get_all_resource_plans requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_all_resource_plans(eval(args[0]),))
-
-elif cmd == 'alter_resource_plan':
-  if len(args) != 1:
-    print('alter_resource_plan requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.alter_resource_plan(eval(args[0]),))
-
-elif cmd == 'validate_resource_plan':
-  if len(args) != 1:
-    print('validate_resource_plan requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.validate_resource_plan(eval(args[0]),))
-
-elif cmd == 'drop_resource_plan':
-  if len(args) != 1:
-    print('drop_resource_plan requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.drop_resource_plan(eval(args[0]),))
-
-elif cmd == 'create_wm_trigger':
-  if len(args) != 1:
-    print('create_wm_trigger requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.create_wm_trigger(eval(args[0]),))
-
-elif cmd == 'alter_wm_trigger':
-  if len(args) != 1:
-    print('alter_wm_trigger requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.alter_wm_trigger(eval(args[0]),))
-
-elif cmd == 'drop_wm_trigger':
-  if len(args) != 1:
-    print('drop_wm_trigger requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.drop_wm_trigger(eval(args[0]),))
-
-elif cmd == 'get_triggers_for_resourceplan':
-  if len(args) != 1:
-    print('get_triggers_for_resourceplan requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_triggers_for_resourceplan(eval(args[0]),))
-
-elif cmd == 'create_wm_pool':
-  if len(args) != 1:
-    print('create_wm_pool requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.create_wm_pool(eval(args[0]),))
-
-elif cmd == 'alter_wm_pool':
-  if len(args) != 1:
-    print('alter_wm_pool requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.alter_wm_pool(eval(args[0]),))
-
-elif cmd == 'drop_wm_pool':
-  if len(args) != 1:
-    print('drop_wm_pool requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.drop_wm_pool(eval(args[0]),))
-
-elif cmd == 'create_or_update_wm_mapping':
-  if len(args) != 1:
-    print('create_or_update_wm_mapping requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.create_or_update_wm_mapping(eval(args[0]),))
-
-elif cmd == 'drop_wm_mapping':
-  if len(args) != 1:
-    print('drop_wm_mapping requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.drop_wm_mapping(eval(args[0]),))
-
-elif cmd == 'create_or_drop_wm_trigger_to_pool_mapping':
-  if len(args) != 1:
-    print('create_or_drop_wm_trigger_to_pool_mapping requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.create_or_drop_wm_trigger_to_pool_mapping(eval(args[0]),))
-
-elif cmd == 'create_ischema':
-  if len(args) != 1:
-    print('create_ischema requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.create_ischema(eval(args[0]),))
-
-elif cmd == 'alter_ischema':
-  if len(args) != 1:
-    print('alter_ischema requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.alter_ischema(eval(args[0]),))
-
-elif cmd == 'get_ischema':
-  if len(args) != 1:
-    print('get_ischema requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_ischema(eval(args[0]),))
-
-elif cmd == 'drop_ischema':
-  if len(args) != 1:
-    print('drop_ischema requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.drop_ischema(eval(args[0]),))
-
-elif cmd == 'add_schema_version':
-  if len(args) != 1:
-    print('add_schema_version requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.add_schema_version(eval(args[0]),))
-
-elif cmd == 'get_schema_version':
-  if len(args) != 1:
-    print('get_schema_version requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_schema_version(eval(args[0]),))
-
-elif cmd == 'get_schema_latest_version':
-  if len(args) != 1:
-    print('get_schema_latest_version requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_schema_latest_version(eval(args[0]),))
-
-elif cmd == 'get_schema_all_versions':
-  if len(args) != 1:
-    print('get_schema_all_versions requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_schema_all_versions(eval(args[0]),))
-
-elif cmd == 'drop_schema_version':
-  if len(args) != 1:
-    print('drop_schema_version requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.drop_schema_version(eval(args[0]),))
-
-elif cmd == 'get_schemas_by_cols':
-  if len(args) != 1:
-    print('get_schemas_by_cols requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_schemas_by_cols(eval(args[0]),))
-
-elif cmd == 'map_schema_version_to_serde':
-  if len(args) != 1:
-    print('map_schema_version_to_serde requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.map_schema_version_to_serde(eval(args[0]),))
-
-elif cmd == 'set_schema_version_state':
-  if len(args) != 1:
-    print('set_schema_version_state requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.set_schema_version_state(eval(args[0]),))
-
-elif cmd == 'add_serde':
-  if len(args) != 1:
-    print('add_serde requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.add_serde(eval(args[0]),))
-
-elif cmd == 'get_serde':
-  if len(args) != 1:
-    print('get_serde requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_serde(eval(args[0]),))
-
-elif cmd == 'get_lock_materialization_rebuild':
-  if len(args) != 3:
-    print('get_lock_materialization_rebuild requires 3 args')
-    sys.exit(1)
-  pp.pprint(client.get_lock_materialization_rebuild(args[0],args[1],eval(args[2]),))
-
-elif cmd == 'heartbeat_lock_materialization_rebuild':
-  if len(args) != 3:
-    print('heartbeat_lock_materialization_rebuild requires 3 args')
-    sys.exit(1)
-  pp.pprint(client.heartbeat_lock_materialization_rebuild(args[0],args[1],eval(args[2]),))
-
-elif cmd == 'add_runtime_stats':
-  if len(args) != 1:
-    print('add_runtime_stats requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.add_runtime_stats(eval(args[0]),))
-
-elif cmd == 'get_runtime_stats':
-  if len(args) != 1:
-    print('get_runtime_stats requires 1 args')
-    sys.exit(1)
-  pp.pprint(client.get_runtime_stats(eval(args[0]),))
-
 elif cmd == 'get_partitions_with_specs':
 elif cmd == 'get_partitions_with_specs':
   if len(args) != 1:
   if len(args) != 1:
     print('get_partitions_with_specs requires 1 args')
     print('get_partitions_with_specs requires 1 args')

파일 크기가 너무 크기때문에 변경 상태를 표시하지 않습니다.
+ 37 - 852
apps/beeswax/gen-py/hive_metastore/ThriftHiveMetastore.py


+ 0 - 4
apps/beeswax/gen-py/hive_metastore/constants.py

@@ -32,7 +32,3 @@ FILE_OUTPUT_FORMAT = "file.outputformat"
 META_TABLE_STORAGE = "storage_handler"
 META_TABLE_STORAGE = "storage_handler"
 TABLE_IS_TRANSACTIONAL = "transactional"
 TABLE_IS_TRANSACTIONAL = "transactional"
 TABLE_NO_AUTO_COMPACT = "no_auto_compaction"
 TABLE_NO_AUTO_COMPACT = "no_auto_compaction"
-TABLE_TRANSACTIONAL_PROPERTIES = "transactional_properties"
-TABLE_BUCKETING_VERSION = "bucketing_version"
-DRUID_CONFIG_PREFIX = "druid."
-JDBC_CONFIG_PREFIX = "hive.sql."

파일 크기가 너무 크기때문에 변경 상태를 표시하지 않습니다.
+ 183 - 565
apps/beeswax/gen-py/hive_metastore/ttypes.py


+ 5 - 10
apps/beeswax/src/beeswax/server/hive_metastore_server.py

@@ -107,10 +107,7 @@ class HiveMetastoreClient:
 
 
 
 
   def get_databases(self, *args, **kwargs):
   def get_databases(self, *args, **kwargs):
-    if self.query_server['server_name'] == 'impala':
-      return ['default']
-    else:
-      return self.meta_client.get_all_databases()
+    return self.meta_client.get_all_databases()
 
 
 
 
   def get_tables(self, *args, **kwargs):
   def get_tables(self, *args, **kwargs):
@@ -238,14 +235,12 @@ class HiveMetastoreClient:
         self._encode_partition(new_part)
         self._encode_partition(new_part)
         return self._client.alter_partition(db_name, tbl_name, new_part)
         return self._client.alter_partition(db_name, tbl_name, new_part)
 
 
-    # Use service name from kerberos principal set in hive-site.xml
-    _, host, port, metastore_kerberos_principal = hive_site.get_metastore()
-    use_sasl, kerberos_principal_short_name = HiveMetastoreClient.get_security()
-    kerberos_principal_short_name = metastore_kerberos_principal and metastore_kerberos_principal.split('/', 1)[0] or None
+    use_sasl, kerberos_principal_short_name = HiveMetastoreClient.get_security() # TODO Reuse from HiveServer2 lib
+
     client = thrift_util.get_client(
     client = thrift_util.get_client(
         ThriftHiveMetastore.Client,
         ThriftHiveMetastore.Client,
-        host,
-        port,
+        host=self.query_server['server_host'],
+        port=self.query_server['server_port'],
         service_name="Hive Metastore Server",
         service_name="Hive Metastore Server",
         kerberos_principal=kerberos_principal_short_name,
         kerberos_principal=kerberos_principal_short_name,
         use_sasl=use_sasl,
         use_sasl=use_sasl,

파일 크기가 너무 크기때문에 변경 상태를 표시하지 않습니다.
+ 66 - 952
apps/beeswax/thrift/hive_metastore.thrift


+ 2 - 1
desktop/libs/notebook/src/notebook/connectors/hive_metastore.py

@@ -34,7 +34,6 @@ LOG = logging.getLogger(__name__)
 
 
 try:
 try:
   from beeswax.api import _autocomplete
   from beeswax.api import _autocomplete
-  from beeswax.models import HiveServerQueryHandle
   from beeswax.server import dbms
   from beeswax.server import dbms
   from beeswax.server.dbms import get_query_server_config, QueryServerException
   from beeswax.server.dbms import get_query_server_config, QueryServerException
 except ImportError, e:
 except ImportError, e:
@@ -68,6 +67,8 @@ class HiveMetastoreApi(Api):
     db = self._get_db(snippet, cluster=self.cluster)
     db = self._get_db(snippet, cluster=self.cluster)
     query = None
     query = None
 
 
+    return db.get_databases()
+
     if snippet.get('query'):
     if snippet.get('query'):
       query = snippet.get('query')
       query = snippet.get('query')
     elif snippet.get('source') == 'query':
     elif snippet.get('source') == 'query':

이 변경점에서 너무 많은 파일들이 변경되어 몇몇 파일들은 표시되지 않았습니다.