La bibliothèque se documente elle-même · Concurrence et distribution

stzComputePipeline

18 méthodes propres · 0 formes avec extensions, rangées sous leur méthode

la source: base/cluster/stzComputePipeline.ring(s'ouvre dans un nouvel onglet) · Toutes les classes · La référence du domaine : Concurrence et distribution

Sous chaque méthode, ses extensions (Q CS XT Z ZZ IB W U) : en gras et cochée, elle existe ; barrée, elle n'existe pas. Les extensions et leur sens

Aucune méthode de cette classe n'est exécutée sur cette page : la classe touche aux fichiers, au réseau, aux processus, à l'horloge, au hasard ou au son, et un exemple exécuté ici ne serait que l'exemple de ses effets. Chaque méthode porte l'explication que la bibliothèque donne d'elle-même.

Méthode

Explication, telle que la source la porte

init

(sans commentaire dans la source : le nom se lit comme une phrase) initaucune extension

Name_

(sans commentaire dans la source : le nom se lit comme une phrase) name_aucune extension

Stage

declaring the pipeline -------------------------------------------- Add a stage: fWork(input) -> output, handled by the FACET pcFacet.aucune extension

NumberOfStages

(sans commentaire dans la source : le nom se lit comme une phrase) number of stagesaucune extension

Stages

(sans commentaire dans la source : le nom se lit comme une phrase) stagesaucune extension

SetPool

Attach a worker pool so each stage is admitted into its facet's budget (load isolation across the pipeline; R8.1). Facets not in the pool run unbudgeted. NOTE: the pipeline works on ITS pool (Haro stores a copy) -- read metrics via PoolQ(), not the caller's original.aucune extension

PoolQ

(sans commentaire dans la source : le nom se lit comme une phrase) pool qaucune extension

ValidateAgainst

Check every stage's facet is offered by a catalog (the deployment's competences, R8.2). Returns [] when all known, else the unknown facets -- so a pipeline is validated against what a cluster can run.aucune extension

Run

running ------------------------------------------------------------ Thread pInput through every stage in order; each stage's output feeds the next. Returns the final output. Records a per-stage trace. A stage that RAISES is CONTAINED: the failure is traced, the facet slot is released (no leak), the pipeline HALTS and returns NULL, and Why()/ Failed() explain -- one bad stage never crashes the whole pipeline.aucune extension

Failed

(sans commentaire dans la source : le nom se lit comme une phrase) failedaucune extension

Why

(sans commentaire dans la source : le nom se lit comme une phrase) whyaucune extension

RunBatch

Run many inputs through the WHOLE pipeline; returns a result list (same order). The trace reflects the LAST input.aucune extension

Trace

(sans commentaire dans la source : le nom se lit comme une phrase) traceaucune extension

StageDurations

Per-stage costs from the last Run: [ [ stageName, durMs ], ... ]. The slowest stage is the pipeline's bottleneck candidate.aucune extension

TotalMs

Total cost of the last Run (sum of its stage durations, ms).aucune extension

LastOutput

(sans commentaire dans la source : le nom se lit comme une phrase) last outputaucune extension

Narrate

(sans commentaire dans la source : le nom se lit comme une phrase) narrateaucune extension