QuerySystem

Instance Constructors

new QuerySystem(symbol: Map[String, String], partitionData: RDD[String], queryInputPath: String, queryResultPath: String, numOfFilesPartition: Int)

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[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
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[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
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
final def notifyAll(): Unit

Definition Classes
AnyRef
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(): Unit
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]
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( ... )
var workingPartialRDD: RDD[(String, List[String])]
var workingTripleRDD: RDD[(String, List[String])]

Related Doc: package semantic

class QuerySystem extends Serializable

Instance Constructors

new QuerySystem(symbol: Map[String, String], partitionData: RDD[String], queryInputPath: String, queryResultPath: String, numOfFilesPartition: Int)

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

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

def clone(): AnyRef

def displayMultiTriplesOutput(selectVariables: ArrayBuffer[String], qID: Int): Unit

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

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

final def getClass(): Class[_]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

def lineParser(lineParse: String): ArrayBuffer[String]

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

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(): Unit

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]

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

def toString(): String

var unionOutputRDD: RDD[String]

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

final def wait(): Unit

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

final def wait(arg0: Long): Unit

var workingPartialRDD: RDD[(String, List[String])]

var workingTripleRDD: RDD[(String, List[String])]

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped