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

Vanilla job executing given bash command. More...

#include <operation.h>

Inheritance diagram for NYT::TCommandVanillaJob:
NYT::IVanillaJob<> NYT::ICommandJob NYT::IVanillaJobBase NYT::IJob NYT::IStructuredJob NYT::IJob

Public Member Functions

 TCommandVanillaJob (TStringBuf command={})
 Create job with specified command.
const TString & GetCommand () const override
 Get bash command to run.
void Do () override
Public Member Functions inherited from NYT::IVanillaJob<>
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

Public Types inherited from NYT::IVanillaJob<>
using TWriter
Public Types inherited from NYT::IJob
enum  EType {
  Mapper , Reducer , ReducerAggregator , RawJob ,
  VanillaJob
}
 Type of job.
Static Public Attributes inherited from NYT::IVanillaJobBase
static constexpr EType JobType = EType::VanillaJob
 Type of job implemented by this class.

Detailed Description

Vanilla job executing given bash command.

Note
The binary will not be uploaded.

Constructor & Destructor Documentation

◆ TCommandVanillaJob()

NYT::TCommandVanillaJob::TCommandVanillaJob ( TStringBuf command = {})
explicit

Create job with specified command.

Parameters
commandBash command to run.

Member Function Documentation

◆ GetCommand()

const TString & NYT::TCommandVanillaJob::GetCommand ( ) const
overridevirtual

Get bash command to run.

Note
This method is called on the client side.

Implements NYT::ICommandJob.


The documentation for this class was generated from the following file: