94088f0a41
It will be used by index tests to know the ground truth for where each partition and row are written, so that this can be checked against the index.
52 lines
1.2 KiB
C++
52 lines
1.2 KiB
C++
/*
|
|
* Copyright (C) 2021-present ScyllaDB
|
|
*/
|
|
|
|
/*
|
|
* SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include <memory>
|
|
#include <seastar/core/smp.hh>
|
|
#include "schema/schema_fwd.hh"
|
|
#include "mutation/mutation_fragment.hh"
|
|
#include "mutation/mutation_fragment_v2.hh"
|
|
|
|
struct encoding_stats;
|
|
|
|
namespace sstables {
|
|
|
|
class sstable;
|
|
struct sstable_writer_config;
|
|
|
|
class sstable_writer {
|
|
public:
|
|
class writer_impl;
|
|
private:
|
|
std::unique_ptr<writer_impl> _impl;
|
|
public:
|
|
sstable_writer(sstable& sst, const schema& s, uint64_t estimated_partitions,
|
|
const sstable_writer_config&, encoding_stats enc_stats,
|
|
shard_id shard = this_shard_id());
|
|
|
|
sstable_writer(sstable_writer&& o);
|
|
sstable_writer& operator=(sstable_writer&& o);
|
|
|
|
~sstable_writer();
|
|
|
|
void consume_new_partition(const dht::decorated_key& dk);
|
|
void consume(tombstone t);
|
|
stop_iteration consume(static_row&& sr);
|
|
stop_iteration consume(clustering_row&& cr);
|
|
stop_iteration consume(range_tombstone_change&& rtc);
|
|
stop_iteration consume_end_of_partition();
|
|
void consume_end_of_stream();
|
|
void set_repaired_at(int64_t repaired_at);
|
|
uint64_t data_file_position_for_tests() const;
|
|
};
|
|
|
|
} // namespace sstables
|
|
|