add evict to family action

Author: swalrus1

ydb/core/protos/flat_scheme_op.proto

@@ -220,15 +220,20 @@ message TTTLSettings {
         optional uint32 MaxShardsInFlight = 6 [default = 0]; // zero means no limit
     }
 
-    message TExternalStorageSettings {
+    message TEvictionToExternalStorageSettings {
         optional string StorageName = 1;
     }
 
+    message TEvictionToColumnFamilySettings {
+        optional string FamilyName = 1;
+    }
+
     message TTier {
         optional uint32 EvictAfterSeconds = 1;
         oneof Action {
             google.protobuf.Empty Delete = 2;
-            TExternalStorageSettings EvictToExternalStorage = 3;
+            TEvictionToExternalStorageSettings EvictToExternalStorage = 3;
+            TEvictionToColumnFamilySettings EvictToColumnFamily = 4;
         }
     }
 

ydb/core/ydb_convert/table_description.cpp

@@ -534,6 +534,9 @@ static void AddTtl(TYdbProto& out, const TTtl& inTTL) {
             case NKikimrSchemeOp::TTTLSettings::TTier::ActionCase::kEvictToExternalStorage:
                 outTier->mutable_evict_to_external_storage()->set_storage_name(inTier.GetEvictToExternalStorage().GetStorageName());
                 break;
+            case NKikimrSchemeOp::TTTLSettings::TTier::ActionCase::kEvictToColumnFamily:
+                outTier->mutable_evict_to_column_family()->set_family_name(inTier.GetEvictToColumnFamily().GetFamilyName());
+                break;
             case NKikimrSchemeOp::TTTLSettings::TTier::ActionCase::ACTION_NOT_SET:
                 break;
         }

ydb/core/ydb_convert/table_settings.h

@@ -46,6 +46,9 @@ bool FillTtlSettings(TTtlSettingsEnabled& out, const Ydb::Table::TtlSettings& in
                 case Ydb::Table::TtlTier::kEvictToExternalStorage:
                     outTier->MutableEvictToExternalStorage()->SetStorageName(inTier.evict_to_external_storage().storage_name());
                     break;
+                case Ydb::Table::TtlTier::kEvictToColumnFamily:
+                    outTier->MutableEvictToColumnFamily()->SetFamilyName(inTier.evict_to_column_family().family_name());
+                    break;
                 case Ydb::Table::TtlTier::ACTION_NOT_SET:
                     break;
             }

ydb/public/api/protos/ydb_table.proto

@@ -434,16 +434,22 @@ message ColumnMeta {
 }
 
 message EvictionToExternalStorageSettings {
-    // Name of external data source
+    // Path to external data source
     string storage_name = 1;
 }
 
+message EvictionToFamilySettings {
+    // Name of column family
+    string family_name = 1;
+}
+
 message TtlTier {
     uint32 evict_after_seconds = 1;
 
     oneof action {
         google.protobuf.Empty delete = 2;
         EvictionToExternalStorageSettings evict_to_external_storage = 3;
+        EvictionToFamilySettings evict_to_column_family = 3;
     }
 }
 

ydb/public/sdk/cpp/client/ydb_table/table.cpp

@@ -2945,13 +2945,16 @@ TTtlTierSettings::TTtlTierSettings(const Ydb::Table::TtlTier& tier)
     : EvictionDelay_(TDuration::Seconds(tier.evict_after_seconds())) {
     switch (tier.action_case()) {
         case Ydb::Table::TtlTier::kDelete:
-        Action_ = TTtlDeleteAction();
-        break;
+            Action_ = TTtlDeleteAction();
+            break;
         case Ydb::Table::TtlTier::kEvictToExternalStorage:
-        Action_ = TTtlEvictToExternalStorageAction(tier.evict_to_external_storage().storage_name());
-        break;
+            Action_ = TTtlEvictToExternalStorageAction(tier.evict_to_external_storage().storage_name());
+            break;
+        case Ydb::Table::TtlTier::kEvictToColumnFamily:
+            Action_ = TTtlEvictToExternalStorageAction(tier.evict_to_column_family().family_name());
+            break;
         case Ydb::Table::TtlTier::ACTION_NOT_SET:
-        break;
+            break;
     }
 }
 
@@ -2962,8 +2965,10 @@ void TTtlTierSettings::SerializeTo(Ydb::Table::TtlTier& proto) const {
         using T = std::decay_t<decltype(action)>;
         if constexpr (std::is_same_v<T, TTtlDeleteAction>) {
             proto.mutable_delete_();
-        } else if constexpr (std::is_same_v<T, TExplicitPartitions>) {
+        } else if constexpr (std::is_same_v<T, TTtlEvictToExternalStorageAction>) {
             proto.mutable_evict_to_external_storage()->set_storage_name(action.StorageName);
+        } else if constexpr (std::is_same_v<T, TTtlEvictToColumnFamilyAction>) {
+            proto.mutable_evict_to_column_family()->set_storage_name(action.FamilyName);
         }
     };
     std::visit(std::move(actionVisitor), Action_);

ydb/public/sdk/cpp/client/ydb_table/table.h

@@ -425,7 +425,11 @@ struct TPartitionStats {
 struct TTtlDeleteAction {};
 
 struct TTtlEvictToExternalStorageAction {
-    TString storageName;
+    TString StorageName;
+};
+
+struct TTtlEvictToColumnFamilyAction {
+    TString FamilyName;
 };
 
 class TTtlTierSettings {