Class

net.sansa_stack.query.spark.semantic

QuerySystem

Related Doc: package semantic

Permalink

class QuerySystem extends Serializable

Linear Supertypes
Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. QuerySystem
  2. Serializable
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new QuerySystem(partitionData: RDD[String], queryInputPath: String)

    Permalink

Value Members

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

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. var _WhereTriples: Map[Int, ArrayBuffer[String]]

    Permalink
  5. var _filterOp: Map[Int, String]

    Permalink
  6. var _numOfWhereClauseTriples: Map[Int, Int]

    Permalink
  7. var _queriesLimit: Map[Int, Int]

    Permalink
  8. var _queriesProcessTime: ArrayBuffer[Long]

    Permalink
  9. var _selectVariables: Map[Int, ArrayBuffer[String]]

    Permalink
  10. var _unionOp: Map[Int, Map[String, Boolean]]

    Permalink
  11. var _whereVariables: Map[Int, ArrayBuffer[String]]

    Permalink
  12. def applyFilter(filterLine: String, processLine: String): (Boolean, Int)

    Permalink
  13. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  14. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  15. def displayMultiTriplesOutput(selectVariables: ArrayBuffer[String], qID: Int): Unit

    Permalink
  16. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  17. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  18. def fetchQueries: ArrayBuffer[ArrayBuffer[String]]

    Permalink
  19. def fetchVarJoinList(qID: Int, clauseNum: Int): ArrayBuffer[String]

    Permalink
  20. def fetchWhereTriples(whereLines: ArrayBuffer[String], whereVariables: ArrayBuffer[String]): ArrayBuffer[String]

    Permalink
  21. def fetchWhereVariables(linesParse: ArrayBuffer[String]): ArrayBuffer[String]

    Permalink
  22. def filterComparison(a: String, b: String, operator: String): Boolean

    Permalink
  23. def filterFunctions(fName: String, filterFunction: String, processLine: String): Boolean

    Permalink
  24. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  25. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  26. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  27. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  28. def lineParser(lineParse: String): ArrayBuffer[String]

    Permalink
  29. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  30. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  31. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  32. var outputRDD: RDD[String]

    Permalink
  33. def queryEngine(qID: Int): Unit

    Permalink
  34. def queryParser(query: ArrayBuffer[String], qID: Int): Unit

    Permalink
  35. def refactorUnionQueries(query: ArrayBuffer[String], qID: Int): ArrayBuffer[ArrayBuffer[String]]

    Permalink
  36. def removeDuplicates(list: ArrayBuffer[String]): ArrayBuffer[String]

    Permalink
  37. def run(): RDD[String]

    Permalink
  38. def runAllTriplesOfQuery(qID: Int): Unit

    Permalink
  39. def runFirstTriple(qID: Int, clauseNum: Int = 0, isRemainingTriples: Boolean = false, varJoinList: ArrayBuffer[String] = null): Unit

    Permalink
  40. def runRemainingTriples(qID: Int, clauseNum: Int, varJoinList: ArrayBuffer[String]): Unit

    Permalink
  41. def setFirstTripleOutput(tripleSubject: String, tripleObject: String, lineSubject: String, lineObject: String): String

    Permalink
  42. def setOnlyTripleOutput(qID: Int, tripleSubject: String, tripleObject: String, lineSubject: String, lineObject: String): String

    Permalink
  43. def setRemainingPartialOutput(varJoinList: ArrayBuffer[String]): Unit

    Permalink
  44. def setRemainingTriplesOutput(tripleSubject: String, tripleObject: String, lineSubject: String, lineObject: String, varJoinList: ArrayBuffer[String]): ArrayListMultimap[String, String]

    Permalink
  45. val symbol: Map[String, String]

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

    Permalink
    Definition Classes
    AnyRef
  47. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  48. var unionOutputRDD: RDD[String]

    Permalink
  49. def validateVariables(variables: ArrayBuffer[String], whereVariables: ArrayBuffer[String], qID: Int, validateType: String = "SELECT"): Unit

    Permalink
  50. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  51. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  52. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  53. var workingPartialRDD: RDD[(String, List[String])]

    Permalink
  54. var workingTripleRDD: RDD[(String, List[String])]

    Permalink

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped