Interface for jobs with typed inputs and outputs. More...

#include <operation.h>

Inheritance diagram for NYT::IStructuredJob:

Public Member Functions
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.

Additional Inherited Members
Public Types inherited from NYT::IJob
enum	EType { Mapper , Reducer , ReducerAggregator , RawJob , VanillaJob }
	Type of job.

Detailed Description

Interface for jobs with typed inputs and outputs.

Member Function Documentation

virtual TRawTableReaderPtr NYT::IStructuredJob::CreateCustomRawJobReader ( int fd ) const

virtual

This methods are called when creating table reader and writer for the job.

Override them if you want to implement custom input logic. (e.g. additional bufferization)

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