exec

package

Go to main page

Versions in this module

v0

v0.11.0

Aug 13, 2026

Changes in this version

+ const MetricExpandIntersectEngaged

+ var ErrSeekSetOverBudget = errors.New("exec: index seek set exceeds its posting budget")

+ func EmitsExactly(op Operator, cols []string) bool

+ func EnforceUniqueOnLabelRemove(reg *ConstraintRegistry, mutator GraphMutator, nodeKey, label string)

+ func EnforceUniqueOnLabelSet(reg *ConstraintRegistry, mutator GraphMutator, mgr *index.Manager, ...) error

+ func EnforceUniqueOnPropertyDelete(reg *ConstraintRegistry, mutator GraphMutator, nodeKey, key string)

+ func EnforceUniqueOnPropertySet(reg *ConstraintRegistry, mutator GraphMutator, mgr *index.Manager, ...) error

+ func ExpandIntoSeekCount() uint64

+ func ExpandIntoSeekReverseCount() uint64

+ func RenderPlan(op Operator) string

+ func RenderPlanNode(n *PlanNode) string

+ type AdjacencySource func() (fwd, rev CSRAdjacency, edgeTypeFilter map[uint64]string)

+ func StaticAdjacency(fwd, rev CSRAdjacency, edgeTypeFilter map[uint64]string) AdjacencySource

type AllShortestPaths

+ func (op *AllShortestPaths) PlanChildren() []Operator

type AntiSemiApply

+ func (op *AntiSemiApply) PlanChildren() []Operator

type Apply

+ func (op *Apply) PlanChildren() []Operator

+ type CSRAdjacency interface

+ EdgesSlice func() []graph.NodeID

+ HandlesSlice func() []uint64

+ VerticesSlice func() []uint64

type ColumnarHashJoin

+ func (op *ColumnarHashJoin) PlanChildren() []Operator

+ func (op *ColumnarHashJoin) PlanDetail() string

+ type ColumnarLimit struct

+ func NewColumnarLimit(lim *Limit) (*ColumnarLimit, bool)

+ func (op *ColumnarLimit) FillChunk(dst *Chunk, maxRows int) (int, error)

+ func (op *ColumnarLimit) NewOutputChunk(capacity int) *Chunk

type ConstraintRegistry

+ func (r *ConstraintRegistry) CommitTxn(ct *ConstraintTxn)

+ func (r *ConstraintRegistry) HasAnyUnique() bool

+ func (r *ConstraintRegistry) ReserveSetProperty(ct *ConstraintTxn, labels []string, prop string, value lpg.PropertyValue, ...) error

+ func (r *ConstraintRegistry) UniqueProperties(label string) []string

+ type ConstraintTxn struct

+ func (t *ConstraintTxn) Reset()

type CorrelatedApply

+ func (op *CorrelatedApply) PlanChildren() []Operator

type CreateNode

+ func (op *CreateNode) PlanChildren() []Operator

type CreateRelationship

+ func (op *CreateRelationship) PlanChildren() []Operator

type DeleteNode

+ func (op *DeleteNode) PlanChildren() []Operator

type DeleteRelationship

+ func (op *DeleteRelationship) PlanChildren() []Operator

type DetachDelete

+ func (op *DetachDelete) PlanChildren() []Operator

type Distinct

+ func (op *Distinct) PlanChildren() []Operator

type Eager

+ func (op *Eager) PlanChildren() []Operator

type EagerAggregation

+ func (op *EagerAggregation) PlanChildren() []Operator

+ type EffectCountingSuppressor interface

+ SuppressEffectCounting func(on bool)

type Expand

+ func (op *Expand) PlanChildren() []Operator

+ func (op *Expand) PlanDetail() string

+ func (op *Expand) WithExpandInto(col int) *Expand

+ func (op *Expand) WithExpandIntoSeek(enabled bool) *Expand

+ type ExpandIntersect struct

+ func NewExpandIntersect(input Operator, src IntersectAdjacencySource, cfg *ExpandIntersectConfig) *ExpandIntersect

+ func (op *ExpandIntersect) Close() error

+ func (op *ExpandIntersect) Init(ctx context.Context) error

+ func (op *ExpandIntersect) Next(out *Row) (bool, error)

+ func (op *ExpandIntersect) PlanChildren() []Operator

+ func (op *ExpandIntersect) PlanDetail() string

+ type ExpandIntersectConfig struct

+ EndCol int

+ EndEdgeType string

+ MidCol int

+ MidEdgeType string

+ RelCols []int

type Filter

+ func (op *Filter) PlanChildren() []Operator

type Foreach

+ func (op *Foreach) PlanChildren() []Operator

type GlobalAggregateAdapter

+ func (op *GlobalAggregateAdapter) PlanChildren() []Operator

type HashJoin

+ func (op *HashJoin) PlanChildren() []Operator

+ func (op *HashJoin) PlanDetail() string

+ type HashLookup interface

+ LookupAppend func(value expr.Value, dst []uint64) ([]uint64, error)

+ type IndexNestedLoopJoin struct

+ func NewIndexNestedLoopJoin(outer, inner Operator, idx NumericPointLookup, outerKeyFn, innerKeyFn KeyFn) *IndexNestedLoopJoin

+ func (op *IndexNestedLoopJoin) Close() error

+ func (op *IndexNestedLoopJoin) Init(ctx context.Context) error

+ func (op *IndexNestedLoopJoin) Next(out *Row) (bool, error)

+ func (op *IndexNestedLoopJoin) PlanChildren() []Operator

+ func (op *IndexNestedLoopJoin) WithProvenNumericCoverage(proven bool) *IndexNestedLoopJoin

+ type IndexRangePart struct

+ Hi RangeBound

+ Index rangeLookup

+ Lo RangeBound

+ type IntersectAdjacencySource func() (fwd, rev CSRAdjacency, midFilter, endFilter map[uint64]string)

+ func StaticIntersectAdjacency(fwd, rev CSRAdjacency, midFilter, endFilter map[uint64]string) IntersectAdjacencySource

+ type LabelIntersectResolver interface

+ ResolveLabelsBitmap func(names []string) *roaring64.Bitmap

type Limit

+ func (op *Limit) PlanChildren() []Operator

type Merge

+ func (op *Merge) PlanChildren() []Operator

+ func (op *Merge) WithLabelSource(src MergeLabelSource) *Merge

+ type MergeLabelSource interface

+ ResolveLabelBitmap func(name string) *roaring64.Bitmap

type MergePattern

+ func (op *MergePattern) PlanChildren() []Operator

+ func (op *MergePattern) WithLabelSource(src MergeLabelSource) *MergePattern

type MergeRelationship

+ func (op *MergeRelationship) PlanChildren() []Operator

type NodeByIndexRangeScan

+ func NewNodeByIndexIntersectionScan(idx rangeLookup, lo, hi RangeBound, parts []IndexRangePart) *NodeByIndexRangeScan

+ func (op *NodeByIndexRangeScan) PlanDetail() string

+ func (op *NodeByIndexRangeScan) RestrictToLabel(resolve func() *roaring64.Bitmap) *NodeByIndexRangeScan

type NodeByIndexSeek

+ func NewNodeByIndexSeekAdmitting(idx HashLookup, seekValue expr.Value, admit func(nodeID uint64) bool) *NodeByIndexSeek

+ func (op *NodeByIndexSeek) PlanDetail() string

+ type NodeByIndexSeekSet struct

+ func NewNodeByIndexSeekSet(idx HashLookup, keys []expr.Value, budget uint64) *NodeByIndexSeekSet

+ func (op *NodeByIndexSeekSet) Admitting(admit func(nodeID uint64) bool) *NodeByIndexSeekSet

+ func (op *NodeByIndexSeekSet) Close() error

+ func (op *NodeByIndexSeekSet) Init(ctx context.Context) error

+ func (op *NodeByIndexSeekSet) Next(out *Row) (bool, error)

type NodeByLabelScan

+ func NewNodeByLabelIntersectionScan(labels []string, src LabelIntersectResolver) *NodeByLabelScan

+ func (op *NodeByLabelScan) PlanDetail() string

+ type NumericPointLookup interface

+ LookupAppend func(value float64, dst []uint64) []uint64

type OptionalApply

+ func (op *OptionalApply) PlanChildren() []Operator

type OptionalExpand

+ func (op *OptionalExpand) PlanChildren() []Operator

+ type PlanChildren interface

+ PlanChildren func() []Operator

+ type PlanDetail interface

+ PlanDetail func() string

+ type PlanNode struct

+ Children []PlanNode

+ DbHits int64

+ Detail string

+ Name string

+ Profiled bool

+ Rows int64

+ Time time.Duration

+ func PlanTree(op Operator) PlanNode

type ProcedureCallOp

+ func (op *ProcedureCallOp) PlanChildren() []Operator

+ type Profiler struct

+ func NewProfiler() *Profiler

+ func (p *Profiler) Wrap(op Operator) Operator

type Project

+ func (op *Project) PlanChildren() []Operator

+ type QueryCounters struct

+ ConstraintsAdded int64

+ ConstraintsRemoved int64

+ IndexesAdded int64

+ IndexesRemoved int64

+ LabelsAdded int64

+ LabelsRemoved int64

+ NodesCreated int64

+ NodesDeleted int64

+ PropertiesRemoved int64

+ PropertiesSet int64

+ RelationshipsCreated int64

+ RelationshipsDeleted int64

+ func (c *QueryCounters) Add(other *QueryCounters)

+ func (c *QueryCounters) ContainsUpdates() bool

type RemoveLabels

+ func (op *RemoveLabels) PlanChildren() []Operator

+ func (op *RemoveLabels) WithConstraintRegistry(reg *ConstraintRegistry) *RemoveLabels

type RemoveProperty

+ func (op *RemoveProperty) PlanChildren() []Operator

type ResultSet

+ func (op *ResultSet) PlanChildren() []Operator

type RollUpApply

+ func (op *RollUpApply) PlanChildren() []Operator

type SemiApply

+ func (op *SemiApply) PlanChildren() []Operator

type SetAllProperties

+ func (op *SetAllProperties) PlanChildren() []Operator

type SetLabels

+ func (op *SetLabels) PlanChildren() []Operator

+ func (op *SetLabels) WithConstraints(reg *ConstraintRegistry, mgr *index.Manager) *SetLabels

type SetProperty

+ func (op *SetProperty) PlanChildren() []Operator

type ShortestPath

+ func (op *ShortestPath) PlanChildren() []Operator

type Skip

+ func (op *Skip) PlanChildren() []Operator

type Sort

+ func (op *Sort) PlanChildren() []Operator

+ type StorageRecordScan interface

type Top

+ func (op *Top) PlanChildren() []Operator

type Union

+ func (op *Union) PlanChildren() []Operator

type UnionAll

+ func (op *UnionAll) PlanChildren() []Operator

type Unwind

+ func (op *Unwind) PlanChildren() []Operator

type VarLengthExpand

+ func (op *VarLengthExpand) PlanChildren() []Operator

v0.10.0

Jul 24, 2026

Changes in this version

+ type AggInputFactory func(ids []graph.NodeID) (Operator, error)

+ type AggReducerKind uint8

+ const ReduceCount

+ const ReduceCountStar

+ const ReduceMax

+ const ReduceMin

+ type AllNodesCountScan struct

+ func NewAllNodesCountScan(g nodeWalker) *AllNodesCountScan

+ func (op *AllNodesCountScan) Close() error

+ func (op *AllNodesCountScan) Init(ctx context.Context) error

+ func (op *AllNodesCountScan) Next(out *Row) (bool, error)

type ChunkProducer

+ func NewColumnarExpand(exp *Expand) (ChunkProducer, bool)

+ type ColumnarHashJoin struct

+ func NewColumnarHashJoin(build, probe Operator, buildFn, probeFn KeyFn, buildOnLeft bool) (*ColumnarHashJoin, bool)

+ func (op *ColumnarHashJoin) Close() error

+ func (op *ColumnarHashJoin) FillChunk(dst *Chunk, maxRows int) (int, error)

+ func (op *ColumnarHashJoin) Init(ctx context.Context) error

+ func (op *ColumnarHashJoin) NewOutputChunk(capacity int) *Chunk

+ func (op *ColumnarHashJoin) Next(out *Row) (bool, error)

+ func (op *ColumnarHashJoin) WithByteBudget(maxBytes int64, estimateRow func(Row) int64) *ColumnarHashJoin

+ type CountBuffer struct

+ func (b *CountBuffer) Commit(cs *count.Store)

+ func (b *CountBuffer) EnqueueDelta(d count.Delta)

+ func (b *CountBuffer) Len() int

+ func (b *CountBuffer) MarkDirty(m count.DirtyMark)

+ func (b *CountBuffer) NumDeltas() int

+ func (b *CountBuffer) Rollback()

+ type ParallelAggregateScan struct

+ func NewParallelAggregateScan(g nodeWalker, factory AggInputFactory, nKeys int, reducers []AggReducerKind, ...) *ParallelAggregateScan

+ func (op *ParallelAggregateScan) Close() error

+ func (op *ParallelAggregateScan) Init(ctx context.Context) error

+ func (op *ParallelAggregateScan) Next(out *Row) (bool, error)

+ func (op *ParallelAggregateScan) WithByteBudget(maxBytes int64, estimateRow func(Row) int64) *ParallelAggregateScan

+ func (op *ParallelAggregateScan) WithGroupCap(maxGroups int) *ParallelAggregateScan

v0.9.0

Jul 19, 2026

Changes in this version

+ const DefaultChunkCapacity

+ func BitSet(bitmap []uint64, i int) bool

type AllNodesScan

+ func (op *AllNodesScan) FillChunk(dst *Chunk, maxRows int) (int, error)

+ func (op *AllNodesScan) NewOutputChunk(capacity int) *Chunk

+ type Chunk struct

+ func NewChunk(capacity int, kinds ...expr.Kind) *Chunk

+ func NewDynamicChunk(capacity, ncols int) *Chunk

+ func (c *Chunk) AppendBool(j int, v bool)

+ func (c *Chunk) AppendFloat64(j int, v float64)

+ func (c *Chunk) AppendInt64(j int, v int64)

+ func (c *Chunk) AppendNull(j int)

+ func (c *Chunk) AppendRowFrom(src *Chunk, srcRow int)

+ func (c *Chunk) AppendString(j int, v string)

+ func (c *Chunk) AppendValue(j int, v expr.Value)

+ func (c *Chunk) Bool(j, row int) (value, valid bool)

+ func (c *Chunk) BoolColumn(j int) (data []bool, valid []uint64, allValid bool)

+ func (c *Chunk) BoxCell(j, row int) expr.Value

+ func (c *Chunk) BoxRow(row int, dst Row) Row

+ func (c *Chunk) Cap() int

+ func (c *Chunk) ColKind(j int) expr.Kind

+ func (c *Chunk) CopyCellTo(srcCol, srcRow int, dst *Chunk, dstCol int)

+ func (c *Chunk) Float64(j, row int) (value float64, valid bool)

+ func (c *Chunk) Float64Column(j int) (data []float64, valid []uint64, allValid bool)

+ func (c *Chunk) Int64(j, row int) (value int64, valid bool)

+ func (c *Chunk) Int64Column(j int) (data []int64, valid []uint64, allValid bool)

+ func (c *Chunk) IsBoolColumn(j int) bool

+ func (c *Chunk) IsFloat64Column(j int) bool

+ func (c *Chunk) IsInt64Column(j int) bool

+ func (c *Chunk) IsNull(j, row int) bool

+ func (c *Chunk) IsStringColumn(j int) bool

+ func (c *Chunk) IsValid(j, row int) bool

+ func (c *Chunk) Len() int

+ func (c *Chunk) NumCols() int

+ func (c *Chunk) PutBool(j int, v bool)

+ func (c *Chunk) PutFloat64(j int, v float64)

+ func (c *Chunk) PutInt64(j int, v int64)

+ func (c *Chunk) PutNull(j int)

+ func (c *Chunk) PutString(j int, v string)

+ func (c *Chunk) PutValue(j int, v expr.Value)

+ func (c *Chunk) Reset()

+ func (c *Chunk) RowByteEstimate(row int, overhead int64, estimateBoxed func(expr.Value) int64) int64

+ func (c *Chunk) SetBool(j, row int, v bool)

+ func (c *Chunk) SetFloat64(j, row int, v float64)

+ func (c *Chunk) SetInt64(j, row int, v int64)

+ func (c *Chunk) SetNull(j, row int)

+ func (c *Chunk) SetString(j, row int, v string)

+ func (c *Chunk) String(j, row int) (value string, valid bool)

+ func (c *Chunk) StringColumn(j int) (data []string, valid []uint64, allValid bool)

+ type ChunkColumnFiller func(src *Chunk, srcRow int, dst *Chunk, dstCol int) error

+ type ChunkPool struct

+ func NewChunkPool(capacity int, kinds ...expr.Kind) *ChunkPool

+ func (cp *ChunkPool) Get() *Chunk

+ func (cp *ChunkPool) Put(c *Chunk)

+ type ChunkPredicate func(src *Chunk, row int) (keep, decided bool)

+ type ChunkProducer interface

+ FillChunk func(dst *Chunk, maxRows int) (int, error)

+ NewOutputChunk func(capacity int) *Chunk

+ type ColumnFiller func(row Row, dst *Chunk, col int) error

+ type ColumnarFilter struct

+ func NewColumnarFilter(child ChunkProducer, predFn FilterFn, pred ChunkPredicate) *ColumnarFilter

+ func (op *ColumnarFilter) FillChunk(dst *Chunk, maxRows int) (int, error)

+ func (op *ColumnarFilter) Init(ctx context.Context) error

+ func (op *ColumnarFilter) NewOutputChunk(capacity int) *Chunk

+ type ColumnarProject struct

+ func NewColumnarProject(child Operator, items []ProjectionItem, fillers []ColumnFiller) (*ColumnarProject, error)

+ func (op *ColumnarProject) FillChunk(dst *Chunk, maxRows int) (int, error)

+ func (op *ColumnarProject) NewOutputChunk(capacity int) *Chunk

+ func (op *ColumnarProject) WithChunkInput(chunkFillers []ChunkColumnFiller) error

+ func (op *ColumnarProject) WithScalarChunkInput(chunkFillers []ChunkColumnFiller) error

type DeleteRelationship

+ func (op *DeleteRelationship) WithRelCols(rc RelCols) *DeleteRelationship

type EagerAggregation

+ func (op *EagerAggregation) WithChunkInput() error

+ type ExprValueEvalFn func(row Row) (expr.Value, error)

+ type Foreach struct

+ func NewForeach(outer, inner Operator, arg *Argument) *Foreach

+ func (op *Foreach) Close() error

+ func (op *Foreach) Init(ctx context.Context) error

+ func (op *Foreach) Next(out *Row) (bool, error)

type GraphMutator

+ RemoveEdgeByHandle func(src, dst string, handle uint64)

+ type LabelCountScan struct

+ func NewLabelCountScan(label string, src labelResolver) *LabelCountScan

+ func (op *LabelCountScan) Close() error

+ func (op *LabelCountScan) Init(ctx context.Context) error

+ func (op *LabelCountScan) Next(out *Row) (bool, error)

+ type MapEvalFn func(row Row) (entries []PropEntry, nullKeys []string, err error)

type Merge

+ func (op *Merge) WithSetAllActions(onCreate, onMatch []MergeSetAllAction) *Merge

type MergePattern

+ func (op *MergePattern) MarkHopRefsPatternNode() *MergePattern

+ func (op *MergePattern) WithHopPropsEvalFn(fn PropsEvalFn) *MergePattern

+ func (op *MergePattern) WithSetAllActions(onCreate, onMatch []MergeSetAllAction) *MergePattern

type MergeRelationship

+ func (op *MergeRelationship) WithParams(params map[string]expr.Value) (*MergeRelationship, error)

+ func (op *MergeRelationship) WithRelPropsEvalFn(fn PropsEvalFn) *MergeRelationship

+ type MergeSetAllAction struct

+ Eval ExprValueEvalFn

+ IsReplace bool

+ TargetVar string

type NodeByLabelScan

+ func (op *NodeByLabelScan) FillChunk(dst *Chunk, maxRows int) (int, error)

+ func (op *NodeByLabelScan) NewOutputChunk(capacity int) *Chunk

+ type NodeIDColumnProducer interface

type ResultSet

+ func (rs *ResultSet) ColumnarProducer() (ChunkProducer, bool)

type SetAllProperties

+ func NewSetAllPropertiesFromExpr(entityVar string, isReplace bool, schema map[string]int, child Operator, ...) *SetAllProperties

+ func (op *SetAllProperties) WithExprEvalFn(fn ExprValueEvalFn) *SetAllProperties

+ func (op *SetAllProperties) WithMapEvalFn(fn MapEvalFn) *SetAllProperties

+ type StaticRows struct

+ func NewStaticRows(rows []Row) *StaticRows

+ func (op *StaticRows) Close() error

+ func (op *StaticRows) Init(ctx context.Context) error

+ func (op *StaticRows) Next(out *Row) (bool, error)

v0.8.1

Jul 14, 2026

v0.8.0

Jul 14, 2026

Changes in this version

+ var ErrConstraintAlreadyExists = errors.New("exec: constraint already exists")

+ var ErrConstraintNameConflict = errors.New("exec: constraint name already in use")

+ var ErrNestedPropertyValue = errors.New(...)

+ func MergeActionEvalKey(targetVar, key string) string

type ConstraintRegistry

+ func (r *ConstraintRegistry) NameInUse(name string) (kind ConstraintKind, label, prop string, found bool)

type Merge

+ func (op *Merge) WithActionEvals(onCreate, onMatch map[string]ValueEvalFn) *Merge

type MergePattern

+ func (op *MergePattern) WithActionEvals(onCreate, onMatch map[string]ValueEvalFn) *MergePattern

type MergeRelationship

+ func (op *MergeRelationship) WithActionEvals(onCreate, onMatch map[string]ValueEvalFn) *MergeRelationship

v0.7.0

Jul 3, 2026

Changes in this version

+ var ErrHashJoinMemoryExceeded = errors.New("exec: hash join memory cap exceeded")

+ var ErrProjectionRowTooLarge = errors.New("exec: projection row memory cap exceeded")

type AllShortestPaths

+ func (op *AllShortestPaths) WithWorkBudget(maxPerRow, maxTotal int) *AllShortestPaths

type Distinct

+ func (op *Distinct) WithByteBudget(maxBytes int64, estimateRow func(Row) int64) *Distinct

type Eager

+ func (op *Eager) WithByteBudget(maxBytes int64, estimateRow func(Row) int64) *Eager

type EagerAggregation

+ func (op *EagerAggregation) WithByteBudget(maxBytes int64, estimateRow func(Row) int64) *EagerAggregation

type HashJoin

+ func (op *HashJoin) WithByteBudget(maxBytes int64, estimateRow func(Row) int64) *HashJoin

+ type MergePattern struct

+ func NewMergePattern(child Operator, mutator GraphMutator) *MergePattern

+ func (op *MergePattern) AddBoundNode(varName string, col int) *MergePattern

+ func (op *MergePattern) AddFreshNode(varName string, labels []string, propsRaw string, outCol int) *MergePattern

+ func (op *MergePattern) AddHop(relVar string, relCol int, relType, relPropsRaw string, ...) *MergePattern

+ func (op *MergePattern) Close() error

+ func (op *MergePattern) Init(ctx context.Context) error

+ func (op *MergePattern) Next(out *Row) (bool, error)

+ func (op *MergePattern) WithActions(onCreateStrs, onMatchStrs []string) (*MergePattern, error)

+ func (op *MergePattern) WithConstraints(reg *ConstraintRegistry, mgr *index.Manager) *MergePattern

+ func (op *MergePattern) WithNodePropsEvalFn(fn PropsEvalFn) *MergePattern

+ func (op *MergePattern) WithParams(params map[string]expr.Value) (*MergePattern, error)

type ParallelScanProject

+ func (op *ParallelScanProject) WithResultBudget(maxRows, maxBytes int64, estimateRow func(Row) int64) *ParallelScanProject

type Project

+ func (op *Project) WithRowByteBudget(maxRowBytes int64, estimateValue func(expr.Value) int64) *Project

type ShortestPath

+ func (op *ShortestPath) WithWorkBudget(maxPerRow, maxTotal int) *ShortestPath

type Sort

+ func (op *Sort) WithByteBudget(maxBytes int64, estimateRow func(Row) int64) *Sort

v0.6.0

Jun 28, 2026

Changes in this version

+ const VLEDirForward

+ const VLEDirReverse

+ const VLEHopStride

type AllShortestPaths

+ func (op *AllShortestPaths) WithHopBounds(minHops, maxHops int) *AllShortestPaths

+ func (op *AllShortestPaths) WithOptional(optional bool) *AllShortestPaths

+ func (op *AllShortestPaths) WithPathPredicate(pred func(Row) (bool, error)) *AllShortestPaths

+ func (op *AllShortestPaths) WithTypeFilter(edgeType string, filter map[uint64]string) *AllShortestPaths

type ConstraintRegistry

+ func (r *ConstraintRegistry) HasAnyNotNull() bool

+ func (r *ConstraintRegistry) NotNullProperties(label string) []string

+ type Float64RangeIndex struct

+ func NewFloat64RangeIndex(idx interface{ ... }) *Float64RangeIndex

+ func (r *Float64RangeIndex) RangeBitmap(lo, hi expr.Value) *roaring64.Bitmap

type GraphMutator

+ DelEdgePropertyByHandle func(src, dst string, handle uint64, key string)

+ EdgeHandleAtPosition func(src, dst string, edgePos uint64) uint64

+ FirstEdgeHandle func(src, dst string) (uint64, bool)

type Int64HashIndex

+ func (h *Int64HashIndex) LookupAppend(value expr.Value, dst []uint64) ([]uint64, error)

type MergeRelAction

+ func MergeRelActionReplaceFromKV(key, value string, replace bool, retainKeys []string) MergeRelAction

+ type ParallelCountScan struct

+ func NewParallelCountScan(g nodeWalker, morselSize int, gov *ParallelGovernor) *ParallelCountScan

+ func (op *ParallelCountScan) Close() error

+ func (op *ParallelCountScan) Init(ctx context.Context) error

+ func (op *ParallelCountScan) Next(out *Row) (bool, error)

+ type ParallelGovernor struct

+ func (g *ParallelGovernor) Enter(morsels int) int

+ func (g *ParallelGovernor) Leave()

+ type ParallelScanProject struct

+ func NewParallelScanProject(g nodeWalker, factory SubplanFactory, morselSize int, gov *ParallelGovernor) *ParallelScanProject

+ func (op *ParallelScanProject) Close() error

+ func (op *ParallelScanProject) Init(ctx context.Context) error

+ func (op *ParallelScanProject) Next(out *Row) (bool, error)

type RelCols

+ EdgeCol int

type ResultSet

+ func (rs *ResultSet) RowCountHint() (n int, ok bool)

type ShortestPath

+ func (op *ShortestPath) WithHopBounds(minHops, maxHops int) *ShortestPath

+ func (op *ShortestPath) WithOptional(optional bool) *ShortestPath

+ func (op *ShortestPath) WithPathPredicate(pred func(Row) (bool, error)) *ShortestPath

+ func (op *ShortestPath) WithTypeFilter(edgeType string, filter map[uint64]string) *ShortestPath

type StringHashIndex

+ func (h *StringHashIndex) LookupAppend(value expr.Value, dst []uint64) ([]uint64, error)

+ type SubplanFactory func(morsel []graph.NodeID) (Operator, error)

v0.5.0

Jun 17, 2026

v0.4.0

Jun 17, 2026

Changes in this version

+ var ErrConstraintNotFound = errors.New("exec: constraint not found")

type ConstraintRegistry

+ func (r *ConstraintRegistry) ResolveByName(name string) (kind ConstraintKind, label, prop string, found bool)

v0.3.2

Jun 15, 2026

v0.3.1

Jun 15, 2026

Changes in this version

+ type HashJoin struct

+ func NewHashJoin(build, probe Operator, buildFn, probeFn KeyFn, buildOnLeft bool) *HashJoin

+ func (op *HashJoin) Close() error

+ func (op *HashJoin) Init(ctx context.Context) error

+ func (op *HashJoin) Next(out *Row) (bool, error)

+ type KeyFn func(row Row) (expr.Value, error)

type ResultSet

+ func (rs *ResultSet) Row() Row

v0.3.0

Jun 14, 2026

Changes in this version

type ConstraintRegistry

+ func (r *ConstraintRegistry) Count() int

+ func (r *ConstraintRegistry) ReleasePropertyValue(labels []string, prop string, value lpg.PropertyValue)

+ func (r *ConstraintRegistry) ReseedFromGraph(scanFn func(label, prop string) []lpg.PropertyValue)

type CreateConstraintOp

+ func (op *CreateConstraintOp) WithBackingIndex(sub index.Subscriber) *CreateConstraintOp

type DeleteNode

+ func (op *DeleteNode) WithConstraintRegistry(reg *ConstraintRegistry) *DeleteNode

type DetachDelete

+ func (op *DetachDelete) WithConstraintRegistry(reg *ConstraintRegistry) *DetachDelete

type GraphMutator

+ RemoveAllEdgesFrom func(n string)

type RemoveProperty

+ func (op *RemoveProperty) WithConstraintRegistry(reg *ConstraintRegistry) *RemoveProperty

type VarLengthConfig

+ MaxTotalEdgesTraversed int

v0.2.0

Jun 5, 2026

Changes in this version

+ const DefaultMaxEagerRows

+ var ErrEagerMemoryExceeded = errors.New("exec: eager memory cap exceeded")

+ func NewUniqueBackingIndex() index.Subscriber

+ func UniqueIndexName(label, prop string) string

+ type ConstraintInfo struct

+ KindUnique bool

+ Label string

+ Name string

+ Property string

type ConstraintRegistry

+ func (r *ConstraintRegistry) Constraints() []ConstraintInfo

+ func (r *ConstraintRegistry) HasUnique(label, prop string) bool

+ func (r *ConstraintRegistry) SeedUniqueValues(label, prop string, values []lpg.PropertyValue) error

+ func (r *ConstraintRegistry) SeedUniqueValuesIgnoringDuplicates(label, prop string, values []lpg.PropertyValue)

+ func (r *ConstraintRegistry) SetConstraintName(kindUnique bool, label, prop, name string)

type RollUpApply

+ func NewRollUpApplyN(outer, inner Operator, arg *Argument, listEval func(Row) (expr.Value, error), ...) *RollUpApply

v0.1.0

Jun 2, 2026

Changes in this version

+ const DefaultMaxDistinct

+ const DefaultMaxGroups

+ const DefaultMaxSortRows

+ const DefaultMorselSize

+ const DefaultSlabCapacity

+ var ErrAggMemoryExceeded = errors.New("exec: aggregation memory cap exceeded")

+ var ErrConstraintViolation = errors.New("exec: constraint violation")

+ var ErrDeleteNodeHasRelationships = errors.New("exec: cannot delete node with existing relationships; use DETACH DELETE")

+ var ErrDistinctMemoryExceeded = errors.New("exec: distinct memory cap exceeded")

+ var ErrIndexTypeMismatch = errors.New("exec: index type mismatch")

+ var ErrPropertyValueIsNull = errors.New("exec: property value is null (skip)")

+ var ErrSchemaMismatch = errors.New("exec: union schema mismatch: column counts differ")

+ var ErrSlabOverflow = errors.New("exec: row slab overflow")

+ var ErrSortMemoryExceeded = errors.New("exec: sort memory cap exceeded")

+ var ErrUnwindNilChild = errors.New("exec: NewUnwind requires non-nil child Operator")

+ var ErrUnwindNilListFn = errors.New("exec: NewUnwind requires non-nil listFn")

+ var ErrVarLenCapExceeded = errors.New("exec: variable-length expand safety cap exceeded")

+ func PropMapContainsNullLiteral(s string) bool

+ func WithCyphermorphism(relCols []int) expandOption

+ type AllNodesScan struct

+ func NewAllNodesScan(g nodeWalker) *AllNodesScan

+ func (op *AllNodesScan) Close() error

+ func (op *AllNodesScan) Init(ctx context.Context) error

+ func (op *AllNodesScan) Next(out *Row) (bool, error)

+ type AllShortestPaths struct

+ func NewAllShortestPaths(input Operator, fwd, rev csrAdjacency, dir Direction, srcCol, dstCol int) *AllShortestPaths

+ func (op *AllShortestPaths) Close() error

+ func (op *AllShortestPaths) Init(ctx context.Context) error

+ func (op *AllShortestPaths) Next(out *Row) (bool, error)

+ type AntiSemiApply struct

+ func NewAntiSemiApply(outer, inner Operator, arg *Argument) *AntiSemiApply

+ func (op *AntiSemiApply) Close() error

+ func (op *AntiSemiApply) Init(ctx context.Context) error

+ func (op *AntiSemiApply) Next(out *Row) (bool, error)

+ type Apply struct

+ func NewApply(outer, inner Operator, arg *Argument) *Apply

+ func (op *Apply) Close() error

+ func (op *Apply) Init(ctx context.Context) error

+ func (op *Apply) Next(out *Row) (bool, error)

+ type Argument struct

+ func NewArgument() *Argument

+ func (op *Argument) Close() error

+ func (op *Argument) Init(ctx context.Context) error

+ func (op *Argument) Next(out *Row) (bool, error)

+ func (op *Argument) SetOuterRow(row Row)

+ type ConstraintKind uint8

+ const ConstraintNotNull

+ const ConstraintUnique

+ type ConstraintRegistry struct

+ func NewConstraintRegistry() *ConstraintRegistry

+ func (r *ConstraintRegistry) CheckSetProperty(labels []string, prop string, value lpg.PropertyValue, mgr *index.Manager) error

+ func (r *ConstraintRegistry) HasNotNull(label, prop string) bool

+ func (r *ConstraintRegistry) ListConstraintRows() [][]expr.Value

+ func (r *ConstraintRegistry) RecordPropertySet(labels []string, prop string, value lpg.PropertyValue)

+ func (r *ConstraintRegistry) RegisterNotNull(label, prop string)

+ func (r *ConstraintRegistry) RegisterUnique(label, prop, indexName string)

+ func (r *ConstraintRegistry) UniqueIndexName(label, prop string) (string, bool)

+ func (r *ConstraintRegistry) UnregisterNotNull(label, prop string)

+ func (r *ConstraintRegistry) UnregisterUnique(label, prop string)

+ type ConstraintViolationError struct

+ Detail string

+ Kind string

+ Label string

+ Property string

+ func (e *ConstraintViolationError) Error() string

+ func (e *ConstraintViolationError) Unwrap() error

+ type CorrelatedApply struct

+ func (op *CorrelatedApply) Close() error

+ func (op *CorrelatedApply) Init(ctx context.Context) error

+ func (op *CorrelatedApply) Next(out *Row) (bool, error)

+ type CreateConstraintOp struct

+ func NewCreateConstraintOp(name, label, prop string, kind ConstraintKind, ifNotExists bool, ...) *CreateConstraintOp

+ func (op *CreateConstraintOp) Close() error

+ func (op *CreateConstraintOp) Init(ctx context.Context) error

+ func (op *CreateConstraintOp) Next(_ *Row) (bool, error)

+ type CreateIndexOp struct

+ func NewCreateIndexOp(name string, kind IndexKindExec, ifNotExists bool, mgr *index.Manager, ...) *CreateIndexOp

+ func (op *CreateIndexOp) Close() error

+ func (op *CreateIndexOp) Init(ctx context.Context) error

+ func (op *CreateIndexOp) Next(_ *Row) (bool, error)

+ type CreateNode struct

+ func NewCreateNode(nodeVar string, labels []string, properties string, child Operator, ...) (*CreateNode, error)

+ func (op *CreateNode) Close() error

+ func (op *CreateNode) Init(ctx context.Context) error

+ func (op *CreateNode) Next(out *Row) (bool, error)

+ func (op *CreateNode) WithConstraints(reg *ConstraintRegistry, mgr *index.Manager) *CreateNode

+ func (op *CreateNode) WithParams(params map[string]expr.Value) (*CreateNode, error)

+ func (op *CreateNode) WithPropsEvalFn(fn PropsEvalFn) *CreateNode

+ type CreateRelationship struct

+ func NewCreateRelationship(startVar, endVar, relVar, relType, properties string, schema map[string]int, ...) (*CreateRelationship, error)

+ func (op *CreateRelationship) Close() error

+ func (op *CreateRelationship) Init(ctx context.Context) error

+ func (op *CreateRelationship) Next(out *Row) (bool, error)

+ func (op *CreateRelationship) WithParams(params map[string]expr.Value) (*CreateRelationship, error)

+ func (op *CreateRelationship) WithPropsEvalFn(fn PropsEvalFn) *CreateRelationship

+ type DeleteNode struct

+ func NewDeleteNode(nodeVar string, schema map[string]int, child Operator, mutator GraphMutator) *DeleteNode

+ func (op *DeleteNode) Close() error

+ func (op *DeleteNode) Init(ctx context.Context) error

+ func (op *DeleteNode) Next(out *Row) (bool, error)

+ func (op *DeleteNode) WithRelEndpoints(fn RelEndpointFn) *DeleteNode

+ func (op *DeleteNode) WithTargetEvalFn(fn TargetEvalFn) *DeleteNode

+ type DeleteRelationship struct

+ func NewDeleteRelationship(relVar string, schema map[string]int, child Operator, mutator GraphMutator) *DeleteRelationship

+ func (op *DeleteRelationship) Close() error

+ func (op *DeleteRelationship) Init(ctx context.Context) error

+ func (op *DeleteRelationship) Next(out *Row) (bool, error)

+ type DetachDelete struct

+ func NewDetachDelete(nodeVar string, schema map[string]int, child Operator, mutator GraphMutator) *DetachDelete

+ func (op *DetachDelete) Close() error

+ func (op *DetachDelete) Init(ctx context.Context) error

+ func (op *DetachDelete) Next(out *Row) (bool, error)

+ func (op *DetachDelete) WithTargetEvalFn(fn TargetEvalFn) *DetachDelete

+ type Direction uint8

+ const DirBoth

+ const DirIn

+ const DirOut

+ type Distinct struct

+ func NewDistinct(child Operator, maxDistinct int) *Distinct

+ func (op *Distinct) Close() error

+ func (op *Distinct) Init(ctx context.Context) error

+ func (op *Distinct) Next(out *Row) (bool, error)

+ type DropConstraintOp struct

+ func NewDropConstraintOp(name, label, prop string, kind ConstraintKind, ifExists bool, ...) *DropConstraintOp

+ func (op *DropConstraintOp) Close() error

+ func (op *DropConstraintOp) Init(ctx context.Context) error

+ func (op *DropConstraintOp) Next(_ *Row) (bool, error)

+ type DropIndexOp struct

+ func NewDropIndexOp(name string, ifExists bool, mgr *index.Manager, onSchemaChange func()) *DropIndexOp

+ func (op *DropIndexOp) Close() error

+ func (op *DropIndexOp) Init(ctx context.Context) error

+ func (op *DropIndexOp) Next(_ *Row) (bool, error)

+ type Eager struct

+ func NewEager(child Operator) *Eager

+ func (op *Eager) Close() error

+ func (op *Eager) Init(ctx context.Context) error

+ func (op *Eager) Next(out *Row) (bool, error)

+ type EagerAggregation struct

+ func NewEagerAggregation(child Operator, keyCols []int, aggFactories []funcs.AggregatorFactory, ...) (*EagerAggregation, error)

+ func (op *EagerAggregation) Close() error

+ func (op *EagerAggregation) Init(ctx context.Context) error

+ func (op *EagerAggregation) Next(out *Row) (bool, error)

+ type Expand struct

+ func NewExpand(input Operator, fwd, rev csrAdjacency, cfg ExpandConfig) *Expand

+ func NewExpandWithOptions(input Operator, fwd, rev csrAdjacency, cfg ExpandConfig, ...) *Expand

+ func (op *Expand) Close() error

+ func (op *Expand) Init(ctx context.Context) error

+ func (op *Expand) Next(out *Row) (bool, error)

+ type ExpandConfig struct

+ Direction Direction

+ EdgeType string

+ EdgeTypeFilter map[uint64]string

+ InputCol int

+ MultiplicityFn func(srcID, dstID uint64) int64

+ RelCols []int

+ type Filter struct

+ func NewFilter(child Operator, predFn FilterFn) *Filter

+ func (op *Filter) Close() error

+ func (op *Filter) Init(ctx context.Context) error

+ func (op *Filter) Next(out *Row) (bool, error)

+ type FilterFn func(row Row) (expr.Value, error)

+ type GlobalAggregateAdapter struct

+ func NewGlobalAggregateAdapter(child Operator, aggFactories []funcs.AggregatorFactory) *GlobalAggregateAdapter

+ func (op *GlobalAggregateAdapter) Close() error

+ func (op *GlobalAggregateAdapter) Init(ctx context.Context) error

+ func (op *GlobalAggregateAdapter) Next(out *Row) (bool, error)

+ type GraphMutator interface

+ AddEdge func(src, dst string, w float64) (srcID, dstID graph.NodeID, err error)

+ AddEdgeH func(src, dst string, w float64) (srcID, dstID graph.NodeID, handle uint64, err error)

+ AddNode func(n string) (graph.NodeID, error)

+ DecEdgeCreateCount func(src, dst string)

+ DelEdgeProperty func(src, dst, key string)

+ DelNodeProperty func(n, key string)

+ EdgeCreateCount func(src, dst string) int64

+ EdgeLabels func(src, dst string) []string

+ EdgeLabelsAt func(src, dst string, idx int64) []string

+ EdgeLabelsByHandle func(src, dst string, handle uint64) []string

+ EdgeProperties func(src, dst string) map[string]lpg.PropertyValue

+ EdgePropertiesAt func(src, dst string, idx int64) map[string]lpg.PropertyValue

+ EdgePropertiesByHandle func(src, dst string, handle uint64) map[string]lpg.PropertyValue

+ HasEdge func(src, dst string) bool

+ InNeighbours func(n string) []string

+ IncEdgeCreateCount func(src, dst string) int64

+ IsTombstoned func(id graph.NodeID) bool

+ NodeLabels func(n string) []string

+ NodeProperties func(n string) map[string]lpg.PropertyValue

+ OutDegree func(n string) int

+ OutNeighbours func(n string) []string

+ RemoveEdge func(src, dst string)

+ RemoveEdgeInstance func(src, dst string, idx int64)

+ RemoveEdgeInstanceByHandle func(src, dst string, handle uint64)

+ RemoveNode func(n string)

+ RemoveNodeLabel func(n, label string)

+ ResolveNodeID func(n string) (graph.NodeID, bool)

+ ResolveNodeLabel func(id graph.NodeID) (string, bool)

+ SetEdgeLabel func(src, dst, label string)

+ SetEdgeLabelAt func(src, dst string, idx int64, label string)

+ SetEdgeLabelByHandle func(src, dst string, handle uint64, label string)

+ SetEdgeProperty func(src, dst, key string, value lpg.PropertyValue) error

+ SetEdgePropertyAt func(src, dst string, idx int64, key string, value lpg.PropertyValue)

+ SetEdgePropertyByHandle func(src, dst string, handle uint64, key string, value lpg.PropertyValue)

+ SetNodeLabel func(n, label string) error

+ SetNodeProperty func(n, key string, value lpg.PropertyValue) error

+ WalkNodeIDs func(fn func(graph.NodeID) bool)

+ type IndexBuffer struct

+ func (b *IndexBuffer) Commit(mgr *index.Manager)

+ func (b *IndexBuffer) Enqueue(c index.Change)

+ func (b *IndexBuffer) Len() int

+ func (b *IndexBuffer) Rollback()

+ type IndexKindExec uint8

+ const ExecIndexBTree

+ const ExecIndexHash

+ type Int64HashIndex struct

+ func NewInt64HashIndex(idx interface{ ... }) *Int64HashIndex

+ func (h *Int64HashIndex) LookupBitmap(value expr.Value) (*roaring64.Bitmap, error)

+ type Int64RangeIndex struct

+ func NewInt64RangeIndex(idx interface{ ... }) *Int64RangeIndex

+ func (r *Int64RangeIndex) RangeBitmap(lo, hi expr.Value) *roaring64.Bitmap

+ type LPGLabelSource struct

+ func NewLPGLabelSource(reg *label.Index, lookupFn func(string) (uint32, bool)) *LPGLabelSource

+ func (s *LPGLabelSource) ResolveLabelBitmap(name string) *roaring64.Bitmap

+ type Limit struct

+ func NewLimit(child Operator, n int64) (*Limit, error)

+ func (op *Limit) Close() error

+ func (op *Limit) Init(ctx context.Context) error

+ func (op *Limit) Next(out *Row) (bool, error)

+ type Merge struct

+ func NewMerge(nodeVar string, labels []string, properties string, ...) (*Merge, error)

+ func (op *Merge) Close() error

+ func (op *Merge) Init(ctx context.Context) error

+ func (op *Merge) Next(out *Row) (bool, error)

+ func (op *Merge) WithConstraints(reg *ConstraintRegistry, mgr *index.Manager) *Merge

+ func (op *Merge) WithParams(params map[string]expr.Value) (*Merge, error)

+ func (op *Merge) WithPropsEvalFn(fn PropsEvalFn) *Merge

+ type MergeRelAction struct

+ func MergeRelActionFromKV(key, value string) MergeRelAction

+ type MergeRelationship struct

+ func NewMergeRelationship(child Operator, srcCol, dstCol int, relType string, mutator GraphMutator) *MergeRelationship

+ func (op *MergeRelationship) Close() error

+ func (op *MergeRelationship) Init(ctx context.Context) error

+ func (op *MergeRelationship) Next(out *Row) (bool, error)

+ func (op *MergeRelationship) WithOnCreate(relVar string, actions []MergeRelAction) *MergeRelationship

+ func (op *MergeRelationship) WithOnMatch(relVar string, actions []MergeRelAction) *MergeRelationship

+ func (op *MergeRelationship) WithRelColumn(relCol int) *MergeRelationship

+ func (op *MergeRelationship) WithRelProperties(propsRaw string) *MergeRelationship

+ func (op *MergeRelationship) WithSchema(schema map[string]int) *MergeRelationship

+ func (op *MergeRelationship) WithUndirected(u bool) *MergeRelationship

+ type MergeSearchFn func(ctx context.Context) ([]Row, error)

+ func NewMergeSearchFnFromPattern(labels []string, propertiesRaw string, params map[string]expr.Value, ...) (MergeSearchFn, error)

+ type NodeByIndexRangeScan struct

+ func NewNodeByIndexRangeScan(idx rangeLookup, lo, hi RangeBound) *NodeByIndexRangeScan

+ func (op *NodeByIndexRangeScan) Close() error

+ func (op *NodeByIndexRangeScan) Init(ctx context.Context) error

+ func (op *NodeByIndexRangeScan) Next(out *Row) (bool, error)

+ type NodeByIndexSeek struct

+ func NewNodeByIndexSeek(idx hashLookup, seekValue expr.Value) *NodeByIndexSeek

+ func (op *NodeByIndexSeek) Close() error

+ func (op *NodeByIndexSeek) Init(ctx context.Context) error

+ func (op *NodeByIndexSeek) Next(out *Row) (bool, error)

+ type NodeByLabelScan struct

+ func NewNodeByLabelScan(labelName string, src labelResolver) *NodeByLabelScan

+ func (op *NodeByLabelScan) Close() error

+ func (op *NodeByLabelScan) Init(ctx context.Context) error

+ func (op *NodeByLabelScan) Next(out *Row) (bool, error)

+ type Operator interface

+ Close func() error

+ Init func(ctx context.Context) error

+ Next func(out *Row) (bool, error)

+ type OptionalApply struct

+ func NewOptionalApply(outer, inner Operator, arg *Argument, paddedWidth int) *OptionalApply

+ func (op *OptionalApply) Close() error

+ func (op *OptionalApply) Init(ctx context.Context) error

+ func (op *OptionalApply) Next(out *Row) (bool, error)

+ type OptionalExpand struct

+ func NewOptionalExpand(input Operator, fwd, rev csrAdjacency, cfg ExpandConfig) *OptionalExpand

+ func (op *OptionalExpand) Close() error

+ func (op *OptionalExpand) Init(ctx context.Context) error

+ func (op *OptionalExpand) Next(out *Row) (bool, error)

+ type ParallelScan struct

+ func NewParallelScan(g nodeWalker, morselSize int) *ParallelScan

+ func (op *ParallelScan) Close() error

+ func (op *ParallelScan) Init(ctx context.Context) error

+ func (op *ParallelScan) Next(out *Row) (bool, error)

+ type ProcedureCallOp struct

+ func NewProcedureCallOp(namespace []string, name string, argExprs []func(Row) (expr.Value, error), ...) *ProcedureCallOp

+ func (op *ProcedureCallOp) Close() error

+ func (op *ProcedureCallOp) Init(ctx context.Context) error

+ func (op *ProcedureCallOp) Next(out *Row) (bool, error)

+ type Project struct

+ func NewProject(child Operator, items []ProjectionItem) (*Project, error)

+ func (op *Project) Close() error

+ func (op *Project) Columns() []string

+ func (op *Project) Init(ctx context.Context) error

+ func (op *Project) Next(out *Row) (bool, error)

+ type ProjectionItem struct

+ Alias string

+ Eval func(Row) (expr.Value, error)

+ type PropEntry struct

+ Key string

+ Value lpg.PropertyValue

+ type PropsEvalFn func(row Row) []PropEntry

+ type RangeBound struct

+ Include bool

+ Value expr.Value

+ type Record map[string]interface

+ type RelCols struct

+ DstCol int

+ SrcCol int

+ type RelEndpointFn func(row Row) (uint64, uint64, bool)

+ type RemoveLabels struct

+ func NewRemoveLabels(nodeVar string, labels []string, schema map[string]int, child Operator, ...) *RemoveLabels

+ func (op *RemoveLabels) Close() error

+ func (op *RemoveLabels) Init(ctx context.Context) error

+ func (op *RemoveLabels) Next(out *Row) (bool, error)

+ type RemoveProperty struct

+ func NewRemoveProperty(entityVar, propertyKey string, schema map[string]int, child Operator, ...) *RemoveProperty

+ func (op *RemoveProperty) Close() error

+ func (op *RemoveProperty) Init(ctx context.Context) error

+ func (op *RemoveProperty) Next(out *Row) (bool, error)

+ func (op *RemoveProperty) WithRelCols(rc RelCols) *RemoveProperty

+ type Result interface

+ Close func() error

+ Columns func() []string

+ Err func() error

+ Next func() bool

+ Record func() Record

+ type ResultSet struct

+ func Run(ctx context.Context, plan Operator, cols []string) *ResultSet

+ func (rs *ResultSet) Close() error

+ func (rs *ResultSet) Columns() []string

+ func (rs *ResultSet) Err() error

+ func (rs *ResultSet) Next() bool

+ func (rs *ResultSet) Record() Record

+ func (rs *ResultSet) TakeRecord() Record

+ type RollUpApply struct

+ func NewRollUpApply(outer, inner Operator, arg *Argument, listEval func(Row) (expr.Value, error)) *RollUpApply

+ func (op *RollUpApply) Close() error

+ func (op *RollUpApply) Init(ctx context.Context) error

+ func (op *RollUpApply) Next(out *Row) (bool, error)

+ type Row []expr.Value

+ func Drain(ctx context.Context, op Operator) ([]Row, error)

+ type RowSlab struct

+ func NewRowSlab(width, capacity int) *RowSlab

+ func (s *RowSlab) Alloc() (Row, error)

+ func (s *RowSlab) AllocRaw() (int, error)

+ func (s *RowSlab) Cap() int

+ func (s *RowSlab) GetRow(idx int) Row

+ func (s *RowSlab) Len() int

+ func (s *RowSlab) Reset()

+ func (s *RowSlab) SetRow(idx int, r Row)

+ type SemiApply struct

+ func NewSemiApply(outer, inner Operator, arg *Argument) *SemiApply

+ func (op *SemiApply) Close() error

+ func (op *SemiApply) Init(ctx context.Context) error

+ func (op *SemiApply) Next(out *Row) (bool, error)

+ type SetAllProperties struct

+ func NewSetAllPropertiesFromEntity(entityVar, sourceVar string, isReplace bool, schema map[string]int, ...) *SetAllProperties

+ func NewSetAllPropertiesFromMap(entityVar, mapLiteral string, isReplace bool, schema map[string]int, ...) (*SetAllProperties, error)

+ func NewSetAllPropertiesFromParam(entityVar, paramName string, isReplace bool, schema map[string]int, ...) *SetAllProperties

+ func (op *SetAllProperties) Close() error

+ func (op *SetAllProperties) Init(ctx context.Context) error

+ func (op *SetAllProperties) Next(out *Row) (bool, error)

+ func (op *SetAllProperties) WithConstraints(reg *ConstraintRegistry, mgr *index.Manager) *SetAllProperties

+ func (op *SetAllProperties) WithParams(params map[string]expr.Value) (*SetAllProperties, error)

+ func (op *SetAllProperties) WithRelCols(rc RelCols) *SetAllProperties

+ func (op *SetAllProperties) WithSourceRelCols(rc RelCols) *SetAllProperties

+ type SetLabels struct

+ func NewSetLabels(nodeVar string, labels []string, schema map[string]int, child Operator, ...) *SetLabels

+ func (op *SetLabels) Close() error

+ func (op *SetLabels) Init(ctx context.Context) error

+ func (op *SetLabels) Next(out *Row) (bool, error)

+ type SetProperty struct

+ func NewSetProperty(entityVar, propertyKey, valueExpr string, schema map[string]int, ...) (*SetProperty, error)

+ func (op *SetProperty) Close() error

+ func (op *SetProperty) Init(ctx context.Context) error

+ func (op *SetProperty) Next(out *Row) (bool, error)

+ func (op *SetProperty) WithConstraints(reg *ConstraintRegistry, mgr *index.Manager) *SetProperty

+ func (op *SetProperty) WithParams(params map[string]expr.Value) *SetProperty

+ func (op *SetProperty) WithRelCols(rc RelCols) *SetProperty

+ func (op *SetProperty) WithValueEvalFn(fn ValueEvalFn) *SetProperty

+ type ShortestPath struct

+ func NewShortestPath(input Operator, fwd, rev csrAdjacency, dir Direction, srcCol, dstCol int) *ShortestPath

+ func (op *ShortestPath) Close() error

+ func (op *ShortestPath) Init(ctx context.Context) error

+ func (op *ShortestPath) Next(out *Row) (bool, error)

+ type SingleRow struct

+ func NewSingleRowOperator() *SingleRow

+ func (op *SingleRow) Close() error

+ func (op *SingleRow) Init(ctx context.Context) error

+ func (op *SingleRow) Next(out *Row) (bool, error)

+ type Skip struct

+ func NewSkip(child Operator, n int64) (*Skip, error)

+ func (op *Skip) Close() error

+ func (op *Skip) Init(ctx context.Context) error

+ func (op *Skip) Next(out *Row) (bool, error)

+ type SlabPool struct

+ func NewSlabPool(width, capacity int) *SlabPool

+ func (sp *SlabPool) Get() *RowSlab

+ func (sp *SlabPool) Put(s *RowSlab)

+ type Sort struct

+ func NewSort(child Operator, keys []SortKey, maxRows int) (*Sort, error)

+ func (op *Sort) Close() error

+ func (op *Sort) Init(ctx context.Context) error

+ func (op *Sort) Next(out *Row) (bool, error)

+ type SortKey struct

+ Ascending bool

+ ColIdx int

+ Eval func(Row) (expr.Value, error)

+ type StringHashIndex struct

+ func NewStringHashIndex(idx interface{ ... }) *StringHashIndex

+ func (h *StringHashIndex) LookupBitmap(value expr.Value) (*roaring64.Bitmap, error)

+ type StringRangeIndex struct

+ func NewStringRangeIndex(idx interface{ ... }) *StringRangeIndex

+ func (r *StringRangeIndex) RangeBitmap(lo, hi expr.Value) *roaring64.Bitmap

+ type TargetEvalFn func(row Row) (expr.Value, error)

+ type Top struct

+ func NewTop(child Operator, keys []SortKey, n int) (*Top, error)

+ func (op *Top) Close() error

+ func (op *Top) Init(ctx context.Context) error

+ func (op *Top) Next(out *Row) (bool, error)

+ type Union struct

+ func NewUnion(left, right Operator, maxDistinct int) *Union

+ func (op *Union) Close() error

+ func (op *Union) Init(ctx context.Context) error

+ func (op *Union) Next(out *Row) (bool, error)

+ type UnionAll struct

+ func NewUnionAll(left, right Operator) *UnionAll

+ func (op *UnionAll) Close() error

+ func (op *UnionAll) Init(ctx context.Context) error

+ func (op *UnionAll) Next(out *Row) (bool, error)

+ type Unwind struct

+ func NewUnwind(child Operator, listFn UnwindListFn) (*Unwind, error)

+ func (op *Unwind) Close() error

+ func (op *Unwind) Init(ctx context.Context) error

+ func (op *Unwind) Next(out *Row) (bool, error)

+ type UnwindListFn func(row Row) (expr.ListValue, error)

+ type ValueEvalFn func(row Row) (value lpg.PropertyValue, isNull bool, hasValue bool, err error)

+ type VarLengthConfig struct

+ Direction Direction

+ EdgeType string

+ EdgeTypeFilter map[uint64]string

+ ExcludedRelCols []int

+ InputCol int

+ MaxEdgesTraversed int

+ MaxHops int

+ MinHops int

+ type VarLengthExpand struct

+ func NewVarLengthExpand(input Operator, fwd, rev csrAdjacency, cfg *VarLengthConfig) *VarLengthExpand

+ func (op *VarLengthExpand) Close() error

+ func (op *VarLengthExpand) Init(ctx context.Context) error

+ func (op *VarLengthExpand) Next(out *Row) (bool, error)

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