Class | Description |
---|---|
CoGroupOperator<IN1,IN2,KEY extends Serializable,OUT> |
An operator that implements the co-group logic.
|
FixedLengthByteKeyComparator<IN> |
A comparator used in
SortingDataInput which compares records keys and timestamps. |
KeyAndValueSerializer<IN> |
A serializer used in
SortingDataInput for serializing elements alongside their key and
timestamp. |
VariableLengthByteKeyComparator<IN> |
A comparator used in
SortingDataInput which compares records keys and timestamps,. |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.