Class | Description |
---|---|
CorrelateFlatMapRunner<IN,OUT> | |
CountPartitionFunction<IN> | |
CRowCorrelateProcessRunner |
A CorrelateProcessRunner with
CRow input and CRow output. |
CRowInputJavaTupleOutputMapRunner |
Convert
CRow to a JTuple2 |
CRowInputMapRunner<OUT> |
MapRunner with
CRow input. |
CRowInputScalaTupleOutputMapRunner |
Convert
CRow to a Tuple2 |
CRowOutputMapRunner |
MapRunner with
CRow output. |
CRowProcessRunner |
ProcessRunner with
CRow input and CRow output. |
CRowWrappingCollector |
The collector is used to wrap a
Row to a CRow |
FlatJoinRunner<IN1,IN2,OUT> | |
FlatMapRunner | |
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–2018 The Apache Software Foundation. All rights reserved.