class QuerySystem extends Serializable
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- QuerySystem
- Serializable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new QuerySystem(partitionData: RDD[String], queryInputPath: String)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- var _WhereTriples: Map[Int, ArrayBuffer[String]]
- var _filterOp: Map[Int, String]
- var _numOfWhereClauseTriples: Map[Int, Int]
- var _queriesLimit: Map[Int, Int]
- var _queriesProcessTime: ArrayBuffer[Long]
- var _selectVariables: Map[Int, ArrayBuffer[String]]
- var _unionOp: Map[Int, Map[String, Boolean]]
- var _whereVariables: Map[Int, ArrayBuffer[String]]
- def applyFilter(filterLine: String, processLine: String): (Boolean, Int)
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- def displayMultiTriplesOutput(selectVariables: ArrayBuffer[String], qID: Int): Unit
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def fetchQueries: ArrayBuffer[ArrayBuffer[String]]
- def fetchVarJoinList(qID: Int, clauseNum: Int): ArrayBuffer[String]
- def fetchWhereTriples(whereLines: ArrayBuffer[String], whereVariables: ArrayBuffer[String]): ArrayBuffer[String]
- def fetchWhereVariables(linesParse: ArrayBuffer[String]): ArrayBuffer[String]
- def filterComparison(a: String, b: String, operator: String): Boolean
- def filterFunctions(fName: String, filterFunction: String, processLine: String): Boolean
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def lineParser(lineParse: String): ArrayBuffer[String]
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- var outputRDD: RDD[String]
- def queryEngine(qID: Int): Unit
- def queryParser(query: ArrayBuffer[String], qID: Int): Unit
- def refactorUnionQueries(query: ArrayBuffer[String], qID: Int): ArrayBuffer[ArrayBuffer[String]]
- def removeDuplicates(list: ArrayBuffer[String]): ArrayBuffer[String]
- def run(): RDD[String]
- def runAllTriplesOfQuery(qID: Int): Unit
- def runFirstTriple(qID: Int, clauseNum: Int = 0, isRemainingTriples: Boolean = false, varJoinList: ArrayBuffer[String] = null): Unit
- def runRemainingTriples(qID: Int, clauseNum: Int, varJoinList: ArrayBuffer[String]): Unit
- def setFirstTripleOutput(tripleSubject: String, tripleObject: String, lineSubject: String, lineObject: String): String
- def setOnlyTripleOutput(qID: Int, tripleSubject: String, tripleObject: String, lineSubject: String, lineObject: String): String
- def setRemainingPartialOutput(varJoinList: ArrayBuffer[String]): Unit
- def setRemainingTriplesOutput(tripleSubject: String, tripleObject: String, lineSubject: String, lineObject: String, varJoinList: ArrayBuffer[String]): ArrayListMultimap[String, String]
- val symbol: Map[String, String]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
- var unionOutputRDD: RDD[String]
- def validateVariables(variables: ArrayBuffer[String], whereVariables: ArrayBuffer[String], qID: Int, validateType: String = "SELECT"): Unit
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- var workingPartialRDD: RDD[(String, List[String])]
- var workingTripleRDD: RDD[(String, List[String])]