Class | Description |
---|---|
CorrelateFlatMapRunner<IN,OUT> | |
CountPartitionFunction<IN> | |
FlatJoinRunner<IN1,IN2,OUT> | |
FlatMapRunner<IN,OUT> | |
IntersectCoGroupFunction<T> | |
LimitFilterFunction<T> | |
MapJoinLeftRunner<IN1,IN2,OUT> | |
MapJoinRightRunner<IN1,IN2,OUT> | |
MapRunner<IN,OUT> | |
MapSideJoinRunner<IN1,IN2,SINGLE_IN,MULTI_IN,OUT> | |
MinusCoGroupFunction<T> | |
TableFunctionCollector<T> |
The basic implementation of collector for
TableFunction . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.