A B C D E F G H I J K L M N O P R S T V W Z 

A

absolute_path(String) - Static method in class org.apache.mrql.FlinkEvaluator
returns the absolute path relative to the directory that contains the MRQL executable
acc - Variable in class org.apache.mrql.FlinkDataSource.Reducer
 
acc - Variable in class org.apache.mrql.FlinkEvaluator.aggregate_partition
 
acc - Variable in class org.apache.mrql.FlinkEvaluator.cross_combiner_reducer
 
acc - Variable in class org.apache.mrql.FlinkEvaluator.groupBy_combiner_reducer
 
acc - Variable in class org.apache.mrql.FlinkEvaluator.join_combiner_reducer
 
acc_fnc - Variable in class org.apache.mrql.FlinkDataSource.Reducer
 
accumulated_value - Variable in class org.apache.mrql.FlinkDataSource.Reducer
 
add(FData) - Method in class org.apache.mrql.FlinkDataSource.Reducer
 
aggregate(Tree, Tree, Tree, Environment) - Method in class org.apache.mrql.FlinkEvaluator
The Aggregate physical operator

B

binaryInputFormat() - Method in class org.apache.mrql.FlinkEvaluator
return the FileInputFormat for binary files
buffer - Variable in class org.apache.mrql.FlinkJsonSplitter
 
buffer - Variable in class org.apache.mrql.FlinkXMLSplitter
 

C

client_env - Variable in class org.apache.mrql.FlinkEvaluator.restore_global_functions
 
close() - Method in class org.apache.mrql.FlinkSequenceInputFormat.FDataInputFormat
 
close() - Method in class org.apache.mrql.LineReader
 
coGroup(Iterable<FData>, Iterable<FData>, Collector<FData>) - Method in class org.apache.mrql.FlinkEvaluator.join_combiner_reducer
 
coGroup(Iterable<FData>, Iterable<FData>, Collector<FData>) - Method in class org.apache.mrql.FlinkEvaluator.join_reducer
 
collect(DataSet, boolean) - Method in class org.apache.mrql.FlinkMRQLFileInputFormat
materialize the entire dataset into a Bag
compareTo(FData) - Method in class org.apache.mrql.FData
 
compareTo(MRData) - Method in class org.apache.mrql.MR_flink
 
copy(DataInputView, DataOutputView) - Method in class org.apache.mrql.FData
 
copyTo(FData) - Method in class org.apache.mrql.FData
 
cross(FData, FData) - Method in class org.apache.mrql.FlinkEvaluator.cross_combiner_reducer
 
cross(FData, FData) - Method in class org.apache.mrql.FlinkEvaluator.cross_reducer
 

D

data - Variable in class org.apache.mrql.FData
 
data() - Method in class org.apache.mrql.FData
 
data_set - Variable in class org.apache.mrql.FlinkDataSource
 
data_source_dir_name - Static variable in class org.apache.mrql.FlinkEvaluator
 
data_sources - Variable in class org.apache.mrql.FlinkParsedInputFormat.ParsedInputFormat
 
deserialize(FData, DataInputView) - Method in class org.apache.mrql.FlinkBinaryInputFormat.FDataInputFormat
 
deserialize(FData, DataInputView) - Method in class org.apache.mrql.FlinkSequenceInputFormat.FDataInputFormat
 
dump(String, Tree, MRData) - Method in class org.apache.mrql.FlinkEvaluator
dump MRQL data into a Hadoop Sequence file
dump_text(String, Tree, MRData) - Method in class org.apache.mrql.FlinkEvaluator
dump MRQL data into a text CVS file

E

encode_data_sources() - Static method in class org.apache.mrql.FlinkMRQLFileInputFormat
encode the data source directory (to be serialized and distributed to clients)
end - Variable in class org.apache.mrql.FlinkJsonSplitter
 
end - Variable in class org.apache.mrql.FlinkXMLSplitter
 
eof - Variable in class org.apache.mrql.FlinkParsedInputFormat.ParsedInputFormat
 
equals(Object) - Method in class org.apache.mrql.FData
 
equals(Object) - Method in class org.apache.mrql.MR_flink
 
eval(Tree, Environment, String) - Method in class org.apache.mrql.FlinkEvaluator
Evaluate an MRQL physical plan and print tracing info
eval(Tree, Environment) - Method in class org.apache.mrql.FlinkEvaluator
Evaluate an MRQL physical plan using Flink and print tracing info
evaluate(Tree, Environment, DataSetFunction) - Static method in class org.apache.mrql.FlinkStreaming
evaluate plan in stream mode: evaluate each batch of data and apply the function f

F

f - Variable in class org.apache.mrql.FlinkEvaluator.cross_reducer
 
f - Variable in class org.apache.mrql.FlinkEvaluator.join_reducer
 
f - Variable in class org.apache.mrql.FlinkEvaluator.mapjoin_reducer
 
fc - Variable in class org.apache.mrql.FlinkEvaluator.group_join_reducer
 
FData - Class in org.apache.mrql
 
FData() - Constructor for class org.apache.mrql.FData
 
FData(MRData) - Constructor for class org.apache.mrql.FData
 
fgx - Variable in class org.apache.mrql.FlinkEvaluator.group_join_left
 
fgx - Variable in class org.apache.mrql.FlinkEvaluator.group_join_reducer
 
fgy - Variable in class org.apache.mrql.FlinkEvaluator.group_join_reducer
 
fgy - Variable in class org.apache.mrql.FlinkEvaluator.group_join_right
 
filter(FData) - Method in class org.apache.mrql.FlinkEvaluator.repeat_filter
 
fkx - Variable in class org.apache.mrql.FlinkEvaluator.group_join_reducer
 
fky - Variable in class org.apache.mrql.FlinkEvaluator.group_join_reducer
 
flatMap(FData, Collector<FData>) - Method in class org.apache.mrql.FlinkDataSource.reduce_mapper
 
flatMap(FData, Collector<FData>) - Method in class org.apache.mrql.FlinkDataSource.size_mapper
 
flatMap(FData, Collector<FData>) - Method in class org.apache.mrql.FlinkEvaluator.group_join_left
 
flatMap(FData, Collector<FData>) - Method in class org.apache.mrql.FlinkEvaluator.group_join_right
 
flatMap(String, Collector<FData>) - Method in class org.apache.mrql.FlinkEvaluator.parsed_mapper
 
flink - Variable in class org.apache.mrql.MR_flink
 
flink() - Method in class org.apache.mrql.MR_flink
 
flink_env - Static variable in class org.apache.mrql.FlinkEvaluator
 
flink_jar - Static variable in class org.apache.mrql.FlinkEvaluator
 
FlinkBinaryInputFormat - Class in org.apache.mrql
Input format for binary files
FlinkBinaryInputFormat() - Constructor for class org.apache.mrql.FlinkBinaryInputFormat
 
FlinkBinaryInputFormat.FDataInputFormat - Class in org.apache.mrql
 
FlinkBinaryInputFormat.FDataInputFormat() - Constructor for class org.apache.mrql.FlinkBinaryInputFormat.FDataInputFormat
 
FlinkDataSource - Class in org.apache.mrql
A data source for storing a Flink result (a Flink DataSet )
FlinkDataSource(DataSet<FData>, String, boolean) - Constructor for class org.apache.mrql.FlinkDataSource
 
FlinkDataSource.reduce_mapper - Class in org.apache.mrql
Used in MRQL total aggregations in FlinkEvaluator.aggregate
FlinkDataSource.reduce_mapper(MRData, String, String) - Constructor for class org.apache.mrql.FlinkDataSource.reduce_mapper
 
FlinkDataSource.Reducer - Class in org.apache.mrql
Used in MRQL total aggregations in FlinkEvaluator.aggregate
FlinkDataSource.Reducer() - Constructor for class org.apache.mrql.FlinkDataSource.Reducer
 
FlinkDataSource.Reducer(MRData, String, String) - Constructor for class org.apache.mrql.FlinkDataSource.Reducer
 
FlinkDataSource.size_mapper - Class in org.apache.mrql
 
FlinkDataSource.size_mapper() - Constructor for class org.apache.mrql.FlinkDataSource.size_mapper
 
FlinkEvaluator - Class in org.apache.mrql
Evaluates physical plans in Apache Flink mode
FlinkEvaluator() - Constructor for class org.apache.mrql.FlinkEvaluator
 
FlinkEvaluator.aggregate_partition - Class in org.apache.mrql
 
FlinkEvaluator.aggregate_partition(Tree, Tree, MRData) - Constructor for class org.apache.mrql.FlinkEvaluator.aggregate_partition
 
FlinkEvaluator.cross_combiner_reducer - Class in org.apache.mrql
 
FlinkEvaluator.cross_combiner_reducer(Tree, Tree, MRData) - Constructor for class org.apache.mrql.FlinkEvaluator.cross_combiner_reducer
 
FlinkEvaluator.cross_reducer - Class in org.apache.mrql
 
FlinkEvaluator.cross_reducer(Tree) - Constructor for class org.apache.mrql.FlinkEvaluator.cross_reducer
 
FlinkEvaluator.generator_mapper - Class in org.apache.mrql
 
FlinkEvaluator.generator_mapper() - Constructor for class org.apache.mrql.FlinkEvaluator.generator_mapper
 
FlinkEvaluator.group_join_left - Class in org.apache.mrql
 
FlinkEvaluator.group_join_left(Tree, int, int) - Constructor for class org.apache.mrql.FlinkEvaluator.group_join_left
 
FlinkEvaluator.group_join_reducer - Class in org.apache.mrql
 
FlinkEvaluator.group_join_reducer(Tree, Tree, Tree, Tree, Tree, Tree, Tree) - Constructor for class org.apache.mrql.FlinkEvaluator.group_join_reducer
 
FlinkEvaluator.group_join_right - Class in org.apache.mrql
 
FlinkEvaluator.group_join_right(Tree, int, int) - Constructor for class org.apache.mrql.FlinkEvaluator.group_join_right
 
FlinkEvaluator.groupBy_combiner_reducer - Class in org.apache.mrql
 
FlinkEvaluator.groupBy_combiner_reducer(Tree, Tree, MRData) - Constructor for class org.apache.mrql.FlinkEvaluator.groupBy_combiner_reducer
 
FlinkEvaluator.join_combiner_reducer - Class in org.apache.mrql
 
FlinkEvaluator.join_combiner_reducer(Tree, Tree, MRData) - Constructor for class org.apache.mrql.FlinkEvaluator.join_combiner_reducer
 
FlinkEvaluator.join_key - Class in org.apache.mrql
 
FlinkEvaluator.join_key() - Constructor for class org.apache.mrql.FlinkEvaluator.join_key
 
FlinkEvaluator.join_reducer - Class in org.apache.mrql
 
FlinkEvaluator.join_reducer(Tree) - Constructor for class org.apache.mrql.FlinkEvaluator.join_reducer
 
FlinkEvaluator.mapjoin_reducer - Class in org.apache.mrql
 
FlinkEvaluator.mapjoin_reducer(Tree) - Constructor for class org.apache.mrql.FlinkEvaluator.mapjoin_reducer
 
FlinkEvaluator.parsed_mapper - Class in org.apache.mrql
 
FlinkEvaluator.parsed_mapper(Class<? extends Parser>) - Constructor for class org.apache.mrql.FlinkEvaluator.parsed_mapper
 
FlinkEvaluator.repeat_filter - Class in org.apache.mrql
 
FlinkEvaluator.repeat_filter() - Constructor for class org.apache.mrql.FlinkEvaluator.repeat_filter
 
FlinkEvaluator.repeat_values - Class in org.apache.mrql
 
FlinkEvaluator.repeat_values() - Constructor for class org.apache.mrql.FlinkEvaluator.repeat_values
 
FlinkEvaluator.restore_global_functions - Class in org.apache.mrql
restore the global bindings at the client node
FlinkEvaluator.restore_global_functions() - Constructor for class org.apache.mrql.FlinkEvaluator.restore_global_functions
 
FlinkEvaluator.set_environment - Class in org.apache.mrql
 
FlinkEvaluator.set_environment(String) - Constructor for class org.apache.mrql.FlinkEvaluator.set_environment
 
FlinkGeneratorInputFormat - 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]
FlinkGeneratorInputFormat() - Constructor for class org.apache.mrql.FlinkGeneratorInputFormat
 
FlinkJsonParser - Class in org.apache.mrql
The JSON parser
FlinkJsonParser() - Constructor for class org.apache.mrql.FlinkJsonParser
 
FlinkJsonSplitter - Class in org.apache.mrql
Extract the JSON objects tagged by tags from a data split of the input stream (fsin)
FlinkJsonSplitter(String[], FSDataInputStream, long, long) - Constructor for class org.apache.mrql.FlinkJsonSplitter
 
FlinkJsonSplitter(String[], String) - Constructor for class org.apache.mrql.FlinkJsonSplitter
 
FlinkLineParser - Class in org.apache.mrql
A parser for line-oriented, character delimited text files (such as CVS)
FlinkLineParser() - Constructor for class org.apache.mrql.FlinkLineParser
 
FlinkMRQLFileInputFormat - Class in org.apache.mrql
A superclass for all MRQL FileInputFormats
FlinkMRQLFileInputFormat() - Constructor for class org.apache.mrql.FlinkMRQLFileInputFormat
 
FlinkOutputFormat - Class in org.apache.mrql
 
FlinkOutputFormat() - Constructor for class org.apache.mrql.FlinkOutputFormat
 
FlinkParsedDataSource - Class in org.apache.mrql
A data source for a text HDFS file along with the parser to parse it
FlinkParsedDataSource(String, Class<? extends Parser>, Trees) - Constructor for class org.apache.mrql.FlinkParsedDataSource
 
FlinkParsedInputFormat - Class in org.apache.mrql
A FileInputFormat for text files (CVS, XML, JSON, ...)
FlinkParsedInputFormat() - Constructor for class org.apache.mrql.FlinkParsedInputFormat
 
FlinkParsedInputFormat.ParsedInputFormat - Class in org.apache.mrql
 
FlinkParsedInputFormat.ParsedInputFormat(String) - Constructor for class org.apache.mrql.FlinkParsedInputFormat.ParsedInputFormat
 
FlinkParser - Interface in org.apache.mrql
for a new text data source, you must implement a new parser
FlinkSequenceInputFormat - Class in org.apache.mrql
Input format for Hadoop Sequence files
FlinkSequenceInputFormat() - Constructor for class org.apache.mrql.FlinkSequenceInputFormat
 
FlinkSequenceInputFormat.FDataInputFormat - Class in org.apache.mrql
 
FlinkSequenceInputFormat.FDataInputFormat() - Constructor for class org.apache.mrql.FlinkSequenceInputFormat.FDataInputFormat
 
FlinkStreaming - Class in org.apache.mrql
Evaluates physical plans in Apache Flink stream mode
FlinkStreaming() - Constructor for class org.apache.mrql.FlinkStreaming
 
FlinkStreaming.MRDataFileSourceFunction - Class in org.apache.mrql
 
FlinkStreaming.MRDataFileSourceFunction(String, long, FileInputFormat<FData>) - Constructor for class org.apache.mrql.FlinkStreaming.MRDataFileSourceFunction
 
FlinkXMLParser - Class in org.apache.mrql
A parser for line-oriented, character delimited text files (such as CVS)
FlinkXMLParser() - Constructor for class org.apache.mrql.FlinkXMLParser
 
FlinkXMLSplitter - Class in org.apache.mrql
Extract the XML elements tagged by tags from a data split of the input stream (fsin) and store them in a buffer (to be parsed by SAX).
FlinkXMLSplitter(String[], FSDataInputStream, long, long) - Constructor for class org.apache.mrql.FlinkXMLSplitter
 
FlinkXMLSplitter(String[], String) - Constructor for class org.apache.mrql.FlinkXMLSplitter
 
fr - Variable in class org.apache.mrql.FlinkEvaluator.group_join_reducer
 
fs_default_name - Static variable in class org.apache.mrql.FlinkEvaluator
 
fsin - Variable in class org.apache.mrql.FlinkJsonSplitter
 
fsin - Variable in class org.apache.mrql.FlinkXMLSplitter
 

G

generatorInputFormat() - Method in class org.apache.mrql.FlinkEvaluator
return the FileInputFormat for data generator files
get_type(String) - Method in class org.apache.mrql.FlinkEvaluator
for dumped data to a file, return the MRQL type of the data
getBinaryLength() - Method in class org.apache.mrql.FData
 
getFiles() - Method in class org.apache.mrql.FlinkSequenceInputFormat.FDataInputFormat
 
getKey(FData) - Method in class org.apache.mrql.FlinkEvaluator.join_key
 
getLocalValue() - Method in class org.apache.mrql.FlinkDataSource.Reducer
 

H

hashCode() - Method in class org.apache.mrql.FData
 
hasNext() - Method in class org.apache.mrql.FlinkJsonSplitter
 
hasNext() - Method in class org.apache.mrql.FlinkXMLSplitter
 

I

in - Variable in class org.apache.mrql.FlinkJsonSplitter
 
in - Variable in class org.apache.mrql.FlinkLineParser
 
in - Variable in class org.apache.mrql.FlinkXMLSplitter
 
in_memory - Variable in class org.apache.mrql.FlinkJsonSplitter
 
in_memory - Variable in class org.apache.mrql.FlinkXMLSplitter
 
init(Configuration) - Method in class org.apache.mrql.FlinkEvaluator
initialize the Flink evaluator
initialize_query() - Method in class org.apache.mrql.FlinkEvaluator
 
inputFormat(String) - Method in class org.apache.mrql.FlinkBinaryInputFormat
the Flink input format for this input
inputFormat(String) - Method in class org.apache.mrql.FlinkGeneratorInputFormat
the Flink input format for this input
inputFormat(String) - Method in class org.apache.mrql.FlinkMRQLFileInputFormat
the Flink input format for this input
inputFormat(String) - Method in class org.apache.mrql.FlinkParsedInputFormat
the Flink input format for this input
inputFormat(String) - Method in class org.apache.mrql.FlinkSequenceInputFormat
the Flink input format for this input
invoke(Collector<FData>) - Method in class org.apache.mrql.FlinkStreaming.MRDataFileSourceFunction
 
is_start_tag(String) - Method in class org.apache.mrql.FlinkJsonSplitter
 
is_start_tag() - Method in class org.apache.mrql.FlinkXMLSplitter
 
iter - Variable in class org.apache.mrql.FlinkParsedInputFormat.ParsedInputFormat
 

J

join(FData, FData) - Method in class org.apache.mrql.FlinkEvaluator.mapjoin_reducer
 

K

key - Variable in class org.apache.mrql.FlinkSequenceInputFormat.FDataInputFormat
 

L

line - Variable in class org.apache.mrql.FlinkLineParser
 
LineReader - Class in org.apache.mrql
 
LineReader(FSDataInputStream, long, long, int) - Constructor for class org.apache.mrql.LineReader
 
loop(Tree, Environment) - Method in class org.apache.mrql.FlinkEvaluator
Evaluate a loop a fixed number of times.

M

m - Variable in class org.apache.mrql.FlinkEvaluator.aggregate_partition
 
m - Variable in class org.apache.mrql.FlinkEvaluator.group_join_left
 
m - Variable in class org.apache.mrql.FlinkEvaluator.group_join_right
 
map(Long) - Method in class org.apache.mrql.FlinkEvaluator.generator_mapper
 
map(FData) - Method in class org.apache.mrql.FlinkEvaluator.repeat_values
 
map(FData) - Method in class org.apache.mrql.FlinkEvaluator.restore_global_functions
 
map(FData) - Method in class org.apache.mrql.FlinkEvaluator.set_environment
 
mapPartition(Iterable<FData>, Collector<FData>) - Method in class org.apache.mrql.FlinkEvaluator.aggregate_partition
 
master_host - Static variable in class org.apache.mrql.FlinkEvaluator
 
master_port - Static variable in class org.apache.mrql.FlinkEvaluator
 
materialize(Path) - Method in class org.apache.mrql.FlinkMRQLFileInputFormat
materialize the input file into a memory Bag
materializeAll() - Method in class org.apache.mrql.MR_flink
 
merge() - Method in class org.apache.mrql.FlinkDataSource
merge the splits of a flink data source that have already been sorted
merge - Variable in class org.apache.mrql.FlinkDataSource.Reducer
 
merge(Accumulator<FData, String>) - Method in class org.apache.mrql.FlinkDataSource.Reducer
 
merge_fnc - Variable in class org.apache.mrql.FlinkDataSource.Reducer
 
MR_flink - Class in org.apache.mrql
a wrapper of a DataSet<FData> as an MRData
MR_flink(DataSet<FData>) - Constructor for class org.apache.mrql.MR_flink
 

N

n - Variable in class org.apache.mrql.FlinkEvaluator.group_join_left
 
n - Variable in class org.apache.mrql.FlinkEvaluator.group_join_right
 
new_configuration() - Method in class org.apache.mrql.FlinkEvaluator
 
next() - Method in class org.apache.mrql.FlinkJsonSplitter
 
next() - Method in class org.apache.mrql.FlinkXMLSplitter
 
nextRecord(FData) - Method in class org.apache.mrql.FlinkParsedInputFormat.ParsedInputFormat
 
nextRecord(FData) - Method in class org.apache.mrql.FlinkSequenceInputFormat.FDataInputFormat
 

O

one - Variable in class org.apache.mrql.FlinkEvaluator.group_join_left
 
open(Configuration) - Method in class org.apache.mrql.FlinkDataSource.reduce_mapper
 
open(Configuration) - Method in class org.apache.mrql.FlinkDataSource.size_mapper
 
open(Configuration) - Method in class org.apache.mrql.FlinkEvaluator.restore_global_functions
 
open(Configuration) - Method in class org.apache.mrql.FlinkEvaluator.set_environment
 
open(String) - Method in class org.apache.mrql.FlinkJsonParser
 
open(FSDataInputStream, long, long) - Method in class org.apache.mrql.FlinkJsonParser
 
open(FSDataInputStream, long, long) - Method in class org.apache.mrql.FlinkLineParser
 
open(FileInputSplit) - Method in class org.apache.mrql.FlinkParsedInputFormat.ParsedInputFormat
 
open(FSDataInputStream, long, long) - Method in interface org.apache.mrql.FlinkParser
 
open(FileInputSplit) - Method in class org.apache.mrql.FlinkSequenceInputFormat.FDataInputFormat
 
open(String) - Method in class org.apache.mrql.FlinkXMLParser
 
open(FSDataInputStream, long, long) - Method in class org.apache.mrql.FlinkXMLParser
 
org.apache.mrql - package org.apache.mrql
 

P

P_0 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_0 - Static variable in class org.apache.mrql.PatternNames_3258700491221857568
 
P_1 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_1 - Static variable in class org.apache.mrql.PatternNames_3258700491221857568
 
P_10 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_11 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_12 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_13 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_14 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_15 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_16 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_17 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_18 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_19 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_2 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_2 - Static variable in class org.apache.mrql.PatternNames_3258700491221857568
 
P_20 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_21 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_22 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_23 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_24 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_25 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_26 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_27 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_3 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_3 - Static variable in class org.apache.mrql.PatternNames_3258700491221857568
 
P_4 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_5 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_6 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_7 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_8 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
P_9 - Static variable in class org.apache.mrql.PatternNames_2589327340439247798
 
parsedInputFormat() - Method in class org.apache.mrql.FlinkEvaluator
return the FileInputFormat for parsed files (CSV, XML, JSON, etc)
parser - Variable in class org.apache.mrql.FlinkEvaluator.parsed_mapper
 
parser - Variable in class org.apache.mrql.FlinkParsedInputFormat.ParsedInputFormat
 
pathname - Variable in class org.apache.mrql.FlinkParsedInputFormat.ParsedInputFormat
 
PatternNames_2589327340439247798 - Class in org.apache.mrql
 
PatternNames_2589327340439247798() - Constructor for class org.apache.mrql.PatternNames_2589327340439247798
 
PatternNames_3258700491221857568 - Class in org.apache.mrql
 
PatternNames_3258700491221857568() - Constructor for class org.apache.mrql.PatternNames_3258700491221857568
 
pos - Variable in class org.apache.mrql.FlinkXMLSplitter
 

R

r - Variable in class org.apache.mrql.FlinkDataSource.reduce_mapper
 
r - Variable in class org.apache.mrql.FlinkEvaluator.cross_combiner_reducer
 
r - Variable in class org.apache.mrql.FlinkEvaluator.groupBy_combiner_reducer
 
r - Variable in class org.apache.mrql.FlinkEvaluator.join_combiner_reducer
 
reachedEnd() - Method in class org.apache.mrql.FlinkParsedInputFormat.ParsedInputFormat
 
reachedEnd() - Method in class org.apache.mrql.FlinkSequenceInputFormat.FDataInputFormat
 
read(DataInputView) - Method in class org.apache.mrql.FData
 
read(DataInputView) - Method in class org.apache.mrql.FlinkDataSource.Reducer
 
read_tag() - Method in class org.apache.mrql.FlinkXMLSplitter
 
readFields(DataInput) - Method in class org.apache.mrql.MR_flink
 
readLine() - Method in class org.apache.mrql.LineReader
 
reduce(Iterable<FData>, Collector<FData>) - Method in class org.apache.mrql.FlinkEvaluator.group_join_reducer
 
reduce(Iterable<FData>, Collector<FData>) - Method in class org.apache.mrql.FlinkEvaluator.groupBy_combiner_reducer
 
remove() - Method in class org.apache.mrql.FlinkJsonSplitter
 
remove() - Method in class org.apache.mrql.FlinkXMLSplitter
 
resetLocal() - Method in class org.apache.mrql.FlinkDataSource.Reducer
 
restore_data_sources(String) - Static method in class org.apache.mrql.FlinkMRQLFileInputFormat
restore the data source directory

S

scanner - Variable in class org.apache.mrql.FlinkJsonSplitter
 
serialize(FData, DataOutputView) - Method in class org.apache.mrql.FlinkOutputFormat
 
shutdown(Configuration) - Method in class org.apache.mrql.FlinkEvaluator
shutdown the Flink evaluator
size(Configuration) - Method in class org.apache.mrql.FlinkDataSource
not used
skip() - Method in class org.apache.mrql.FlinkJsonSplitter
skip until the beginning of a split element
skip() - Method in class org.apache.mrql.FlinkXMLSplitter
skip until the beginning of a split element
slice() - Method in class org.apache.mrql.FlinkJsonParser
 
slice() - Method in class org.apache.mrql.FlinkLineParser
 
slice() - Method in class org.apache.mrql.FlinkXMLParser
 
splitter - Variable in class org.apache.mrql.FlinkJsonParser
 
splitter - Variable in class org.apache.mrql.FlinkXMLParser
 
start - Variable in class org.apache.mrql.FlinkJsonSplitter
 
start - Variable in class org.apache.mrql.FlinkXMLSplitter
 
start_tagname - Variable in class org.apache.mrql.FlinkXMLSplitter
 
store() - Method in class org.apache.mrql.FlinkJsonSplitter
store one split element into the buffer; may cross split boundaries
store() - Method in class org.apache.mrql.FlinkXMLSplitter
store one split element into the buffer; may cross split boundaries
stream_env - Static variable in class org.apache.mrql.FlinkEvaluator
 
streaming(Tree, Environment, DataSetFunction) - Method in class org.apache.mrql.FlinkEvaluator
evaluate plan in stream mode: evaluate each batch of data and apply the function f

T

tagname - Variable in class org.apache.mrql.FlinkXMLSplitter
 
tags - Variable in class org.apache.mrql.FlinkJsonParser
 
tags - Variable in class org.apache.mrql.FlinkJsonSplitter
 
tags - Variable in class org.apache.mrql.FlinkXMLSplitter
 
take(int) - Method in class org.apache.mrql.FlinkDataSource
return the first num values
toString() - Method in class org.apache.mrql.FData
 
two - Variable in class org.apache.mrql.FlinkEvaluator.group_join_right
 

V

value - Variable in class org.apache.mrql.FlinkSequenceInputFormat.FDataInputFormat
 
var - Variable in class org.apache.mrql.FlinkEvaluator.set_environment
 

W

write(DataOutputView) - Method in class org.apache.mrql.FData
 
write(DataOutputView) - Method in class org.apache.mrql.FlinkDataSource.Reducer
 
write(DataOutput) - Method in class org.apache.mrql.MR_flink
 

Z

z - Variable in class org.apache.mrql.FlinkEvaluator.group_join_reducer
 
zero - Variable in class org.apache.mrql.FlinkDataSource.Reducer
 
zero - Variable in class org.apache.mrql.FlinkEvaluator.aggregate_partition
 
zero - Variable in class org.apache.mrql.FlinkEvaluator.cross_combiner_reducer
 
zero - Variable in class org.apache.mrql.FlinkEvaluator.groupBy_combiner_reducer
 
zero - Variable in class org.apache.mrql.FlinkEvaluator.join_combiner_reducer
 
A B C D E F G H I J K L M N O P R S T V W Z 

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