@@ -338,6 +338,11 @@ void TRetryfulWriterV2::Abort()
}
+size_t TRetryfulWriterV2::GetBufferMemoryUsage() const
+{
+ return BufferSize_ * 4;
+}
+
void TRetryfulWriterV2::DoFinish()
{
if (Sender_) {
@@ -32,6 +32,8 @@ public:
void NotifyRowEnd() override;
void Abort() override;
+ size_t GetBufferMemoryUsage() const override;
protected:
void DoWrite(const void* buf, size_t len) override;
void DoFinish() override;