public final class PlanGeneration extends AlgebraicOptimization
Modifier and Type | Class and Description |
---|---|
(package private) static class |
PlanGeneration.Aggregates
extract the combiner from the reducer in a MapReduce plan
|
algebraic_operators, data_constructors, functions, global_datatype_env, global_functions, global_macros, global_type_env, global_vars, identity, impure_functions, monoids, plan_names, plans_with_distributed_lambdas, repeat_variables, st, type_env, type_names
Constructor and Description |
---|
PlanGeneration() |
Modifier and Type | Method and Description |
---|---|
static boolean |
is_dataset_expr(Tree e)
true if e returns a dataset stored in HDFS
|
static Tree |
makePlan(Tree e)
compile an algebraic form to a algebraic plan
|
static Tree |
physical_plan(Tree plan)
convert an algebraic plan to a physical plan
|
static boolean |
streamed_MapReduce_reducer(Tree x)
can we process the second arg of the MapReducer reducer (a bag) as a stream?
|
static boolean |
streamed_MapReduce2_reducer(Tree x)
can we process the first arg of the MapReducer2 reducer (a bag) as a stream?
|
common_factoring, translate_all, translate
simplify_all, simplify
bind_pattern, normalize_all, normalize, remove_groupby, rename
alpha_equivalent, alpha_equivalent, collection_type, error, free_variables, global_reset, identity, is_collection, is_persistent_collection, is_pure, new_var, occurences, pattern_variables, persistent_collection, print_aggregates, reify, reify, reset, subst_list, subst_var, subst, template, top_level, transient_collection, translate_select, union
print_plan, print_query, print_type, print, reify
public static boolean streamed_MapReduce_reducer(Tree x)
public static boolean streamed_MapReduce2_reducer(Tree x)
public static boolean is_dataset_expr(Tree e)
public static Tree makePlan(Tree e)
e
- the algebraic formCopyright © 2013 The Apache Software Foundation. All rights reserved.