|
C++ YT Wrapper
C++ library for working with YT clusters
|
Raw job executing given bash command. More...
#include <operation.h>
Public Member Functions | |
| TCommandRawJob (TStringBuf command={}) | |
| Create job with specified command. | |
| const TString & | GetCommand () const override |
| Get bash command to run. | |
| void | Do (const TRawJobContext &jobContext) override |
| This method is called exactly once for the whole job input. | |
| 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. | |
Additional Inherited Members | |
| Public Types inherited from NYT::IJob | |
| enum | EType { Mapper , Reducer , ReducerAggregator , RawJob , VanillaJob } |
| Type of job. | |
| Static Public Attributes inherited from NYT::IRawJob | |
| static constexpr EType | JobType = EType::RawJob |
| Type of job implemented by this class. | |
Raw job executing given bash command.
|
explicit |
Create job with specified command.
| command | Bash command to run. |
|
overridevirtual |
This method is called exactly once for the whole job input.
Implements NYT::IRawJob.
|
overridevirtual |