C++ YT Wrapper
C++ library for working with YT clusters
Loading...
Searching...
No Matches
NYT::TRawTableWriter Class Referenceabstract

Low-level interface to write YT table. More...

#include <io.h>

Inheritance diagram for NYT::TRawTableWriter:

Public Member Functions

virtual void NotifyRowEnd ()=0
 Call this method after complete row representation is written to the stream.
virtual void Abort ()
 Try to abort writing process as soon as possible (makes sense for multi-threaded writers).
virtual size_t GetBufferMemoryUsage () const

Detailed Description

Low-level interface to write YT table.

Retries must be handled by implementation.

Member Function Documentation

◆ Abort()

virtual void NYT::TRawTableWriter::Abort ( )
inlinevirtual

Try to abort writing process as soon as possible (makes sense for multi-threaded writers).

By default it does nothing, but implementations are welcome to override this method.

◆ NotifyRowEnd()

virtual void NYT::TRawTableWriter::NotifyRowEnd ( )
pure virtual

Call this method after complete row representation is written to the stream.

When this method is called TRowTableWriter can check its buffer and if it is full send data to YT.

Note
TRawTableWriter never sends partial records to YT (due to retries).

The documentation for this class was generated from the following file:
  • yt/cpp/mapreduce/interface/io.h