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

Interface to deal with multiple raw output streams. More...

#include <io.h>

Public Member Functions

virtual size_t GetStreamCount () const =0
 Get amount of managed streams.
virtual IOutputStream * GetStream (size_t tableIndex) const =0
 Get stream corresponding to the specified table index.
virtual void OnRowFinished (size_t tableIndex)=0
 This handler must be called right after the next row has been written.
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

Interface to deal with multiple raw output streams.

Member Function Documentation

◆ Abort()

virtual void NYT::IProxyOutput::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.


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