CAPSSession

Type Members

abstract type Graph <: RelationalCypherGraph[DataFrameTable]

Definition Classes
RelationalCypherSession
abstract type Result <: CypherResult

Definition Classes
CypherSession

Abstract Value Members

abstract def cypher(query: String, parameters: CypherMap, drivingTable: Option[CypherRecords]): Result

Definition Classes
CypherSession
abstract def sparkSession: SparkSession
abstract def sql(query: String): CypherRecords

Concrete 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
implicit val caps: CAPSSession

Attributes
protected
lazy val catalog: CypherCatalog

Definition Classes
CAPSSession → CypherSession
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
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] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
val graphs: CAPSGraphFactory

Definition Classes
CAPSSession → RelationalCypherSession
def hashCode(): Int

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def readFrom(tags: Set[Int], nodeTable: CAPSNodeTable, entityTables: CAPSEntityTable*): PropertyGraph

Reads a graph from a sequence of entity tables that contains at least one node table.
Reads a graph from a sequence of entity tables that contains at least one node table.
tags
tags that are used by graph entities
nodeTable
first parameter to guarantee there is at least one node table
entityTables
sequence of node and relationship tables defining the graph
returns
property graph
def readFrom(nodeTable: CAPSNodeTable, entityTables: CAPSEntityTable*): PropertyGraph

Reads a graph from a sequence of entity tables that contains at least one node table.
Reads a graph from a sequence of entity tables that contains at least one node table.
nodeTable
first parameter to guarantee there is at least one node table
entityTables
sequence of node and relationship tables defining the graph
returns
property graph
def readFrom[N <: Node, R <: Relationship](nodes: Seq[N], relationships: Seq[R] = Seq.empty)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[N], arg1: scala.reflect.api.JavaUniverse.TypeTag[R]): PropertyGraph

Reads a graph from sequences of nodes and relationships.
Reads a graph from sequences of nodes and relationships.
N
node type implementing org.opencypher.spark.api.io.Node
R
relationship type implementing org.opencypher.spark.api.io.Relationship
nodes
sequence of nodes
relationships
sequence of relationships
returns
graph defined by the sequences
val records: CAPSRecordsFactory

Definition Classes
CAPSSession → RelationalCypherSession
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
AnyRef → Any
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Docs: object CAPSSession | package api

trait CAPSSession extends RelationalCypherSession[DataFrameTable]

Type Members

abstract type Graph <: RelationalCypherGraph[DataFrameTable]

abstract type Result <: CypherResult

Abstract Value Members

abstract def cypher(query: String, parameters: CypherMap, drivingTable: Option[CypherRecords]): Result

abstract def sparkSession: SparkSession

abstract def sql(query: String): CypherRecords

Concrete Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

implicit val caps: CAPSSession

lazy val catalog: CypherCatalog

def clone(): AnyRef

def deregisterSource(namespace: Namespace): Unit

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

val graphs: CAPSGraphFactory

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def readFrom(tags: Set[Int], nodeTable: CAPSNodeTable, entityTables: CAPSEntityTable*): PropertyGraph

def readFrom(nodeTable: CAPSNodeTable, entityTables: CAPSEntityTable*): PropertyGraph

def readFrom[N <: Node, R <: Relationship](nodes: Seq[N], relationships: Seq[R] = Seq.empty)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[N], arg1: scala.reflect.api.JavaUniverse.TypeTag[R]): PropertyGraph

val records: CAPSRecordsFactory

def registerSource(namespace: Namespace, dataSource: PropertyGraphDataSource): Unit

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

final def wait(): Unit

Inherited from RelationalCypherSession[DataFrameTable]

Inherited from CypherSession

Inherited from AnyRef

Inherited from Any

Ungrouped