spec

package

Go to main page

Versions in this module

v0

v0.0.24

Nov 12, 2024

v0.0.23

Nov 12, 2024

Changes in this version

type Spec

+ DataWeightPerJob int

+ DataWeightPerMapJob int

+ DataWeightPerPartitionJob int

+ DataWeightPerReduceJob int

+ DataWeightPerSortJob int

+ DataWeightPerSortedMergeJob int

+ IntermediateDataAccount string

+ IntermediateDataMedium string

+ MapJobCount int

+ MapSelectivityFactor float64

+ PartitionCount int

+ PartitionDataSize int

+ SchedulingSegmentModules []string

v0.0.22

Sep 24, 2024

v0.0.21

Aug 27, 2024

v0.0.20

Jun 21, 2024

v0.0.19

Jun 21, 2024

v0.0.18

May 31, 2024

v0.0.17

Apr 14, 2024

v0.0.16

Mar 22, 2024

v0.0.15

Feb 26, 2024

Changes in this version

type UserScript

+ Monitoring map[string]any

v0.0.14

Feb 7, 2024

Changes in this version

+ type DiskRequest struct

+ Account string

+ DiskSpace int64

+ InodeCount int64

+ MediumName string

type Spec

+ Alias string

type UserScript

+ DiskRequest *DiskRequest

+ JobTimeLimit yson.Duration

v0.0.13

Oct 26, 2023

v0.0.12

Oct 19, 2023

v0.0.11

Oct 9, 2023

v0.0.10

Oct 9, 2023

v0.0.9

Aug 10, 2023

Changes in this version

type Spec

+ JobCPUMonitor *JobCPUMonitor

v0.0.8

Aug 3, 2023

v0.0.7

Jul 27, 2023

v0.0.6

Jun 17, 2023

Changes in this version

+ type JobCPUMonitor struct

+ CheckPeriod yson.Duration

+ DecreaseCoefficient float64

+ EnableCPUReclaim bool

+ IncreaseCoefficient float64

+ MinCPULimit float64

+ SmoothingFactor float64

+ StartDelay yson.Duration

+ VoteDecisionThreshold int

+ VoteWindowSize int

type Spec

+ TryAvoidDuplicatingJobs *bool

type UserScript

+ JobCPUMonitor *JobCPUMonitor

v0.0.5

May 30, 2023

v0.0.4

May 22, 2023

Changes in this version

type Spec

+ FailOnJobRestart *bool

+ MaxSpeculativeJobCountPerTask *int

v0.0.3

May 3, 2023

Changes in this version

type Spec

+ InputQuery string

v0.0.2

Mar 20, 2023

v0.0.1

Mar 20, 2023

Changes in this version

+ const AutoMergeDisabled

+ const AutoMergeEconomic

+ const AutoMergeManual

+ const AutoMergeRelaxed

+ func ConfigureJobIOForDynamicTable(spec *Spec)

+ type AutoMerge struct

+ ChunkCountPerMergeJob int

+ ChunkSizeThreshold int

+ MaxIntermediateChunkCount int

+ Mode string

+ type ControlAttributes struct

+ EnableKeySwitch bool

+ EnableRangeIndex bool

+ EnableRowIndex bool

+ EnableTableIndex bool

+ type File struct

+ BypassArtifactCache bool

+ CypressPath ypath.Path

+ Executable bool

+ FileName string

+ Format interface{}

+ type JobIO struct

+ ControlAttributes *ControlAttributes

+ TableReader interface{}

+ TableWriter interface{}

+ type ResourceLimits struct

+ CPU int

+ Memory int64

+ UserSlots int

+ type Spec struct

+ ACL []yt.ACE

+ Annotations map[string]interface{}

+ Atomicity string

+ AutoMerge *AutoMerge

+ ClusterName string

+ CombineChunks bool

+ ConsiderOnlyPrimarySize *bool

+ CopyAttributes *bool

+ CoreTablePath ypath.Path

+ DataSizePerJob int64

+ Description map[string]interface{}

+ EnableKeyGuarantee *bool

+ ForceTransform bool

+ InputTablePaths []ypath.YPath

+ IntermediateDataReplicationFactor int

+ JobCount int

+ JobIO *JobIO

+ JoinBy []string

+ MapJobIO *JobIO

+ Mapper *UserScript

+ MapperOutputTableCount int

+ MaxFailedJobCount int

+ MergeBy []string

+ MergeJobIO *JobIO

+ MergeMode string

+ NetworkName string

+ Ordered bool

+ OutputTablePath ypath.YPath

+ OutputTablePaths []ypath.YPath

+ PartitionJobIO *JobIO

+ PivotKeys [][]interface{}

+ Pool string

+ PoolTrees []string

+ ProbingPoolTree string

+ ProbingRatio int

+ ReduceBy []string

+ ReduceCombiner *UserScript

+ ReduceJobIO *JobIO

+ Reducer *UserScript

+ ResourceLimits *ResourceLimits

+ SchedulingTagFilter string

+ SecureVault map[string]string

+ SortBy []string

+ SortJobIO *JobIO

+ StartedBy map[string]interface{}

+ StderrTablePath ypath.Path

+ Tasks map[string]*UserScript

+ TentativePoolTrees []string

+ TimeLimit yson.Duration

+ Title string

+ Type yt.OperationType

+ UseColumnarStatistics *bool

+ Weight float64

+ func Erase() *Spec

+ func Map() *Spec

+ func MapReduce() *Spec

+ func Merge() *Spec

+ func Reduce() *Spec

+ func Sort() *Spec

+ func Vanilla() *Spec

+ func (s *Spec) AddAnnotations(annotations map[string]interface{}) *Spec

+ func (s *Spec) AddInput(path ypath.YPath) *Spec

+ func (s *Spec) AddOutput(path ypath.YPath) *Spec

+ func (s *Spec) AddSecureVaultVar(name, value string) *Spec

+ func (s *Spec) AddVanillaTask(name string, jobCount int) *Spec

+ func (s *Spec) Clone() *Spec

+ func (s *Spec) Erase() *Spec

+ func (s *Spec) JoinByColumns(columns ...string) *Spec

+ func (s *Spec) Map() *Spec

+ func (s *Spec) MapReduce() *Spec

+ func (s *Spec) Merge() *Spec

+ func (s *Spec) PatchUserBinary(path ypath.Path)

+ func (s *Spec) Reduce() *Spec

+ func (s *Spec) ReduceByColumns(columns ...string) *Spec

+ func (s *Spec) SetOutput(path ypath.YPath) *Spec

+ func (s *Spec) Sort() *Spec

+ func (s *Spec) SortByColumns(columns ...string) *Spec

+ func (s *Spec) Vanilla() *Spec

+ func (s *Spec) VisitUserScripts(cb func(*UserScript))

+ type UserScript struct

+ CPULimit float32

+ Command string

+ CopyFiles bool

+ EnableCPUReclaim *bool

+ EnablePorto string

+ Environment map[string]string

+ FilePaths []File

+ Format interface{}

+ GPULimit int

+ InputFormat interface{}

+ JobCount int

+ JobIO *JobIO

+ LayerPaths []ypath.Path

+ MakeRootFSWritable bool

+ MemoryLimit int64

+ MemoryReserveFactor float64

+ NetworkProject string

+ OutputFormat interface{}

+ OutputTablePaths []ypath.YPath

+ TmpfsPath string

+ TmpfsSize int64

+ UsePortoMemoryTracking *bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL