public interface ReduceFunction
Modifier and Type | Method and Description |
---|---|
void |
init(Config cfg,
DataFlowOperation op,
java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> expectedIds)
Initialize the function
|
java.lang.Object |
reduce(java.lang.Object t1,
java.lang.Object t2)
Reduce t1 and t2 to a single value
|
void init(Config cfg, DataFlowOperation op, java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> expectedIds)
cfg
- configurationop
- optionsexpectedIds
- for each target, expected source idsjava.lang.Object reduce(java.lang.Object t1, java.lang.Object t2)
t1
- first valuet2
- second value