Skip navigation links
A B C D E F G I J K L M N O P R S T W 

A

aggregate(Tree, Tree, Tree, Environment) - Method in class org.apache.mrql.MapReduceEvaluator
The Aggregate physical operator
aggregate(Tree, Tree, DataSet) - Static method in class org.apache.mrql.MapReducePlan
The Aggregate physical operator

B

binaryInputFormat() - Method in class org.apache.mrql.MapReduceEvaluator
return the FileInputFormat for binary files

C

clear_configuration(Configuration) - Static method in class org.apache.mrql.MapReduceEvaluator
 
close() - Method in class org.apache.mrql.MapReduceGeneratorInputFormat.GeneratorRecordReader
 
close() - Method in class org.apache.mrql.MapReduceParsedInputFormat.ParsedRecordReader
 
closure(Function, DataSet, int) - Static method in class org.apache.mrql.MapReducePlan
The closure physical operator.
cMap(Tree, Tree, Tree, DataSet, String) - Static method in class org.apache.mrql.MapOperation
The cMap physical operator
collect(DataSet, boolean) - Method in class org.apache.mrql.MapReduceMRQLFileInputFormat
materialize the entire dataset into a Bag
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.mrql.JoinOperation.MRContainerGroupingComparator
 
compare(JoinOperation.JoinKey, JoinOperation.JoinKey) - Method in class org.apache.mrql.JoinOperation.MRContainerGroupingComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.mrql.JoinOperation.MRContainerSortComparator
 
compare(JoinOperation.JoinKey, JoinOperation.JoinKey) - Method in class org.apache.mrql.JoinOperation.MRContainerSortComparator
 
container_size - Variable in class org.apache.mrql.JoinOperation.MRContainerGroupingComparator
 
container_size - Variable in class org.apache.mrql.JoinOperation.MRContainerSortComparator
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.mrql.MapReduceBinaryInputFormat
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.mrql.MapReduceGeneratorInputFormat
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.mrql.MapReduceMRQLFileInputFormat
record reader for map-reduce
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.mrql.MapReduceParsedInputFormat
 
crossProduct(Tree, Tree, Tree, Tree, Tree, DataSet, DataSet, String) - Static method in class org.apache.mrql.CrossProductOperation
The CrossProduct physical operator (similar to block-nested loop)
CrossProductOperation - Class in org.apache.mrql
The CrossProduct physical operation (similar to block-nested loop)
CrossProductOperation() - Constructor for class org.apache.mrql.CrossProductOperation
 

D

data - Variable in class org.apache.mrql.MapReduceParsedInputFormat.ParsedRecordReader
 

E

end - Variable in class org.apache.mrql.MapReduceParsedInputFormat.ParsedRecordReader
 
eval(Tree, Environment, String) - Method in class org.apache.mrql.MapReduceEvaluator
Evaluate an MRQL physical plan using Hadoop and print tracing info
evalD(Tree, Environment, String) - Method in class org.apache.mrql.MapReduceEvaluator
Evaluate MRQL physical operators using Hadoop

F

fsin - Variable in class org.apache.mrql.MapReduceParsedInputFormat.ParsedRecordReader
 

G

generatorInputFormat() - Method in class org.apache.mrql.MapReduceEvaluator
return the FileInputFormat for data generator files
GeneratorRecordReader(FileSplit, TaskAttemptContext) - Constructor for class org.apache.mrql.MapReduceGeneratorInputFormat.GeneratorRecordReader
 
getCurrentKey() - Method in class org.apache.mrql.MapReduceGeneratorInputFormat.GeneratorRecordReader
 
getCurrentKey() - Method in class org.apache.mrql.MapReduceParsedInputFormat.ParsedRecordReader
 
getCurrentValue() - Method in class org.apache.mrql.MapReduceGeneratorInputFormat.GeneratorRecordReader
 
getCurrentValue() - Method in class org.apache.mrql.MapReduceParsedInputFormat.ParsedRecordReader
 
getPartition(JoinOperation.JoinKey, MRContainer, int) - Method in class org.apache.mrql.JoinOperation.MRContainerJoinPartitioner
 
getPartition(MRContainer, MRContainer, int) - Method in class org.apache.mrql.MapReduceOperation.MRContainerPartitioner
 
getPos() - Method in class org.apache.mrql.MapReduceParsedInputFormat.ParsedRecordReader
 
getProgress() - Method in class org.apache.mrql.MapReduceGeneratorInputFormat.GeneratorRecordReader
 
getProgress() - Method in class org.apache.mrql.MapReduceParsedInputFormat.ParsedRecordReader
 
groupByJoin(Tree, Tree, Tree, Tree, Tree, Tree, Tree, DataSet, DataSet, int, int, int, String) - Static method in class org.apache.mrql.GroupByJoinPlan
the GroupByJoin operation: an equi-join combined with a group-by implemented using hashing
GroupByJoinPlan - Class in org.apache.mrql
A map-reduce job that captures a join with group-by.
GroupByJoinPlan() - Constructor for class org.apache.mrql.GroupByJoinPlan
 

I

index - Variable in class org.apache.mrql.MapReduceGeneratorInputFormat.GeneratorRecordReader
 
init(Configuration) - Method in class org.apache.mrql.MapReduceEvaluator
initialize the MapReduce evaluator
initialize(InputSplit, TaskAttemptContext) - Method in class org.apache.mrql.MapReduceGeneratorInputFormat.GeneratorRecordReader
 
initialize(InputSplit, TaskAttemptContext) - Method in class org.apache.mrql.MapReduceParsedInputFormat.ParsedRecordReader
 
initialize_query() - Method in class org.apache.mrql.MapReduceEvaluator
initialize the query evaluation
inputFormat - Static variable in class org.apache.mrql.MapReduceBinaryInputFormat
 

J

JoinKey() - Constructor for class org.apache.mrql.JoinOperation.JoinKey
 
JoinKey(byte, MRData) - Constructor for class org.apache.mrql.JoinOperation.JoinKey
 
JoinOperation - Class in org.apache.mrql
The MapReduce2 physical operator (a reduce-side join)
JoinOperation() - Constructor for class org.apache.mrql.JoinOperation
 
JoinOperation.JoinKey - Class in org.apache.mrql
Container for join input values.
JoinOperation.MRContainerGroupingComparator - Class in org.apache.mrql
The grouping of the joined values is based on join key only
JoinOperation.MRContainerJoinPartitioner - Class in org.apache.mrql
 
JoinOperation.MRContainerSortComparator - Class in org.apache.mrql
The sorting of the joined values uses ths join key for major order and tag for minor order

K

key - Variable in class org.apache.mrql.JoinOperation.JoinKey
 

L

loop(Tree, Environment) - Method in class org.apache.mrql.MapReduceEvaluator
Evaluate a loop a fixed # of times

M

mapJoin(Tree, Tree, Tree, Tree, Tree, DataSet, DataSet, String) - Static method in class org.apache.mrql.MapJoinOperation
The fragment-replicate join (map-side join) physical operator
MapJoinOperation - Class in org.apache.mrql
The fragment-replicate join (map-side join) physical operator
MapJoinOperation() - Constructor for class org.apache.mrql.MapJoinOperation
 
MapOperation - Class in org.apache.mrql
The MapReduce operation that use a map stage only
MapOperation() - Constructor for class org.apache.mrql.MapOperation
 
mapReduce(Tree, Tree, Tree, Tree, Tree, DataSet, int, String, boolean) - Static method in class org.apache.mrql.MapReduceOperation
The MapReduce physical operator
mapReduce2(Tree, Tree, Tree, Tree, Tree, Tree, DataSet, DataSet, int, String, boolean) - Static method in class org.apache.mrql.JoinOperation
The MapReduce2 physical operator (a reduce-side join)
MapReduceBinaryInputFormat - Class in org.apache.mrql
Input format for Apache Hadoop sequence files
MapReduceBinaryInputFormat() - Constructor for class org.apache.mrql.MapReduceBinaryInputFormat
 
MapReduceEvaluator - Class in org.apache.mrql
Evaluates physical plans in Apache Hadoop MapReduce mode
MapReduceEvaluator() - Constructor for class org.apache.mrql.MapReduceEvaluator
 
MapReduceGeneratorInputFormat - Class in org.apache.mrql
the FileInputFormat for data generators: it creates HDFS files, where each file contains an (offset,size) pair that generates the range of values [offset,offset+size]
MapReduceGeneratorInputFormat() - Constructor for class org.apache.mrql.MapReduceGeneratorInputFormat
 
MapReduceGeneratorInputFormat.GeneratorRecordReader - Class in org.apache.mrql
 
MapReduceMRQLFileInputFormat - Class in org.apache.mrql
A superclass for all MRQL FileInputFormats
MapReduceMRQLFileInputFormat() - Constructor for class org.apache.mrql.MapReduceMRQLFileInputFormat
 
MapReduceOperation - Class in org.apache.mrql
The MapReduce operation that uses an in-mapper combiner to partially reduce groups during mapping
MapReduceOperation() - Constructor for class org.apache.mrql.MapReduceOperation
 
MapReduceOperation.MRContainerPartitioner - Class in org.apache.mrql
 
MapReduceParsedInputFormat - Class in org.apache.mrql
A FileInputFormat for text files (CVS, XML, JSON, ...)
MapReduceParsedInputFormat() - Constructor for class org.apache.mrql.MapReduceParsedInputFormat
 
MapReduceParsedInputFormat.ParsedRecordReader - Class in org.apache.mrql
 
MapReducePlan - Class in org.apache.mrql
A superclass for Hadoop MapReduce physical operators (files *Operator.java)
MapReducePlan() - Constructor for class org.apache.mrql.MapReducePlan
 
materialize(Path) - Method in class org.apache.mrql.MapReduceBinaryInputFormat
collect the data from multiple sequence files at the path directory into a Bag
materialize(Path) - Method in class org.apache.mrql.MapReduceGeneratorInputFormat
Insert all results from the generators stored in path into a Bag.
materialize(Path) - Method in class org.apache.mrql.MapReduceMRQLFileInputFormat
materialize the input file into a memory Bag
materialize(Path) - Method in class org.apache.mrql.MapReduceParsedInputFormat
Find the parser associated with each file in the path and parse the file, inserting all results into a Bag.
MRContainerGroupingComparator() - Constructor for class org.apache.mrql.JoinOperation.MRContainerGroupingComparator
 
MRContainerJoinPartitioner() - Constructor for class org.apache.mrql.JoinOperation.MRContainerJoinPartitioner
 
MRContainerPartitioner() - Constructor for class org.apache.mrql.MapReduceOperation.MRContainerPartitioner
 
MRContainerSortComparator() - Constructor for class org.apache.mrql.JoinOperation.MRContainerSortComparator
 

N

new_configuration() - Method in class org.apache.mrql.MapReduceEvaluator
create a new evaluation configuration
nextKeyValue() - Method in class org.apache.mrql.MapReduceGeneratorInputFormat.GeneratorRecordReader
 
nextKeyValue() - Method in class org.apache.mrql.MapReduceParsedInputFormat.ParsedRecordReader
 

O

offset - Variable in class org.apache.mrql.MapReduceGeneratorInputFormat.GeneratorRecordReader
 
org.apache.mrql - package org.apache.mrql
 
outputRecords(Job) - Static method in class org.apache.mrql.MapReducePlan
find the number of records in the hadoop MapReduce job output

P

P_0 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_1 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_10 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_11 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_12 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_13 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_14 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_15 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_16 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_17 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_18 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_19 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_2 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_20 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_21 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_22 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_23 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_24 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_25 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_26 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_27 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_28 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_3 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_4 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_5 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_6 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_7 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_8 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
P_9 - Static variable in class org.apache.mrql.PatternNames_3611058747495859076
 
parsedInputFormat() - Method in class org.apache.mrql.MapReduceEvaluator
return the FileInputFormat for parsed files (CSV, XML, JSON, etc)
ParsedRecordReader(FileSplit, TaskAttemptContext, Class<? extends Parser>, Trees) - Constructor for class org.apache.mrql.MapReduceParsedInputFormat.ParsedRecordReader
 
parser - Variable in class org.apache.mrql.MapReduceParsedInputFormat.ParsedRecordReader
 
PatternNames_3611058747495859076 - Class in org.apache.mrql
 
PatternNames_3611058747495859076() - Constructor for class org.apache.mrql.PatternNames_3611058747495859076
 

R

reader - Variable in class org.apache.mrql.MapReduceGeneratorInputFormat.GeneratorRecordReader
 
readFields(DataInput) - Method in class org.apache.mrql.JoinOperation.JoinKey
 
repeat(Function, DataSet, int) - Static method in class org.apache.mrql.MapReducePlan
The repeat physical operator.
result - Variable in class org.apache.mrql.MapReduceParsedInputFormat.ParsedRecordReader
 

S

setupSplits(DataSet[], Configuration) - Static method in class org.apache.mrql.MapReducePlan
Set hadoop map min and max split size based on number of requested nodes
setupSplits(DataSet, Configuration) - Static method in class org.apache.mrql.MapReducePlan
Set hadoop map min and max split size based on number of requested nodes
shutdown(Configuration) - Method in class org.apache.mrql.MapReduceEvaluator
shutdown the MapReduce evaluator
size - Variable in class org.apache.mrql.MapReduceGeneratorInputFormat.GeneratorRecordReader
 
start - Variable in class org.apache.mrql.MapReduceParsedInputFormat.ParsedRecordReader
 

T

tag - Variable in class org.apache.mrql.JoinOperation.JoinKey
 
toBag(MRData) - Method in class org.apache.mrql.MapReduceEvaluator
Coerce a persistent collection to a Bag
toString() - Method in class org.apache.mrql.JoinOperation.JoinKey
 

W

write(DataOutput) - Method in class org.apache.mrql.JoinOperation.JoinKey
 
A B C D E F G I J K L M N O P R S T W 
Skip navigation links

Copyright © 2013-2016 The Apache Software Foundation. All Rights Reserved.