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, queryResultPath: String, numOfFilesPartition: Int)

    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. def queryEngine(qID: Int): Unit

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

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

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

    Permalink
  36. def run(): Unit

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

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

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

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

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

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

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

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

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

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

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

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

    Permalink
  49. final def wait(): Unit

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

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

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

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

    Permalink

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped