TripleOps

Value Members

1. final def !=(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

4. def asHDT(triple: RDD[Triple]): DataFrame

   

   Function converts RDD[graph.Triple] to DataFrame [Subject,Object,Predicate] by extracting SOP value from each record

   Function converts RDD[graph.Triple] to DataFrame [Subject,Object,Predicate] by extracting SOP value from each record

   returns

   Returns DataFrame [Subject,Object,Predicate]

5. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

6. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

7. def dictionarySchema: StructType

   

   Function returns the Schema of Dictionary Dataframe.

   Function returns the Schema of Dictionary Dataframe.

   returns

   Schema of Dictionary

8. final def eq(arg0: AnyRef): Boolean

   

   Definition Classes

   AnyRef

9. def equals(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

10. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

11. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

12. def getDistinctObjectDictDF(triples: RDD[Triple]): DataFrame

    

    Return Dataframe of Index + Object by retrieving the unique objects from RDD[Triple] and zip it with undex

    Return Dataframe of Index + Object by retrieving the unique objects from RDD[Triple] and zip it with undex

    triples

    RDD[Triple] conversion of input file

    returns

    DataFrame Object dictionary of [index , object]

13. def getDistinctPredicateDictDF(triples: RDD[Triple]): DataFrame

    

    Return Dataframe of Index + Predicate by retrieving the unique predicate from RDD[Triple] and zip it with undex

    Return Dataframe of Index + Predicate by retrieving the unique predicate from RDD[Triple] and zip it with undex

    triples

    RDD[Triple] conversion of input file

    returns

    DataFrame Predicate dictionary of [index,Prediate]

14. def getDistinctSubjectDictDF(triples: RDD[Triple]): DataFrame

    

    Return Dataframe of Index + Subject by retrieving the unique subjects from RDD[Triple] and zip it with undex

    Return Dataframe of Index + Subject by retrieving the unique subjects from RDD[Triple] and zip it with undex

    triples

    RDD[Triple] conversion of input file

    returns

    DataFrame Subject dictionary of [index,subject]

15. def getHDT(triples: RDD[Triple]): DataFrame

    

    This is key function of TripleOps that read RDF file and create Dictionaries and Index Table and register them as Spark In memory Table

    This is key function of TripleOps that read RDF file and create Dictionaries and Index Table and register them as Spark In memory Table

    returns

    Returns the Tuple4 [IndexDataFrame,SubjectDictDataFrame,ObjectDictDataFrame,PredicateDictDataFrame]

16. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

17. def hdtSchema: StructType

    

    Function returns the Schema of Indexed Triple Fact table.

    Function returns the Schema of Indexed Triple Fact table.

    returns

    StructType

18. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

19. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

20. final def notify(): Unit

    

    Definition Classes

    AnyRef

21. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

22. def readHDTFromDisk(input: String): (DataFrame, DataFrame, DataFrame, DataFrame)

    

    Read hdt data from disk.

    Read hdt data from disk.

    input

    -- path to hdt data.

23. def saveAsCSV(hdt: DataFrame, subjectDF: DataFrame, predicateDF: DataFrame, objectDF: DataFrame, output: String, mode: SaveMode): Unit

    

    Function saves the Index and Dictionaries Dataframe into given location

    Function saves the Index and Dictionaries Dataframe into given location

    output

    Path to be written

    mode

    SaveMode of Write

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

    

    Definition Classes

    AnyRef

25. def toString(): String

    

    Definition Classes

    AnyRef → Any

26. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

28. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )