public final class CrossProductOperation extends MapReducePlan
Plan.MRContainerKeyComparator
cache, conf, counter_container, counter_key, max_input_files, temporary_paths, value_container
Constructor and Description |
---|
CrossProductOperation() |
Modifier and Type | Method and Description |
---|---|
static DataSet |
crossProduct(Tree mx,
Tree my,
Tree reduce_fnc,
Tree acc_fnc,
Tree zero,
DataSet X,
DataSet Y,
String stop_counter)
The CrossProduct physical operator (similar to block-nested loop)
|
aggregate, closure, outputRecords, repeat
, binarySource, binarySource, clean, collect, collect, distribute_compiled_arguments, fileCache, functional_argument, generator, generator, get_type, getCache, merge, merge, new_path, parsedSource, parsedSource, print_stream, setCache, size
public static final DataSet crossProduct(Tree mx, Tree my, Tree reduce_fnc, Tree acc_fnc, Tree zero, DataSet X, DataSet Y, String stop_counter) throws Exception
mx
- left mappermy
- right mapperreduce_fnc
- reduceracc_fnc
- optional accumulator functionzero
- optional the zero value for the accumulatorX
- the left sourceY
- the right source (stored in distributed cache)stop_counter
- optional counter used in repeat operationException
Copyright © 2013–2014 The Apache Software Foundation. All rights reserved.