add autopartitioning by load (#7124)

ydb-platform · Jul 29, 2024 · 690f5e8 · 690f5e8
1 parent 312992d
commit 690f5e8
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/ydb/core/persqueue/writer/metadata_initializers.cpp b/ydb/core/persqueue/writer/metadata_initializers.cpp
@@ -74,6 +74,16 @@ void TSrcIdMetaInitializer::DoPrepare(NInitializer::IInitializerInput::TPtr cont
 
             result.emplace_back(new NInitializer::TGenericTableModifier<NRequest::TDialogAlterTable>(request, "add_column_SeqNo"));
         }
+
+        {
+            Ydb::Table::AlterTableRequest request;
+            request.set_session_id("");
+            request.set_path(tablePath);
+            request.mutable_alter_partitioning_settings()->set_min_partitions_count(50);
+            request.mutable_alter_partitioning_settings()->set_partitioning_by_load(::Ydb::FeatureFlag_Status::FeatureFlag_Status_ENABLED);
+
+            result.emplace_back(new NInitializer::TGenericTableModifier<NRequest::TDialogAlterTable>(request, "enable_autopartitioning_by_load"));
+        }
     }
     result.emplace_back(NInitializer::TACLModifierConstructor::GetReadOnlyModifier(tablePath, "acl"));
     controller->OnPreparationFinished(result);