CreateChangefeedsPropose

Author: stanislav-shchetinin

ydb/core/tx/schemeshard/schemeshard_import_flow_proposals.cpp

@@ -8,6 +8,18 @@
 namespace NKikimr {
 namespace NSchemeShard {
 
+void CreateChangefeedsPropose(THolder<TEvSchemeShard::TEvModifySchemeTransaction>& propose, const TImportInfo::TItem& item) {
+    auto& record = propose->Record;
+    const auto& changefeeds = item.Changefeeds;
+    
+    for (const auto& changefeed : changefeeds) {
+        auto& modifyScheme = *record.AddTransaction();
+        const auto& cdcStream = modifyScheme.MutableCreateCdcStream();
+        cdcStream->MutableTableName();
+    }
+
+}
+
 THolder<TEvSchemeShard::TEvModifySchemeTransaction> CreateTablePropose(
     TSchemeShard* ss,
     TTxId txId,

ydb/core/tx/schemeshard/schemeshard_info_types.h

@@ -2850,6 +2850,7 @@ struct TImportInfo: public TSimpleRefCount<TImportInfo> {
         TString CreationQuery;
         TMaybe<NKikimrSchemeOp::TModifyScheme> PreparedCreationQuery;
         TMaybeFail<Ydb::Scheme::ModifyPermissionsRequest> Permissions;
+        TVector<Ydb::Table::ChangefeedDescription> Changefeeds;
         NBackup::TMetadata Metadata;
         TVector<Ydb::Table::ChangefeedDescription> Changefeeds;