|
C++ YT Wrapper
C++ library for working with YT clusters
|
Base interface for vanilla jobs. More...
#include <operation.h>
Static Public Attributes | |
| static constexpr EType | JobType = EType::VanillaJob |
| Type of job implemented by this class. | |
Additional Inherited Members | |
| Public Types inherited from NYT::IJob | |
| enum | EType { Mapper , Reducer , ReducerAggregator , RawJob , VanillaJob } |
| Type of job. | |
| Public Member Functions inherited from NYT::IStructuredJob | |
| virtual TRawTableReaderPtr | CreateCustomRawJobReader (int fd) const |
| This methods are called when creating table reader and writer for the job. | |
| virtual THolder< IProxyOutput > | CreateCustomRawJobWriter (size_t outputTableCount) const |
| virtual TStructuredRowStreamDescription | GetInputRowStreamDescription () const =0 |
| virtual TStructuredRowStreamDescription | GetOutputRowStreamDescription () const =0 |
| Public Member Functions inherited from NYT::IJob | |
| virtual void | Save (IOutputStream &stream) const |
| Save job state to stream to be restored on cluster nodes. | |
| virtual void | Load (IInputStream &stream) |
| Restore job state from a stream. | |
| const TNode & | SecureVault () const |
| Get operation secure vault (specified in NYT::TOperationOptions::SecureVault) inside a job. | |
| i64 | GetOutputTableCount () const |
| Get number of output tables. | |
| virtual void | PrepareOperation (const IOperationPreparationContext &context, TJobOperationPreparer &preparer) const |
| Method allowing user to control some properties of input and output tables and formats. | |
Base interface for vanilla jobs.