private final class ExponentialCompactionWindowFactory.Window extends CompactionWindow
Modifier and Type | Field and Description |
---|---|
private long |
divPosition
A timestamp t is within the window iff t / size == divPosition.
|
private long |
maxTierAgeCutoff
Will not promote to next tier for window before it.
|
private long |
windowMillis
How big a range of timestamps fit inside the window in milliseconds.
|
Constructor and Description |
---|
Window(long baseWindowMillis,
long divPosition,
long maxTierAgeCutoff) |
Modifier and Type | Method and Description |
---|---|
int |
compareToTimestamp(long timestamp)
Compares the window to a timestamp.
|
long |
endMillis()
Exclusive upper bound
|
ExponentialCompactionWindowFactory.Window |
nextEarlierWindow()
Move to the new window of the same tier or of the next tier, which represents an earlier time
span.
|
long |
startMillis()
Inclusive lower bound
|
toString
private final long maxTierAgeCutoff
private final long windowMillis
private final long divPosition
public Window(long baseWindowMillis, long divPosition, long maxTierAgeCutoff)
public int compareToTimestamp(long timestamp)
CompactionWindow
compareToTimestamp
in class CompactionWindow
timestamp
- the timestamp to compare.public ExponentialCompactionWindowFactory.Window nextEarlierWindow()
CompactionWindow
nextEarlierWindow
in class CompactionWindow
public long startMillis()
CompactionWindow
startMillis
in class CompactionWindow
public long endMillis()
CompactionWindow
endMillis
in class CompactionWindow
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.