public class RollupScheduler
extends java.lang.Object
Constructor and Description |
---|
RollupScheduler(BlueCollectionOnDisk<?> collection) |
Modifier and Type | Method and Description |
---|---|
void |
forceScheduleRollups() |
java.util.Map<RollupTarget,java.lang.Long> |
getRollupTimes() |
long |
getScheduledRollupTime(RollupTarget target) |
void |
reportRead(RollupTarget rollupTarget,
long timeMillis) |
void |
reportReads(java.util.List<? extends RollupTarget> rollupTargets) |
void |
reportWrite(RollupTarget rollupTarget,
long timeMillis) |
void |
reportWrites(java.util.List<? extends RollupTarget> rollupTargets) |
protected java.util.List<RollupTarget> |
rollupTargetsReadyForRollup() |
protected java.util.List<RollupTarget> |
rollupTargetsReadyForRollup(int maxCount) |
protected void |
scheduleLimitedReadyRollups() |
protected void |
scheduleReadyRollups(int maxRollupsToSchedule) |
protected void |
scheduleRollup(RollupTarget target) |
void |
setRollupTime(RollupTarget rollupTarget,
long timeMillis) |
void |
start() |
public RollupScheduler(BlueCollectionOnDisk<?> collection)
public void start()
public void reportReads(java.util.List<? extends RollupTarget> rollupTargets)
public void reportWrites(java.util.List<? extends RollupTarget> rollupTargets)
public void reportRead(RollupTarget rollupTarget, long timeMillis)
public void reportWrite(RollupTarget rollupTarget, long timeMillis)
public void setRollupTime(RollupTarget rollupTarget, long timeMillis)
public long getScheduledRollupTime(RollupTarget target)
protected void scheduleLimitedReadyRollups()
protected void scheduleReadyRollups(int maxRollupsToSchedule)
public void forceScheduleRollups()
protected java.util.List<RollupTarget> rollupTargetsReadyForRollup(int maxCount)
protected java.util.List<RollupTarget> rollupTargetsReadyForRollup()
protected void scheduleRollup(RollupTarget target)
public java.util.Map<RollupTarget,java.lang.Long> getRollupTimes()