A B C D E F G I L M N O P R S 

A

aggregate(Tree, Tree, Tree, Environment) - Method in class org.apache.mrql.BSPEvaluator
The Aggregate physical operator

B

binaryInputFormat() - Method in class org.apache.mrql.BSPEvaluator
return the FileInputFormat for binary files
bsp(Tree, Environment) - Method in class org.apache.mrql.BSPEvaluator
Evaluate MRQL physical operators using BSP
BSP(int[], Tree, Tree, boolean, DataSet) - Static method in class org.apache.mrql.BSPPlan
Evaluate a BSP operation that returns a DataSet
bsp(BSPPeer<MRContainer, MRContainer, MRContainer, MRContainer, MRContainer>) - Method in class org.apache.mrql.BSPPlan.BSPop
 
BSPaggregate(int, Tree, Tree, Tree, Tree, DataSet) - Static method in class org.apache.mrql.BSPPlan
Evaluate a BSP operation that aggregates the results
BSPBinaryInputFormat - Class in org.apache.mrql
Input format for hadoop sequence files
BSPBinaryInputFormat() - Constructor for class org.apache.mrql.BSPBinaryInputFormat
 
BSPBinaryInputFormat.BinaryInputRecordReader - Class in org.apache.mrql
 
BSPBinaryInputFormat.BinaryInputRecordReader(FileSplit, BSPJob, int) - Constructor for class org.apache.mrql.BSPBinaryInputFormat.BinaryInputRecordReader
 
BSPEvaluator - Class in org.apache.mrql
Evaluate a physical plan in BSP mode using Apache Hama
BSPEvaluator() - Constructor for class org.apache.mrql.BSPEvaluator
 
BSPGeneratorInputFormat - 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]
BSPGeneratorInputFormat() - Constructor for class org.apache.mrql.BSPGeneratorInputFormat
 
BSPGeneratorInputFormat.GeneratorRecordReader - Class in org.apache.mrql
 
BSPGeneratorInputFormat.GeneratorRecordReader(FileSplit, int, BSPJob) - Constructor for class org.apache.mrql.BSPGeneratorInputFormat.GeneratorRecordReader
 
BSPMRQLFileInputFormat - Class in org.apache.mrql
A superclass for all MRQL FileInputFormats
BSPMRQLFileInputFormat() - Constructor for class org.apache.mrql.BSPMRQLFileInputFormat
 
BSPParsedInputFormat - Class in org.apache.mrql
A FileInputFormat for text files (CVS, XML, JSON, ...)
BSPParsedInputFormat() - Constructor for class org.apache.mrql.BSPParsedInputFormat
 
BSPParsedInputFormat.ParsedRecordReader - Class in org.apache.mrql
 
BSPParsedInputFormat.ParsedRecordReader(FileSplit, BSPJob, Class<? extends Parser>, int, Trees) - Constructor for class org.apache.mrql.BSPParsedInputFormat.ParsedRecordReader
 
BSPPlan - Class in org.apache.mrql
Evaluate a BSP plan using Hama
BSPPlan() - Constructor for class org.apache.mrql.BSPPlan
 
BSPPlan.BSPop - Class in org.apache.mrql
The BSP evaluator
BSPPlan.BSPop() - Constructor for class org.apache.mrql.BSPPlan.BSPop
 

C

cleanup(BSPPeer<MRContainer, MRContainer, MRContainer, MRContainer, MRContainer>) - Method in class org.apache.mrql.BSPPlan.BSPop
 
close() - Method in class org.apache.mrql.BSPGeneratorInputFormat.GeneratorRecordReader
 
close() - Method in class org.apache.mrql.BSPParsedInputFormat.ParsedRecordReader
 
collect(DataSet, boolean) - Method in class org.apache.mrql.BSPMRQLFileInputFormat
materialize the entire dataset into a Bag
createKey() - Method in class org.apache.mrql.BSPGeneratorInputFormat.GeneratorRecordReader
 
createKey() - Method in class org.apache.mrql.BSPParsedInputFormat.ParsedRecordReader
 
createValue() - Method in class org.apache.mrql.BSPGeneratorInputFormat.GeneratorRecordReader
 
createValue() - Method in class org.apache.mrql.BSPParsedInputFormat.ParsedRecordReader
 

D

distribute(MR_string, Bag) - Method in class org.apache.mrql.BSPEvaluator
 
distribute(MR_string, Bag) - Static method in class org.apache.mrql.BSPPlan.BSPop
collect a bag from all peers by distributing the local copy s

E

end - Variable in class org.apache.mrql.BSPParsedInputFormat.ParsedRecordReader
 
eval(Tree, Environment, String) - Method in class org.apache.mrql.BSPEvaluator
 
eval(Tree, Environment) - Method in class org.apache.mrql.BSPEvaluator
Evaluate MRQL BSP physical operators using Hama (returns a DataSet) and print tracing info
evalD(Tree, Environment) - Method in class org.apache.mrql.BSPEvaluator
Evaluate MRQL BSP physical operators using Hama (returns a DataSet)

F

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

G

generatorInputFormat() - Method in class org.apache.mrql.BSPEvaluator
return the FileInputFormat for data generator files
getConfiguration(BSPJob) - Static method in class org.apache.mrql.BSPPlan
 
getPos() - Method in class org.apache.mrql.BSPGeneratorInputFormat.GeneratorRecordReader
 
getPos() - Method in class org.apache.mrql.BSPParsedInputFormat.ParsedRecordReader
 
getProgress() - Method in class org.apache.mrql.BSPGeneratorInputFormat.GeneratorRecordReader
 
getProgress() - Method in class org.apache.mrql.BSPParsedInputFormat.ParsedRecordReader
 
getRecordReader(InputSplit, BSPJob) - Method in class org.apache.mrql.BSPBinaryInputFormat
 
getRecordReader(InputSplit, BSPJob) - Method in class org.apache.mrql.BSPGeneratorInputFormat
 
getRecordReader(InputSplit, BSPJob) - Method in class org.apache.mrql.BSPMRQLFileInputFormat
record reader for map-reduce
getRecordReader(InputSplit, BSPJob) - Method in class org.apache.mrql.BSPParsedInputFormat
 
getRecordReader(InputSplit, BSPJob) - Method in class org.apache.mrql.MultipleBSPInput
 

I

index - Variable in class org.apache.mrql.BSPGeneratorInputFormat.GeneratorRecordReader
 
init(Configuration) - Method in class org.apache.mrql.BSPEvaluator
initialize the BSP evaluator
initialize(InputSplit, TaskAttemptContext) - Method in class org.apache.mrql.BSPGeneratorInputFormat.GeneratorRecordReader
 
initialize_query() - Method in class org.apache.mrql.BSPEvaluator
 

L

local_cache - Variable in class org.apache.mrql.BSPPlan.BSPop
 
loop(Tree, Environment) - Method in class org.apache.mrql.BSPEvaluator
Evaluate a loop a fixed # of times

M

materialize(Path) - Method in class org.apache.mrql.BSPMRQLFileInputFormat
materialize the input file into a memory Bag
more_supersteps - Static variable in class org.apache.mrql.BSPPlan.BSPop
 
more_to_come - Static variable in class org.apache.mrql.BSPPlan.BSPop
 
msg_cache - Variable in class org.apache.mrql.BSPPlan.BSPop
 
MultipleBSPInput - Class in org.apache.mrql
A FileInputFormat for multiple files, where each file may be associated with a different FileInputFormat
MultipleBSPInput() - Constructor for class org.apache.mrql.MultipleBSPInput
 

N

new_configuration() - Method in class org.apache.mrql.BSPEvaluator
 
next(MRContainer, MRContainer) - Method in class org.apache.mrql.BSPBinaryInputFormat.BinaryInputRecordReader
 
next(MRContainer, MRContainer) - Method in class org.apache.mrql.BSPGeneratorInputFormat.GeneratorRecordReader
 
next(MRContainer, MRContainer) - Method in class org.apache.mrql.BSPParsedInputFormat.ParsedRecordReader
 
null_key - Static variable in class org.apache.mrql.BSPPlan.BSPop
 

O

offset - Variable in class org.apache.mrql.BSPGeneratorInputFormat.GeneratorRecordReader
 
org.apache.mrql - package org.apache.mrql
 

P

P_0 - Static variable in class org.apache.mrql.PatternNames_6881458761208731168
 
P_1 - Static variable in class org.apache.mrql.PatternNames_6881458761208731168
 
P_10 - Static variable in class org.apache.mrql.PatternNames_6881458761208731168
 
P_11 - Static variable in class org.apache.mrql.PatternNames_6881458761208731168
 
P_2 - Static variable in class org.apache.mrql.PatternNames_6881458761208731168
 
P_3 - Static variable in class org.apache.mrql.PatternNames_6881458761208731168
 
P_4 - Static variable in class org.apache.mrql.PatternNames_6881458761208731168
 
P_5 - Static variable in class org.apache.mrql.PatternNames_6881458761208731168
 
P_6 - Static variable in class org.apache.mrql.PatternNames_6881458761208731168
 
P_7 - Static variable in class org.apache.mrql.PatternNames_6881458761208731168
 
P_8 - Static variable in class org.apache.mrql.PatternNames_6881458761208731168
 
P_9 - Static variable in class org.apache.mrql.PatternNames_6881458761208731168
 
parsedInputFormat() - Method in class org.apache.mrql.BSPEvaluator
return the FileInputFormat for parsed files (CSV, XML, JSON, etc)
parser - Variable in class org.apache.mrql.BSPParsedInputFormat.ParsedRecordReader
 
PatternNames_6881458761208731168 - Class in org.apache.mrql
 
PatternNames_6881458761208731168() - Constructor for class org.apache.mrql.PatternNames_6881458761208731168
 

R

reader - Variable in class org.apache.mrql.BSPGeneratorInputFormat.GeneratorRecordReader
 
result - Variable in class org.apache.mrql.BSPBinaryInputFormat.BinaryInputRecordReader
 
result - Variable in class org.apache.mrql.BSPParsedInputFormat.ParsedRecordReader
 

S

setup(BSPPeer<MRContainer, MRContainer, MRContainer, MRContainer, MRContainer>) - Method in class org.apache.mrql.BSPPlan.BSPop
 
setupSplits(BSPJob, DataSet) - Static method in class org.apache.mrql.BSPPlan
set Hama's min split size and number of BSP tasks (doesn't work with Hama 0.6.0)
shutdown(Configuration) - Method in class org.apache.mrql.BSPEvaluator
shutdown the BSP evaluator
size - Variable in class org.apache.mrql.BSPGeneratorInputFormat.GeneratorRecordReader
 
source_num_data - Variable in class org.apache.mrql.BSPBinaryInputFormat.BinaryInputRecordReader
 
source_num_data - Variable in class org.apache.mrql.BSPGeneratorInputFormat.GeneratorRecordReader
 
source_num_data - Variable in class org.apache.mrql.BSPParsedInputFormat.ParsedRecordReader
 
source_number - Variable in class org.apache.mrql.BSPBinaryInputFormat.BinaryInputRecordReader
 
source_number - Variable in class org.apache.mrql.BSPGeneratorInputFormat.GeneratorRecordReader
 
source_number - Variable in class org.apache.mrql.BSPParsedInputFormat.ParsedRecordReader
 
start - Variable in class org.apache.mrql.BSPParsedInputFormat.ParsedRecordReader
 
synchronize(MR_string, MR_bool) - Method in class org.apache.mrql.BSPEvaluator
 
synchronize(MR_string, MR_bool) - Static method in class org.apache.mrql.BSPPlan.BSPop
to exit a BSP loop, all peers must agree to exit (this is used in BSPTranslate.bspSimplify)
synchronize(BSPPeer<MRContainer, MRContainer, MRContainer, MRContainer, MRContainer>, MR_bool) - Static method in class org.apache.mrql.BSPPlan.BSPop
to exit a BSP loop, all peers must agree to exit (this is used in BSPTranslate.bspSimplify)
A B C D E F G I L M N O P R S 

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