abstract class RelationalCypherSession[T <: Table[T]] extends CypherSession
Base class for relational back ends implementing the OKAPI pipeline.
The class provides a generic implementation of the necessary steps to execute a Cypher query on a relational back end including parsing, IR planning, logical planning and relational planning.
Implementers need to make sure to provide factories for back end specific record and graph implementations.
- T
back end specific Table implementation
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- RelationalCypherSession
- CypherSession
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new RelationalCypherSession()(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[T])
Type Members
-
abstract
type
Records <: RelationalCypherRecords[T]
Back end specific records type
-
type
Result = RelationalCypherResult[T]
- Definition Classes
- RelationalCypherSession → CypherSession
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
lazy val
catalog: CypherCatalog
- Definition Classes
- RelationalCypherSession → CypherSession
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
cypher(query: String, parameters: CypherMap = CypherMap.empty, drivingTable: Option[CypherRecords] = None, queryCatalog: Map[QualifiedGraphName, PropertyGraph] = Map.empty): Result
- Definition Classes
- RelationalCypherSession → CypherSession
-
def
deregisterSource(namespace: Namespace): Unit
- Definition Classes
- CypherSession
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
generateQualifiedGraphName: QualifiedGraphName
- Definition Classes
- CypherSession
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
logStageProgress(s: String, newLine: Boolean = true): Unit
- Attributes
- protected
-
val
logicalOptimizer: LogicalOptimizer.type
- Attributes
- protected
-
val
logicalPlanner: LogicalPlanner
- Attributes
- protected
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
val
parser: CypherParser
- Attributes
- protected
-
def
planCypherQuery(graph: PropertyGraph, cypherQuery: CypherQuery, allParameters: CypherMap, inputFields: Set[Var], maybeDrivingTable: Option[RelationalCypherRecords[T]], queryLocalCatalog: QueryLocalCatalog): Result
- Attributes
- protected
-
def
planLogical(ir: CypherQuery, graph: PropertyGraph, inputFields: Set[Var], queryLocalCatalog: QueryLocalCatalog): LogicalOperator
- Attributes
- protected
-
def
planRelational(maybeDrivingTable: Option[RelationalCypherRecords[T]], parameters: CypherMap, logicalPlan: LogicalOperator, queryLocalCatalog: QueryLocalCatalog): Result
- Attributes
- protected
-
def
readFrom(nodeTable: ElementTable[T], elementTables: ElementTable[T]*): RelationalCypherGraph[T]
Reads a graph from a sequence of element tables that contains at least one node table.
Reads a graph from a sequence of element tables that contains at least one node table.
- nodeTable
first parameter to guarantee there is at least one node table
- elementTables
sequence of node and relationship tables defining the graph
- returns
property graph
-
def
registerSource(namespace: Namespace, dataSource: PropertyGraphDataSource): Unit
- Definition Classes
- CypherSession
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- CypherSession → AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )