use snowflakeid as transaction id

Author: arthurpassos

src/Storages/MergeTree/MergeTreeExportManifest.h

@@ -8,14 +8,11 @@
 #include <IO/ReadHelpers.h>
 #include <IO/WriteHelpers.h>
 #include <Common/Exception.h>
-#include "Storages/MergeTree/RangesInDataPart.h"
 #include <Poco/JSON/Object.h>
 #include <Poco/JSON/Array.h>
 #include <Poco/JSON/Parser.h>
 #include <Poco/JSON/Stringifier.h>
 #include <Poco/Dynamic/Var.h>
-#include <memory>
-#include <sstream>
 
 namespace DB
 {
@@ -54,17 +51,17 @@ struct MergeTreeExportManifest
     static std::shared_ptr<MergeTreeExportManifest> create(
         const DiskPtr & disk_,
         const String & path_prefix,
-        const String & commit_id_,
+        const String & transaction_id_,
         const String & partition_id_,
         const StorageID & destination_storage_id_,
         const std::vector<DataPartPtr> & data_parts)
     {
         auto manifest = std::make_shared<MergeTreeExportManifest>();
         manifest->disk = disk_;
-        manifest->transaction_id = commit_id_;
+        manifest->transaction_id = transaction_id_;
         manifest->partition_id = partition_id_;
         manifest->destination_storage_id = destination_storage_id_;
-        manifest->file_path = std::filesystem::path(path_prefix) / ("export_partition_" + partition_id_ + "_commit_" + commit_id_ + ".json");
+        manifest->file_path = std::filesystem::path(path_prefix) / ("export_partition_" + partition_id_ + "_transaction_" + transaction_id_ + ".json");
         manifest->items.reserve(data_parts.size());
         for (const auto & data_part : data_parts)
             manifest->items.push_back({data_part->name, ""});
@@ -177,5 +174,3 @@ struct MergeTreeExportManifest
 };
 
 }
-
-

src/Storages/StorageMergeTree.cpp

@@ -47,11 +47,12 @@
 #include <Common/ProfileEventsScope.h>
 #include <Common/escapeForFileName.h>
 #include "Core/BackgroundSchedulePool.h"
-#include "Core/Names.h"
-#include "ObjectStorage/MergeTree/StorageObjectStorageMergeTreePartImporterSink.h"
-#include "Storages/MergeTree/MergeMutateSelectedEntry.h"
-#include "Storages/MergeTree/MergeTreeExportManifest.h"
-#include "Storages/MergeTree/MergeTreePartInfo.h"
+#include <Core/Names.h>
+#include <Functions/generateSnowflakeID.h>
+#include <Storages/ObjectStorage/MergeTree/StorageObjectStorageMergeTreePartImporterSink.h>
+#include <Storages/MergeTree/MergeMutateSelectedEntry.h>
+#include <Storages/MergeTree/MergeTreeExportManifest.h>
+#include <Storages/MergeTree/MergeTreePartInfo.h>
 
 namespace DB
 {
@@ -597,16 +598,7 @@ void StorageMergeTree::exportPartitionToTable(const PartitionCommand & command,
 
     auto exports_tagger = std::make_shared<CurrentlyExportingPartsTagger>(std::move(all_parts), *this);
 
-    std::string transaction_id;
-    {
-        std::random_device rd;
-        std::mt19937_64 gen(rd());
-        std::uniform_int_distribution<uint64_t> dis;
-        uint64_t random_value = dis(gen);
-        std::ostringstream oss;
-        oss << std::hex << random_value;
-        transaction_id = oss.str();
-    }
+    const auto transaction_id = std::to_string(generateSnowflakeID());
 
     const auto manifest = MergeTreeExportManifest::create(
         getStoragePolicy()->getAnyDisk(),

src/Storages/StorageMergeTree.h

@@ -17,7 +17,7 @@
 
 #include <Disks/StoragePolicy.h>
 #include <Common/SimpleIncrement.h>
-#include "Storages/MergeTree/MergeTreeExportManifest.h"
+#include <Storages/MergeTree/MergeTreeExportManifest.h>
 
 
 namespace DB