public class FlinkStreaming extends FlinkEvaluator
Modifier and Type | Class and Description |
---|---|
static class |
FlinkStreaming.MRDataFileSourceFunction |
FlinkEvaluator.aggregate_partition, FlinkEvaluator.cross_combiner_reducer, FlinkEvaluator.cross_reducer, FlinkEvaluator.generator_mapper, FlinkEvaluator.group_join_left, FlinkEvaluator.group_join_reducer, FlinkEvaluator.group_join_right, FlinkEvaluator.groupBy_combiner_reducer, FlinkEvaluator.join_combiner_reducer, FlinkEvaluator.join_key, FlinkEvaluator.join_reducer, FlinkEvaluator.mapjoin_reducer, FlinkEvaluator.parsed_mapper, FlinkEvaluator.repeat_filter, FlinkEvaluator.repeat_values, FlinkEvaluator.restore_global_functions, FlinkEvaluator.set_environment
data_source_dir_name, flink_env, flink_jar, fs_default_name, master_host, master_port, stream_env
counter_container, counter_key, evaluator, value_container
coerce_method, false_name, false_value, global_env, identity_mapper, is_dataset, null_name, null_value, query_plan, query_type, tab_count, trace_count, true_name, true_value
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 |
---|
FlinkStreaming() |
Modifier and Type | Method and Description |
---|---|
static void |
evaluate(Tree plan,
Environment env,
Function f)
evaluate plan in stream mode: evaluate each batch of data and apply the function f
|
absolute_path, aggregate, binaryInputFormat, dump_text, dump, eval, eval, generatorInputFormat, get_type, init, initialize_query, loop, new_configuration, parsedInputFormat, shutdown, streaming, toBag
bsp, distribute, synchronize
closure, dataSetCollect, evalE, evalE, evalF, evalM, evalMM, evalS, lookup_distributed_binding, lookup_global_binding, new_distributed_binding, new_global_binding, pre_trace, remove_global_binding, set_global_bindings, tabs, trace, translate_expression, variable_lookup
compare_types, equal_types, expand, make_persistent_type, normalize_type, subtype_unify, subtype, subtype, subtype, type_error, type_inference, type_inference2, unify, unify
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 final void evaluate(Tree plan, Environment env, Function f)
Copyright © 2013-2016 The Apache Software Foundation. All Rights Reserved.