NYT::TJoinReduceOperationSpec Struct Reference

Spec of JoinReduce operation. More...

#include <operation.h>

Inheritance diagram for NYT::TJoinReduceOperationSpec:

Additional Inherited Members
Public Member Functions inherited from NYT::TJoinReduceOperationSpecBase< TJoinReduceOperationSpec >
TSelf &	ReducerSpec (TUserJobSpec)
	Spec of reduce job.
TSelf &	JoinBy (TSortColumns)
	Columns to join foreign tables by (must be prefix of ReduceBy).
TSelf &	DataSizePerJob (ui64)
	Recommended number of jobs to run.
Public Member Functions inherited from NYT::TUserOperationSpecBase< TJoinReduceOperationSpec >
TSelf &	FailOnJobRestart (bool)
	On any unsuccessful job completion (i.e. abortion or failure) force the whole operation to fail.
TSelf &	StderrTablePath (TYPath)
	Table to save whole stderr of operation.
TSelf &	CoreTablePath (TYPath)
	Table to save coredumps of operation.
TSelf &	WaitingJobTimeout (TDuration)
	How long should the scheduler wait for the job to be started on a node.
Public Member Functions inherited from NYT::TOperationSpecBase< TJoinReduceOperationSpec >
TSelf &	TimeLimit (TDuration)
	Limit on operation execution time.
TSelf &	Alias (TString)
	Alias for searching for an operation in the future.
TSelf &	Title (TString)
	Title to be shown in web interface.
TSelf &	Pool (TString)
	Pool to be used for this operation.
TSelf &	Weight (double)
	Weight of operation.
	FLUENT_OPTIONAL_VECTOR_FIELD_ENCAPSULATED (TString, PoolTree)
	Pool tree list that operation will use.
	FLUENT_FIELD_OPTION_ENCAPSULATED (TSchedulerResources, ResourceLimits)
	How much resources can be consumed by operation.
TSelf &	MaxFailedJobCount (ui64)
	How many jobs can fail before operation is failed.
TSelf &	Annotations (TNode)
TSelf &	Description (TNode)
Public Member Functions inherited from NYT::TOperationIOSpec< TJoinReduceOperationSpec >
TJoinReduceOperationSpec &	AddInput (const TRichYPath &path)
TJoinReduceOperationSpec &	AddStructuredInput (TStructuredTablePath path)
TJoinReduceOperationSpec &	SetInput (size_t tableIndex, const TRichYPath &path)
TJoinReduceOperationSpec &	AddOutput (const TRichYPath &path)
TJoinReduceOperationSpec &	AddStructuredOutput (TStructuredTablePath path)
TJoinReduceOperationSpec &	SetOutput (size_t tableIndex, const TRichYPath &path)
TJoinReduceOperationSpec &	AddProtobufInput_VerySlow_Deprecated (const TRichYPath &path)
TJoinReduceOperationSpec &	AddProtobufOutput_VerySlow_Deprecated (const TRichYPath &path)
Public Member Functions inherited from NYT::TOperationInputSpecBase
template<class T>
void	AddInput (const TRichYPath &path)
	Add input table path to input path list and specify type of rows.
void	AddStructuredInput (TStructuredTablePath path)
	Add input table path as structured paths.
template<class T>
void	SetInput (size_t tableIndex, const TRichYPath &path)
	Set input table path and type.
const TVector< TStructuredTablePath > &	GetStructuredInputs () const
	Get all input structured paths.
Public Member Functions inherited from NYT::TOperationOutputSpecBase
template<class T>
void	AddOutput (const TRichYPath &path)
	Add output table path to output path list and specify type of rows.
void	AddStructuredOutput (TStructuredTablePath path)
	Add output table path as structured paths.
template<class T>
void	SetOutput (size_t tableIndex, const TRichYPath &path)
	Set output table path and type.
const TVector< TStructuredTablePath > &	GetStructuredOutputs () const
	Get all output structured paths.
Public Member Functions inherited from NYT::TUserJobInputFormatHintsBase< TJoinReduceOperationSpec >
TSelf &	InputFormatHints (TFormatHints)
	Fine tune input format of the job.
Public Member Functions inherited from NYT::TUserJobOutputFormatHintsBase< TJoinReduceOperationSpec >
TSelf &	OutputFormatHints (TFormatHints)
	Fine tune output format of the job.
Public Attributes inherited from NYT::TOperationInputSpecBase
TVector< TRichYPath >	Inputs_
	All input paths.
Public Attributes inherited from NYT::TOperationOutputSpecBase
TVector< TRichYPath >	Outputs_
	All output paths.

Detailed Description

Spec of JoinReduce operation.

Deprecated

Instead the user should run a reduce operation with NYT::TReduceOperationSpec::EnableKeyGuarantee set to false.

See also

https://ytsaurus.tech/docs/en/user-guide/data-processing/operations/reduce#foreign_tables

---

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

• yt/cpp/mapreduce/interface/operation.h