object SparkExecutionModel
Model that contains methods for query operations on top of spark.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- SparkExecutionModel
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
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
- def basicGraphPatternMatch(bgp: BasicGraphPattern): RDD[Result[Node]]
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- def createSparkSession(session: SparkSession): Unit
- def createSparkSession(): Unit
- def distinct(result: RDD[Result[Node]]): RDD[Result[Node]]
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def extend(result: RDD[Result[Node]], sub: Node, expr: Node): RDD[Result[Node]]
- def filter(result: RDD[Result[Node]], filters: List[Expression]): RDD[Result[Node]]
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getGraph: Graph[Node, Node]
- def getSession: SparkSession
- def group(result: RDD[Result[Node]], vars: List[Node], aggregates: List[ExprAggregator]): RDD[Result[Node]]
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def leftJoin(left: RDD[Result[Node]], right: RDD[Result[Node]]): RDD[Result[Node]]
- def loadGraph(graph: Graph[Node, Node]): Unit
- def loadGraph(path: String, lang: Lang): Unit
- def loadGraph(): Unit
- def minus(left: RDD[Result[Node]], right: RDD[Result[Node]]): RDD[Result[Node]]
-
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()
- def project(result: RDD[Result[Node]], varSet: Set[Node]): RDD[Result[Node]]
- def setSparkSession(spark: SparkSession): Unit
- def slice(result: RDD[Result[Node]], limit: Int, offset: Int): RDD[Result[Node]]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
- def union(left: RDD[Result[Node]], right: RDD[Result[Node]]): RDD[Result[Node]]
-
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
- @throws( ... ) @native()