ClickHouse/dbms/include/DB/Storages/MergeTree/ReplicatedMergeTreeBlockOutputStream.h

31 lines
548 B
C++

#pragma once
#include <DB/DataStreams/IBlockOutputStream.h>
namespace DB
{
class StorageReplicatedMergeTree;
class ReplicatedMergeTreeBlockOutputStream : public IBlockOutputStream
{
public:
ReplicatedMergeTreeBlockOutputStream(StorageReplicatedMergeTree & storage_, const String & insert_id_,
size_t quorum_, size_t quorum_timeout_ms_);
void write(const Block & block) override;
private:
StorageReplicatedMergeTree & storage;
String insert_id;
size_t quorum;
size_t quorum_timeout_ms;
size_t block_index = 0;
Logger * log;
};
}