2fa0f82910
tools/scylla-sstable.cc has 3.5k SLOC, out of which this class alone is 1K. Extract into own hh and cc, just a copy-paste after the preparation commit.
34 lines
1.0 KiB
C++
34 lines
1.0 KiB
C++
/*
|
|
* Copyright (C) 2025-present ScyllaDB
|
|
*/
|
|
|
|
/*
|
|
* SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
|
|
*/
|
|
|
|
#include <seastar/core/iostream.hh>
|
|
|
|
#include "mutation/mutation_fragment_v2.hh"
|
|
|
|
#pragma once
|
|
|
|
namespace tools {
|
|
|
|
/// Parse a stream of JSON encoded mutation fragments, using the format produced
|
|
/// by scylla-sstable write.
|
|
/// The parsing is streamed, at most a single mutation fragment is kept in memory.
|
|
/// Not all data types are supported: collections, tuples, UDTs and counters are not supported.
|
|
/// See docs/operating-scylla/admin-tools/scylla-sstable.rst for the format documentation.
|
|
class json_mutation_stream_parser {
|
|
class impl;
|
|
std::unique_ptr<impl> _impl;
|
|
|
|
public:
|
|
explicit json_mutation_stream_parser(schema_ptr schema, reader_permit permit, input_stream<char> istream, logger& logger);
|
|
json_mutation_stream_parser(json_mutation_stream_parser&&) noexcept;
|
|
~json_mutation_stream_parser();
|
|
future<mutation_fragment_v2_opt> operator()();
|
|
};
|
|
|
|
} // namespace tools
|