IN
- Type of the value field of the StreamRecordpublic class StreamRecordComparator<IN> extends Object implements Comparator<StreamRecord<IN>>, Serializable
StreamRecord
s based on their timestamp.Constructor and Description |
---|
StreamRecordComparator() |
Modifier and Type | Method and Description |
---|---|
int |
compare(StreamRecord<IN> o1,
StreamRecord<IN> o2) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
comparing, comparing, comparingDouble, comparingInt, comparingLong, equals, naturalOrder, nullsFirst, nullsLast, reversed, reverseOrder, thenComparing, thenComparing, thenComparing, thenComparingDouble, thenComparingInt, thenComparingLong
public int compare(StreamRecord<IN> o1, StreamRecord<IN> o2)
compare
in interface Comparator<StreamRecord<IN>>
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.