diff --git a/HEAD~1:standalone-metastore/metastore-common/src/main/thrift/hive_metastore.thrift b/HEAD:standalone-metastore/metastore-common/src/main/thrift/hive_metastore.thrift index 19bc713..c378405 100644 --- a/HEAD~1:standalone-metastore/metastore-common/src/main/thrift/hive_metastore.thrift +++ b/HEAD:standalone-metastore/metastore-common/src/main/thrift/hive_metastore.thrift @@ -424,6 +424,15 @@ struct StorageDescriptor { 12: optional bool storedAsSubDirectories // stored as subdirectories or not } +struct CreationMetadata { + 1: required string catName + 2: required string dbName, + 3: required string tblName, + 4: required set tablesUsed, + 5: optional string validTxnList, + 6: optional i64 materializationTime +} + // table information struct Table { 1: optional i64 id, // id of the table. It will be ignored if set. It's only for @@ -927,6 +936,15 @@ struct CommitTxnKeyValue { 3: required string value, } +struct ReplLastIdInfo { + 1: required string database, + 2: required i64 lastReplId, + 3: optional string table, + 4: optional string catalog, + 5: optional list partitionList, + 6: optional bool needUpdateDBReplId, +} + struct CommitTxnRequest { 1: required i64 txnid, 2: optional string replPolicy, @@ -940,15 +958,6 @@ struct CommitTxnRequest { 5: optional ReplLastIdInfo replLastIdInfo, } -struct ReplLastIdInfo { - 1: required string database, - 2: required i64 lastReplId, - 3: optional string table, - 4: optional string catalog, - 5: optional list partitionList, - 6: optional bool needUpdateDBReplId, -} - struct WriteEventInfo { 1: required i64 writeId, 2: required string database, @@ -989,6 +998,12 @@ struct GetValidWriteIdsResponse { 1: required list tblValidWriteIds, } +// Map for allocated write id against the txn for which it is allocated +struct TxnToWriteId { + 1: required i64 txnId, + 2: required i64 writeId, +} + // Request msg to allocate table write ids for the given list of txns struct AllocateTableWriteIdsRequest { 1: required string dbName, @@ -1001,12 +1016,6 @@ struct AllocateTableWriteIdsRequest { 5: optional list srcTxnToWriteIdList, } -// Map for allocated write id against the txn for which it is allocated -struct TxnToWriteId { - 1: required i64 txnId, - 2: required i64 writeId, -} - struct AllocateTableWriteIdsResponse { 1: required list txnToWriteIds, } @@ -1099,10 +1108,6 @@ struct CompactionRequest { 6: optional map properties } -struct OptionalCompactionInfoStruct { - 1: optional CompactionInfoStruct ci, -} - struct CompactionInfoStruct { 1: required i64 id, 2: required string dbname, @@ -1118,6 +1123,10 @@ struct CompactionInfoStruct { 12: optional i64 highestWriteId } +struct OptionalCompactionInfoStruct { + 1: optional CompactionInfoStruct ci, +} + struct CompactionResponse { 1: required i64 id, 2: required string state, @@ -1165,14 +1174,6 @@ struct BasicTxnInfo { 6: optional string partitionname } -struct CreationMetadata { - 1: required string catName - 2: required string dbName, - 3: required string tblName, - 4: required set tablesUsed, - 5: optional string validTxnList, - 6: optional i64 materializationTime -} struct NotificationEventRequest { 1: required i64 lastEvent,