exec

package

Go to main page

Versions in this module

v0

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