Loading...
Searching...
No Matches
NYT::IVanillaJob< TW > Class Template Referenceabstract
Interface for vanilla jobs with output tables. More...
#include <operation.h>
Inheritance diagram for NYT::IVanillaJob< TW >:
Public Types | |
| using | TWriter = TW |
| Public Types inherited from NYT::IJob | |
| enum | EType { Mapper , Reducer , ReducerAggregator , RawJob , VanillaJob } |
| Type of job. | |
Public Member Functions | |
| virtual void | Start (TWriter *) |
| This method is called before Do method. | |
| virtual void | Do (TWriter *writer)=0 |
| This method is called exactly once for each vanilla job. | |
| virtual void | Finish (TWriter *) |
| This method is called after Do method. | |
| virtual TStructuredRowStreamDescription | GetInputRowStreamDescription () const override |
| virtual TStructuredRowStreamDescription | GetOutputRowStreamDescription () const override |
| 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 |
| 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 | |
| Static Public Attributes inherited from NYT::IVanillaJobBase | |
| static constexpr EType | JobType = EType::VanillaJob |
| Type of job implemented by this class. | |
Detailed Description
template<class TW>
class NYT::IVanillaJob< TW >
class NYT::IVanillaJob< TW >
Interface for vanilla jobs with output tables.
Member Function Documentation
◆ Do()
template<class TW>
|
pure virtual |
This method is called exactly once for each vanilla job.
Write output rows to writer.
◆ GetInputRowStreamDescription()
template<class TW>
|
overridevirtual |
Implements NYT::IStructuredJob.
◆ GetOutputRowStreamDescription()
template<class TW>
|
overridevirtual |
Implements NYT::IStructuredJob.
The documentation for this class was generated from the following file:
- yt/cpp/mapreduce/interface/operation.h
