vibespatial.spatial.point_partition¶

Private ownership and admission contracts for point-partition reducers.

Classes¶

`PointPartitionVariant`	Enum where members are also (and must be) strings
`PointPartitionCacheKey`	Identity of one prepared derivative of a NativeSpatialIndex.
`PointPartitionQueryPlan`	Device query counts and bounded host schedule for one prepared index.
`PointPartitionQuerySlice`	Provenance-bound capacity token for one candidate scatter.
`PointPartitionDecline`
`PointPartitionPreflight`	Pure provider shape and memory estimate before provider submission.

Module Contents¶

class vibespatial.spatial.point_partition.PointPartitionVariant¶

Enum where members are also (and must be) strings

GRID = 'grid'¶

MORTON = 'morton'¶

class vibespatial.spatial.point_partition.PointPartitionCacheKey¶

Identity of one prepared derivative of a NativeSpatialIndex.

variant: PointPartitionVariant¶

native_index_identity: int¶

source_token: str | None¶

row_count: int¶

order_identity: int¶

morton_identity: int¶

bounds_identity: int¶

device_id: int¶

context_identity: int¶

producer_event_identity: int¶

parameters: tuple[tuple[str, int], Ellipsis]¶

class vibespatial.spatial.point_partition.PointPartitionQueryPlan¶

Device query counts and bounded host schedule for one prepared index.

owner: Any¶

variant: PointPartitionVariant¶

prepared: Any¶

cache_key: PointPartitionCacheKey¶

query_bounds: Any¶

query_counts: Any¶

partitions: tuple[tuple[int, int, int], Ellipsis]¶

pair_budget: int¶

selection_reason: str¶

relation_admission: PointPartitionPreflight | None¶

readiness: vibespatial.api._native_state.NativeStreamReadiness¶

slices() → collections.abc.Iterator[PointPartitionQuerySlice]¶

validate(owner: Any, variant: PointPartitionVariant, prepared: Any) → None¶

class vibespatial.spatial.point_partition.PointPartitionQuerySlice¶

Provenance-bound capacity token for one candidate scatter.

plan: PointPartitionQueryPlan¶

ordinal: int¶

property query_start: int¶

property query_stop: int¶

property capacity: int¶

property oversized: bool¶

property query_bounds¶

property query_counts¶

validate(owner: Any, variant: PointPartitionVariant, prepared: Any) → None¶

class vibespatial.spatial.point_partition.PointPartitionDecline¶

variant: PointPartitionVariant¶

reason: str¶

memory_decline: bool = False¶

class vibespatial.spatial.point_partition.PointPartitionPreflight¶

Pure provider shape and memory estimate before provider submission.

variant: PointPartitionVariant¶

required_bytes: int¶

reason: str¶

owner_identity: int¶

query_count: int¶

pair_budget: int¶

cache_key: PointPartitionCacheKey¶

admitted: bool = False¶

validate_admission(owner: Any, variant: PointPartitionVariant, *, query_count: int, pair_budget: int, cache_key: PointPartitionCacheKey, required_bytes: int) → None¶