public final class MapOperation extends MapReducePlan
Plan.MRContainerKeyComparator
cache, conf, counter_container, counter_key, max_input_files, temporary_paths, value_container
Constructor and Description |
---|
MapOperation() |
Modifier and Type | Method and Description |
---|---|
static DataSet |
cMap(Tree map_fnc,
Tree acc_fnc,
Tree zero,
DataSet source,
String stop_counter)
The cMap physical operator
|
aggregate, closure, outputRecords, repeat
, binarySource, binarySource, clean, collect, collect, distribute_compiled_arguments, dump, fileCache, functional_argument, generator, generator, get_type, getCache, merge, merge, new_path, parsedSource, parsedSource, print_stream, setCache, size
public static final DataSet cMap(Tree map_fnc, Tree acc_fnc, Tree zero, DataSet source, String stop_counter) throws Exception
map_fnc
- mapper functionacc_fnc
- optional accumulator functionzero
- optional the zero value for the accumulatorsource
- input data sourcestop_counter
- optional counter used in repeat operationException
Copyright © 2013 The Apache Software Foundation. All rights reserved.