ClickHouse/dbms/src/Storages/MergeTree/ReplicatedMergeTreeBlockOutputStream.h

#pragma once

#include <DataStreams/IBlockOutputStream.h>
#include <Core/Types.h>

namespace Poco { class Logger; }

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;

    using Logger = Poco::Logger;
    Logger * log;
};

}