class RDDTensor extends Tensor[RDD[Triple], String, RDD[Seq[Long]], ResultRDD[String]]
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- RDDTensor
- Tensor
- TensorApi
- Serializable
- 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 buildSPO: SPO[Node]
- def buildTensor: RDD[Seq[Long]]
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- def compareResult(result: Result[ResultRDD[String]], expected: RDD[String], resultVars: List[Var]): Boolean
-
def
data: RDD[Triple]
- Definition Classes
- Tensor
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
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 getEmptyRDD: RDD[String]
- def getSpoField(method: String): NodeIndexed[Node]
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isRDDEquals(expected: RDD[String], result: RDD[String]): Boolean
- Definition Classes
- Tensor
- def mapTensorIndexesToNodes(triple: Triple, tensor: RDD[Seq[Long]]): RDD[VarNodeMap[String]]
- def mapWithKeys(result: Result[ResultRDD[String]], keys: List[Var]): RDD[(List[String], VarNodeMap[String])]
-
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 output(result: Result[ResultRDD[String]], resultVars: List[Var]): Array[String]
- def process(triple: Triple, mapV: VariableMap[String]): RDD[VarNodeMap[String]]
- def readData: RDD[Triple]
- def saveResult(result: Result[ResultRDD[String]], current: Result[ResultRDD[String]]): Result[ResultRDD[String]]
- def saveResult(triple: Triple, result: Result[ResultRDD[String]], current: ResultRDD[String]): Result[ResultRDD[String]]
-
def
sparkContext: SparkSession
- Definition Classes
- Tensor
-
def
spo: SPO[Node]
- Definition Classes
- Tensor
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
tensor: RDD[Seq[Long]]
- Definition Classes
- Tensor
-
def
toString(): String
- Definition Classes
- AnyRef → Any
- def transform(result: Result[ResultRDD[String]], keysI: List[Var], keysU: List[Var]): RDD[(List[String], List[String])]
- def transform(tensor: RDD[Seq[Long]], index: Int): RDD[(Long, Seq[Long])]
- def traverse(triple: Triple, mapV: VariableMap[String]): RDD[Seq[Long]]
- def unionResult(result: Result[ResultRDD[String]], current: Result[ResultRDD[String]]): Result[ResultRDD[String]]
- def updateMapV(triple: Triple, mapV: VariableMap[String], tensor: RDD[Seq[Long]]): Unit
-
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()