TripleReader

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def execute(): Unit

def expandNodesNLevel(nodes: VertexRDD[Node], graph: Graph[Node, Node], levels: Int = 1): Dataset[Row]

Returns a dataset of rows expanded by the number of levels given

def finalize(): Unit

final def getClass(): Class[_]

def getSubjectsWithProperty(graph: Graph[Node, Node], property: String): VertexRDD[Node]

Returns a VertexRDD of Nodes linked by the given property

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

def loadGraph(session: SparkSession, path: String): Graph[Node, Node]

Main method for load the graph from a path

def loadObjects(session: SparkSession, path: String): RDD[Node]

Returns all the distinct objects in the file (but not the subjects or predicates)

def loadPredicates(session: SparkSession, path: String): RDD[Node]

Returns all the distinct predicates in the file

def loadSubjects(session: SparkSession, path: String): RDD[Node]

Returns all the subjects in the file (but not the objects or predicates)

def loadTriplets(sparkSession: SparkSession, path: String): RDD[Triple]

Load the triplets initially

val log: Logger

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

val processSparkSession: SparkSession

def showTripletsRDD(tripletsRDD: RDD[Triple]): Unit

Prints the current RDD of Triples Warning: this method needs to collect the RDD

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

def toString(): String

final def wait(): Unit

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

final def wait(arg0: Long): Unit

def Dep_getSubjectsWithProperty(graph: Graph[Node, Node], property: String): VertexRDD[Node]

def expandNodes(nodes: VertexRDD[Node], graph: Graph[Node, Node]): VertexRDD[Node]