Versions in this module Expand all Collapse all v0 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 NewCorrelatedApply(outer, inner Operator, arg *Argument) *CorrelatedApply + 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)
Go to main page