public static final class FlinkEvaluator.group_join_reducer extends org.apache.flink.api.common.functions.RichGroupReduceFunction<FData,FData>
Modifier and Type | Field and Description |
---|---|
(package private) Function |
fc |
(package private) Function |
fgx |
(package private) Function |
fgy |
(package private) Function |
fkx |
(package private) Function |
fky |
(package private) Function |
fr |
(package private) MRData |
z |
Constructor and Description |
---|
group_join_reducer(Tree kx,
Tree ky,
Tree gx,
Tree gy,
Tree c,
Tree r,
Tree zero) |
Modifier and Type | Method and Description |
---|---|
void |
reduce(Iterable<FData> values,
org.apache.flink.util.Collector<FData> out) |
Copyright © 2013-2016 The Apache Software Foundation. All Rights Reserved.