Loading...
Searching...
No Matches
NYT::TReduceOperationSpec Struct Reference
Spec of Reduce operation. More...
#include <operation.h>
Inheritance diagram for NYT::TReduceOperationSpec:
Additional Inherited Members | |
| Public Member Functions inherited from NYT::TReduceOperationSpecBase< TReduceOperationSpec > | |
| TSelf & | ReducerSpec (TUserJobSpec) |
| Spec of reduce job. | |
| TSelf & | SortBy (TSortColumns) |
| Columns to sort rows by (must include ReduceBy as prefix). | |
| TSelf & | ReduceBy (TSortColumns) |
| Columns to group rows by. | |
| TSelf & | JoinBy (TSortColumns) |
| Columns to join foreign tables by (must be prefix of ReduceBy). | |
| TSelf & | EnableKeyGuarantee (bool) |
| Guarantee to feed all rows with same ReduceBy columns to a single job (true by default). | |
| TSelf & | DataSizePerJob (ui64) |
| Recommended number of jobs to run. | |
| Public Member Functions inherited from NYT::TUserOperationSpecBase< TReduceOperationSpec > | |
| 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< TReduceOperationSpec > | |
| 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::TWithAutoMergeSpec< TReduceOperationSpec > | |
| TSelf & | AutoMerge (TAutoMergeSpec) |
| Options for auto merge operation stage. | |
| Public Member Functions inherited from NYT::TOperationIOSpec< TReduceOperationSpec > | |
| TReduceOperationSpec & | AddInput (const TRichYPath &path) |
| TReduceOperationSpec & | AddStructuredInput (TStructuredTablePath path) |
| TReduceOperationSpec & | SetInput (size_t tableIndex, const TRichYPath &path) |
| TReduceOperationSpec & | AddOutput (const TRichYPath &path) |
| TReduceOperationSpec & | AddStructuredOutput (TStructuredTablePath path) |
| TReduceOperationSpec & | SetOutput (size_t tableIndex, const TRichYPath &path) |
| TReduceOperationSpec & | AddProtobufInput_VerySlow_Deprecated (const TRichYPath &path) |
| TReduceOperationSpec & | 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< TReduceOperationSpec > | |
| TSelf & | InputFormatHints (TFormatHints) |
| Fine tune input format of the job. | |
| Public Member Functions inherited from NYT::TUserJobOutputFormatHintsBase< TReduceOperationSpec > | |
| 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 Reduce operation.
The documentation for this struct was generated from the following file:
- yt/cpp/mapreduce/interface/operation.h
