CASSANDRA-9420 add table option for saying theres no deletes on table

src/java/org/apache/cassandra/cql3/statements/schema/TableAttributes.java

@@ -164,6 +164,9 @@ private TableParams build(TableParams.Builder builder)
         if (hasOption(MIN_INDEX_INTERVAL))
             builder.minIndexInterval(getInt(MIN_INDEX_INTERVAL));
 
+        if (hasOption(Option.NO_DELETES))
+            builder.noDeletes(getBoolean(Option.NO_DELETES));
+
         if (hasOption(SPECULATIVE_RETRY))
             builder.speculativeRetry(SpeculativeRetryPolicy.fromString(getString(SPECULATIVE_RETRY)));
 

src/java/org/apache/cassandra/schema/TableParams.java

@@ -100,7 +100,8 @@ public enum Option
         TRANSACTIONAL_MODE,
         TRANSACTIONAL_MIGRATION_FROM,
         PENDING_DROP,
-        AUTO_REPAIR;
+        AUTO_REPAIR,
+        NO_DELETES;
 
         @Override
         public String toString()
@@ -132,6 +133,7 @@ public String toString()
     public final TransactionalMode transactionalMode;
     public final TransactionalMigrationFromMode transactionalMigrationFrom;
     public final boolean pendingDrop;
+    public final boolean noDeletes;
 
     public final AutoRepairParams autoRepair;
 
@@ -164,6 +166,7 @@ private TableParams(Builder builder)
         pendingDrop = builder.pendingDrop;
         checkNotNull(transactionalMigrationFrom);
         autoRepair = builder.autoRepair;
+        noDeletes = builder.noDeletes;
     }
 
     public static Builder builder()
@@ -196,7 +199,8 @@ public static Builder builder(TableParams params)
                             .transactionalMode(params.transactionalMode)
                             .transactionalMigrationFrom(params.transactionalMigrationFrom)
                             .pendingDrop(params.pendingDrop)
-                            .automatedRepair(params.autoRepair);
+                            .automatedRepair(params.autoRepair)
+                            .noDeletes(params.noDeletes);
     }
 
     public Builder unbuild()
@@ -297,7 +301,8 @@ public boolean equals(Object o)
             && transactionalMode == p.transactionalMode
             && transactionalMigrationFrom == p.transactionalMigrationFrom
             && pendingDrop == p.pendingDrop
-            && autoRepair.equals(p.autoRepair);
+            && autoRepair.equals(p.autoRepair)
+            && noDeletes == p.noDeletes;
     }
 
     @Override
@@ -326,7 +331,8 @@ public int hashCode()
                                 transactionalMode,
                                 transactionalMigrationFrom,
                                 pendingDrop,
-                                autoRepair);
+                                autoRepair,
+                                noDeletes);
     }
 
     @Override
@@ -358,6 +364,7 @@ public String toString()
                           .add(Option.TRANSACTIONAL_MIGRATION_FROM.toString(), transactionalMigrationFrom)
                           .add(PENDING_DROP.toString(), pendingDrop)
                           .add(Option.AUTO_REPAIR.toString(), autoRepair)
+                          .add(Option.NO_DELETES.toString(), noDeletes)
                           .toString();
     }
 
@@ -407,6 +414,8 @@ public void appendCqlTo(CqlBuilder builder, boolean isView)
                .newLine()
                .append("AND min_index_interval = ").append(minIndexInterval)
                .newLine()
+               .append("AND no_deletes = ").append(noDeletes)
+               .newLine()
                .append("AND read_repair = ").appendWithSingleQuotes(readRepair.toString())
                .newLine();
 
@@ -454,6 +463,7 @@ public static final class Builder
         public boolean pendingDrop = false;
 
         private AutoRepairParams autoRepair = AutoRepairParams.DEFAULT;
+        private boolean noDeletes = false;
         public Builder()
         {
         }
@@ -606,6 +616,12 @@ public Builder automatedRepair(AutoRepairParams val)
             autoRepair = val;
             return this;
         }
+
+        public Builder noDeletes(boolean val)
+        {
+            noDeletes = val;
+            return this;
+        }
     }
 
     public static class Serializer implements MetadataSerializer<TableParams>
@@ -641,6 +657,7 @@ public void serialize(TableParams t, DataOutputPlus out, Version version) throws
                 out.writeInt(t.transactionalMode.ordinal());
                 out.writeInt(t.transactionalMigrationFrom.ordinal());
                 out.writeBoolean(t.pendingDrop);
+                out.writeBoolean(t.noDeletes);
             }
         }
 
@@ -671,7 +688,8 @@ public TableParams deserialize(DataInputPlus in, Version version) throws IOExcep
                 builder.fastPath(FastPathStrategy.serializer.deserialize(in, version))
                        .transactionalMode(TransactionalMode.fromOrdinal(in.readInt()))
                        .transactionalMigrationFrom(TransactionalMigrationFromMode.fromOrdinal(in.readInt()))
-                       .pendingDrop(in.readBoolean());
+                       .pendingDrop(in.readBoolean())
+                       .noDeletes(in.readBoolean());
             }
             return builder.build();
         }
@@ -702,7 +720,8 @@ public long serializedSize(TableParams t, Version version)
                 size += FastPathStrategy.serializer.serializedSize(t.fastPath, version) +
                         sizeof(t.transactionalMode.ordinal()) +
                         sizeof(t.transactionalMigrationFrom.ordinal()) +
-                        sizeof(t.pendingDrop);
+                        sizeof(t.pendingDrop) +
+                        sizeof(t.noDeletes);
             }
             return size;
         }

src/java/org/apache/cassandra/tcm/serialization/Version.java

@@ -65,6 +65,7 @@ public enum Version
      *  - Added ConsensusMigrationState
      *  - Added AccordStaleReplicas
      *  - TableParam now has pendingDrop (accord table drop is multistep)
+     *  - TableParam now has noDeletes
      */
     V7(7),