RUBY-261 - Support cdc option in table metadata.

Author: stamhankar999

lib/cassandra/cluster/schema/fetchers.rb

@@ -572,7 +572,8 @@ def create_table_options(table_data, compaction_strategy, is_compact)
               compression_parameters,
               is_compact,
               table_data['crc_check_chance'],
-              table_data['extensions']
+              table_data['extensions'],
+              nil
             )
           end
         end
@@ -741,7 +742,8 @@ def create_table_options(table_data, compaction_strategy, is_compact)
               compression_parameters,
               is_compact,
               table_data['crc_check_chance'],
-              table_data['extensions']
+              table_data['extensions'],
+              nil
             )
           end
         end
@@ -815,7 +817,8 @@ def create_table_options(table_data, compaction_strategy, is_compact)
               compression_parameters,
               is_compact,
               table_data['crc_check_chance'],
-              table_data['extensions']
+              table_data['extensions'],
+              nil
             )
           end
         end
@@ -1347,7 +1350,8 @@ def create_table_options(table_data, compaction_strategy, is_compact)
               compression,
               is_compact,
               table_data['crc_check_chance'],
-              table_data['extensions']
+              table_data['extensions'],
+              table_data['cdc']
             )
           end
 

lib/cassandra/column_container.rb

@@ -60,6 +60,9 @@ class Options
       # @return [ColumnContainer::Compaction] the compaction strategy of this column-container.
       attr_reader :compaction_strategy
 
+      # @return whether or not change data capture is enabled on this table.
+      attr_reader :cdc
+
       # @private
       # rubocop:disable Metrics/ParameterLists
       def initialize(comment,
@@ -80,7 +83,8 @@ def initialize(comment,
                      compression,
                      compact_storage,
                      crc_check_chance,
-                     extensions)
+                     extensions,
+                     cdc)
         @comment                     = comment
         @read_repair_chance          = read_repair_chance
         @local_read_repair_chance    = local_read_repair_chance
@@ -100,6 +104,7 @@ def initialize(comment,
         @compact_storage             = compact_storage
         @crc_check_chance            = crc_check_chance
         @extensions                  = extensions
+        @cdc                         = cdc
       end
 
       # Return whether to replicate counter updates to other replicas. It is *strongly* recommended
@@ -130,6 +135,7 @@ def to_cql
           options << "bloom_filter_fp_chance = #{Util.encode_object(@bloom_filter_fp_chance)}"
         end
         options << "caching = #{Util.encode_object(@caching)}" unless @caching.nil?
+        options << "cdc = true" if @cdc
         options << "comment = #{Util.encode_object(@comment)}" unless @comment.nil?
         options << "compaction = #{@compaction_strategy.to_cql}" unless @compaction_strategy.nil?
         options << "compression = #{Util.encode_object(@compression)}" unless @compression.nil?
@@ -153,7 +159,6 @@ def to_cql
         options << "read_repair_chance = #{Util.encode_object(@read_repair_chance)}" unless @read_repair_chance.nil?
         options << "replicate_on_write = '#{@replicate_on_write}'" unless @replicate_on_write.nil?
         options << "speculative_retry = #{Util.encode_object(@speculative_retry)}" unless @speculative_retry.nil?
-
         options.join("\nAND ")
       end
 
@@ -177,6 +182,7 @@ def eql?(other)
           @compact_storage == other.compact_storage? &&
           @crc_check_chance == other.crc_check_chance &&
           @extensions == other.extensions
+          @cdc == other.cdc
       end
       alias == eql?
     end

spec/cassandra/cluster/schema/fetchers/3.0.0-data.json

@@ -18,6 +18,7 @@
         "keys": "ALL",
         "rows_per_partition": "NONE"
       },
+      "cdc": true,
       "comment": "test table for unit tests",
       "compaction": {
         "class": "org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy",

spec/cassandra/cluster/schema/fetchers/3.0.0-schema.cql

@@ -8,6 +8,7 @@ CREATE TABLE simplex."t1" (
 )
 WITH bloom_filter_fp_chance = 0.01
  AND caching = {'keys': 'ALL', 'rows_per_partition': 'NONE'}
+ AND cdc = true
  AND comment = 'test table for unit tests'
  AND compaction = {'class': 'SizeTieredCompactionStrategy', 'max_threshold': '32', 'min_threshold': '4'}
  AND compression = {'chunk_length_in_kb': '64', 'class': 'LZ4Compressor'}