Rename streamed_mutation* files to mutation_fragment*

Signed-off-by: Piotr Jastrzebski <piotr@scylladb.com>

cache_flat_mutation_reader.hh

@@ -24,7 +24,7 @@
 #include <vector>
 #include "row_cache.hh"
 #include "mutation_reader.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 #include "partition_version.hh"
 #include "utils/logalloc.hh"
 #include "query-request.hh"

cell_locking.hh

@@ -39,7 +39,7 @@ using small_vector = std::vector<T>;
 #endif
 
 #include "fnv1a_hasher.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 #include "mutation_partition.hh"
 
 #include "db/timeout_clock.hh"

clustering_ranges_walker.hh

@@ -25,7 +25,7 @@
 
 #include "schema.hh"
 #include "query-request.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 
 // Utility for in-order checking of overlap with position ranges.
 class clustering_ranges_walker {

configure.py

@@ -200,7 +200,7 @@ modes = {
 scylla_tests = [
     'tests/mutation_test',
     'tests/mvcc_test',
-    'tests/streamed_mutation_test',
+    'tests/mutation_fragment_test',
     'tests/flat_mutation_reader_test',
     'tests/schema_registry_test',
     'tests/canonical_mutation_test',
@@ -363,7 +363,7 @@ scylla_core = (['database.cc',
                  'schema_registry.cc',
                  'bytes.cc',
                  'mutation.cc',
-                 'streamed_mutation.cc',
+                 'mutation_fragment.cc',
                  'partition_version.cc',
                  'row_cache.cc',
                  'canonical_mutation.cc',

db/size_estimates_virtual_reader.hh

@@ -35,7 +35,7 @@
 #include "range.hh"
 #include "service/storage_service.hh"
 #include "stdx.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 #include "sstables/sstables.hh"
 #include "db/timeout_clock.hh"
 

db/view/view.hh

@@ -25,7 +25,7 @@
 #include "gc_clock.hh"
 #include "query-request.hh"
 #include "schema.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 #include "flat_mutation_reader.hh"
 #include "stdx.hh"
 

flat_mutation_reader.hh

@@ -26,7 +26,7 @@
 
 #include "dht/i_partitioner.hh"
 #include "position_in_partition.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 #include "tracing/trace_state.hh"
 
 #include <seastar/util/gcc6-concepts.hh>

frozen_mutation.hh

@@ -25,7 +25,7 @@
 #include "atomic_cell.hh"
 #include "database_fwd.hh"
 #include "mutation_partition_view.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 #include "flat_mutation_reader.hh"
 
 class mutation;

mutation.hh

@@ -28,7 +28,7 @@
 #include "schema.hh"
 #include "dht/i_partitioner.hh"
 #include "hashing.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 
 #include <seastar/util/optimized_optional.hh>
 

mutation_compactor.hh

@@ -21,7 +21,7 @@
 
 #pragma once
 
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 
 static inline bool has_ck_selector(const query::clustering_row_ranges& ranges) {
     // Like PK range, an empty row range, should be considered an "exclude all" restriction

mutation_fragment.cc

@@ -24,7 +24,7 @@
 #include <seastar/util/defer.hh>
 
 #include "mutation.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 
 std::ostream&
 operator<<(std::ostream& os, const clustering_row& row) {

mutation_partition.cc

@@ -28,7 +28,7 @@
 #include "query-result-writer.hh"
 #include "atomic_cell_hash.hh"
 #include "reversibly_mergeable.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 #include "mutation_query.hh"
 #include "service/priority_manager.hh"
 #include "mutation_compactor.hh"

mutation_partition_serializer.hh

@@ -26,7 +26,7 @@
 #include "database_fwd.hh"
 #include "mutation_partition_view.hh"
 #include "bytes_ostream.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 
 namespace ser {
 template<typename Output>

partition_version.hh

@@ -22,7 +22,7 @@
 #pragma once
 
 #include "mutation_partition.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 #include "utils/anchorless_list.hh"
 #include "utils/logalloc.hh"
 

range_tombstone.cc

@@ -20,7 +20,7 @@
  */
 
 #include "range_tombstone.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 
 std::ostream& operator<<(std::ostream& out, const range_tombstone& rt) {
     if (rt) {

read_context.hh

@@ -23,7 +23,7 @@
 
 #include "schema.hh"
 #include "query-request.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 #include "partition_version.hh"
 #include "tracing/tracing.hh"
 #include "row_cache.hh"

schema_upgrader.hh

@@ -21,7 +21,7 @@
 
 #pragma once
 
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 #include "converting_mutation_partition_applier.hh"
 
 // A StreamedMutationTransformer which transforms the stream to a different schema

tests/flat_mutation_reader_test.cc

@@ -24,7 +24,7 @@
 #include <seastar/tests/test-utils.hh>
 
 #include "mutation.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 #include "mutation_source_test.hh"
 #include "flat_mutation_reader.hh"
 #include "mutation_reader.hh"

tests/mutation_fragment_test.cc

@@ -24,7 +24,7 @@
 #include <seastar/tests/test-utils.hh>
 
 #include "mutation_source_test.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 #include "frozen_mutation.hh"
 #include "tests/test_services.hh"
 #include "schema_builder.hh"

tests/simple_schema.hh

@@ -26,10 +26,9 @@
 #include "make_random_string.hh"
 #include "schema.hh"
 #include "keys.hh"
-#include "streamed_mutation.hh"
+#include "mutation_fragment.hh"
 #include "mutation.hh"
 #include "schema_builder.hh"
-#include "streamed_mutation.hh"
 #include "sstable_utils.hh"
 
 // Helper for working with the following table: