operators

Type Members

1. final case class Aggregate(in: CAPSPhysicalOperator, aggregations: Set[(Var, Aggregator)], group: Set[Var], header: RecordHeader) extends UnaryPhysicalOperator with Product with Serializable

   

2. final case class Alias(in: CAPSPhysicalOperator, aliases: Seq[(Expr, Var)], header: RecordHeader) extends UnaryPhysicalOperator with Product with Serializable

   

3. final case class BoundedVarExpand(first: CAPSPhysicalOperator, second: CAPSPhysicalOperator, third: CAPSPhysicalOperator, rel: Var, edgeList: Var, target: Var, initialEndNode: Var, lower: Int, upper: Int, direction: Direction, header: RecordHeader, isExpandInto: Boolean) extends TernaryPhysicalOperator with Product with Serializable

   

4. final case class Cache(in: CAPSPhysicalOperator) extends UnaryPhysicalOperator with InheritedHeader with Product with Serializable

   

5. final case class CartesianProduct(lhs: CAPSPhysicalOperator, rhs: CAPSPhysicalOperator, header: RecordHeader) extends BinaryPhysicalOperator with Product with Serializable

   

6. final case class ConstructGraph(lhs: CAPSPhysicalOperator, rhs: CAPSPhysicalOperator, construct: LogicalPatternGraph) extends BinaryPhysicalOperator with Product with Serializable

   
   lhs

   table with aliases and data for new entities

   rhs

   graph on which we construct the new graph

7. final case class Distinct(in: CAPSPhysicalOperator, fields: Set[Var]) extends UnaryPhysicalOperator with InheritedHeader with Product with Serializable

   

8. final case class Drop(in: CAPSPhysicalOperator, dropFields: Seq[Expr], header: RecordHeader) extends UnaryPhysicalOperator with Product with Serializable

   

9. final case class EmptyRecords(in: CAPSPhysicalOperator, header: RecordHeader)(implicit caps: CAPSSession) extends UnaryPhysicalOperator with Product with Serializable

   

10. final case class ExistsSubQuery(lhs: CAPSPhysicalOperator, rhs: CAPSPhysicalOperator, targetField: Var, header: RecordHeader) extends BinaryPhysicalOperator with Product with Serializable

    

    This operator performs a left outer join between the already matched path and the pattern path.

    This operator performs a left outer join between the already matched path and the pattern path. If, for a given, already bound match, there is a non-null partner, we set a target column to true, otherwise false. Only the mandatory match data and the target column are kept in the result.

    lhs

    mandatory match data

    rhs

    expanded pattern predicate data

    targetField

    field that will store the subquery value (exists true/false)

    header

    result header (lhs header + predicateField)

11. final case class Filter(in: CAPSPhysicalOperator, expr: Expr, header: RecordHeader) extends UnaryPhysicalOperator with Product with Serializable

    

12. final case class FromGraph(in: CAPSPhysicalOperator, graph: LogicalCatalogGraph) extends UnaryPhysicalOperator with InheritedHeader with Product with Serializable

    

13. final case class GraphUnionAll(inputs: List[CAPSPhysicalOperator], qgn: QualifiedGraphName) extends CAPSPhysicalOperator with InheritedHeader with Product with Serializable

    

14. trait InheritedHeader extends AnyRef

    

15. final case class InitVarExpand(in: CAPSPhysicalOperator, source: Var, edgeList: Var, target: Var, header: RecordHeader) extends UnaryPhysicalOperator with Product with Serializable

    

16. final case class Join(lhs: CAPSPhysicalOperator, rhs: CAPSPhysicalOperator, joinColumns: Seq[(Expr, Expr)], header: RecordHeader, joinType: String) extends BinaryPhysicalOperator with Product with Serializable

    

17. final case class Limit(in: CAPSPhysicalOperator, expr: Expr, header: RecordHeader) extends UnaryPhysicalOperator with Product with Serializable

    

18. final case class NodeScan(in: CAPSPhysicalOperator, v: Var, header: RecordHeader) extends UnaryPhysicalOperator with Product with Serializable

    

19. final case class OrderBy(in: CAPSPhysicalOperator, sortItems: Seq[SortItem[Expr]]) extends UnaryPhysicalOperator with InheritedHeader with Product with Serializable

    

20. final case class Project(in: CAPSPhysicalOperator, expr: Expr, header: RecordHeader) extends UnaryPhysicalOperator with Product with Serializable

    

21. final case class RelationshipScan(in: CAPSPhysicalOperator, v: Var, header: RecordHeader) extends UnaryPhysicalOperator with Product with Serializable

    

22. final case class RemoveAliases(in: CAPSPhysicalOperator, dependentFields: Set[(ProjectedField, ProjectedExpr)], header: RecordHeader) extends UnaryPhysicalOperator with Product with Serializable

    

23. final case class ReturnGraph(in: CAPSPhysicalOperator) extends UnaryPhysicalOperator with Product with Serializable

    

24. final case class SelectFields(in: CAPSPhysicalOperator, fields: List[Var], header: RecordHeader) extends UnaryPhysicalOperator with Product with Serializable

    

25. final case class SimpleDistinct(in: CAPSPhysicalOperator) extends UnaryPhysicalOperator with InheritedHeader with Product with Serializable

    

26. final case class Skip(in: CAPSPhysicalOperator, expr: Expr, header: RecordHeader) extends UnaryPhysicalOperator with Product with Serializable

    

27. final case class Start(qgn: QualifiedGraphName, recordsOpt: Option[CAPSRecords])(implicit caps: CAPSSession) extends LeafPhysicalOperator with Product with Serializable

    

28. final case class TabularUnionAll(lhs: CAPSPhysicalOperator, rhs: CAPSPhysicalOperator) extends BinaryPhysicalOperator with InheritedHeader with Product with Serializable

    

    Computes the union of the two input operators.

    Computes the union of the two input operators. The two inputs must have identical headers. This operation does not remove duplicates.

    The output header of this operation is identical to the input headers.

    lhs

    the first operand

    rhs

    the second operand