@PublicEvolving public class TimeWindow extends Window
Modifier and Type | Class and Description |
---|---|
static class |
TimeWindow.Serializer |
Constructor and Description |
---|
TimeWindow(long start,
long end) |
Modifier and Type | Method and Description |
---|---|
TimeWindow |
cover(TimeWindow other)
Returns the minimal window covers both this window and the given window.
|
boolean |
equals(Object o) |
long |
getEnd() |
long |
getStart() |
int |
hashCode() |
boolean |
intersects(TimeWindow other)
Returns
true if this window intersects the given window. |
long |
maxTimestamp() |
static void |
mergeWindows(Collection<TimeWindow> windows,
MergingWindowAssigner.MergeCallback<TimeWindow> c)
Merge overlapping
TimeWindow s. |
String |
toString() |
public long getStart()
public long getEnd()
public long maxTimestamp()
maxTimestamp
in class Window
public boolean intersects(TimeWindow other)
true
if this window intersects the given window.public TimeWindow cover(TimeWindow other)
public static void mergeWindows(Collection<TimeWindow> windows, MergingWindowAssigner.MergeCallback<TimeWindow> c)
TimeWindow
s. For use by merging
WindowAssigners
.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.