public class IntersectCoGroupFunction<T> extends Object implements CoGroupFunction<T,T,T>
Constructor and Description |
---|
IntersectCoGroupFunction(boolean all) |
Modifier and Type | Method and Description |
---|---|
void |
coGroup(Iterable<T> first,
Iterable<T> second,
Collector<T> out)
This method must be implemented to provide a user implementation of a
coGroup.
|
public void coGroup(Iterable<T> first, Iterable<T> second, Collector<T> out)
CoGroupFunction
coGroup
in interface CoGroupFunction<T,T,T>
first
- The records from the first input.second
- The records from the second.out
- A collector to return elements.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.