SchemaCompletenessMeasurement

abstract def execute(): Unit

abstract val processSparkSession: SparkSession

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 expandNodesNLevel(nodes: VertexRDD[Node], graph: Graph[Node, Node], levels: Int): Dataset[Row]

def finalize(): Unit

final def getClass(): Class[_]

def getMeasurementGlobal(graph: Graph[Node, Node], properties: Seq[String]): Dataset[Row]

Returns the result for SchemaCompleteness Measurement for all the graph, globally

def getMeasurementSubgraph(subjects: VertexRDD[Node], graph: Graph[Node, Node], properties: Seq[String]): Dataset[Row]

Returns the result particularized for each subject in the subset of the graph

def getMeasurementSubject(subjectId: VertexId, graph: Graph[Node, Node], properties: Seq[String]): Boolean

Returns the result particularized for the subject

def getRatio: UserDefinedFunction

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

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

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

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

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

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

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

val log: Logger

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

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

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]