vibespatial.runtime.fusion

Classes

StepKind	Enum where members are also (and must be) strings
IntermediateDisposition	Enum where members are also (and must be) strings
PipelineStep
FusionStage
FusionPlan

Functions

plan_fusion(→ FusionPlan)
default_fusible_sequences(→ dict[str, ...)

Module Contents

class vibespatial.runtime.fusion.StepKind

Enum where members are also (and must be) strings

GEOMETRY = 'geometry'

DERIVED = 'derived'

FILTER = 'filter'

ORDERING = 'ordering'

INDEX = 'index'

MATERIALIZATION = 'materialization'

RASTER = 'raster'

class vibespatial.runtime.fusion.IntermediateDisposition

Enum where members are also (and must be) strings

EPHEMERAL = 'ephemeral'

PERSIST = 'persist'

BOUNDARY = 'boundary'

class vibespatial.runtime.fusion.PipelineStep

name: str

kind: StepKind

output_name: str

output_rows_follow_input: bool = True

reusable_output: bool = False

materializes_host_output: bool = False

requires_stable_row_order: bool = False

class vibespatial.runtime.fusion.FusionStage

steps: tuple[PipelineStep, Ellipsis]

disposition: IntermediateDisposition

reason: str

class vibespatial.runtime.fusion.FusionPlan

stages: tuple[FusionStage, Ellipsis]

peak_memory_target_ratio: float

reason: str

vibespatial.runtime.fusion.plan_fusion(steps: tuple[PipelineStep, Ellipsis] | list[PipelineStep]) → FusionPlan

vibespatial.runtime.fusion.default_fusible_sequences() → dict[str, tuple[PipelineStep, Ellipsis]]