alluxio.heartbeat

Class CronExpressionIntervalSupplier

java.lang.Object

alluxio.heartbeat.CronExpressionIntervalSupplier

All Implemented Interfaces:

SleepIntervalSupplier

public class CronExpressionIntervalSupplier
extends Object
implements SleepIntervalSupplier

Calculate the next interval by given cron expression.

Constructor Summary

Constructors

Constructor and Description
CronExpressionIntervalSupplier(org.apache.logging.log4j.core.util.CronExpression cronExpression, long fixedInterval) Constructs a new CronExpressionIntervalSupplier.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
long	getNextInterval(long previousTickedMs, long nowTimeStampMillis) Gets the next interval for sleeping.
long	getRunLimit(long previousTickedMs) Gets the run limit from previous ticked.
int	hashCode()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CronExpressionIntervalSupplier

public CronExpressionIntervalSupplier(org.apache.logging.log4j.core.util.CronExpression cronExpression,
                                      long fixedInterval)

Constructs a new CronExpressionIntervalSupplier.

Parameters:

cronExpression - the cron expression

fixedInterval - the fixed interval

Method Detail

getNextInterval

public long getNextInterval(long previousTickedMs,
                            long nowTimeStampMillis)

Description copied from interface: SleepIntervalSupplier

Gets the next interval for sleeping.

Specified by:

getNextInterval in interface SleepIntervalSupplier

Parameters:

previousTickedMs - previous ticked time stamp in millisecond

nowTimeStampMillis - current time stamp in millisecond

Returns:

the interval to sleep starting from now before next time the timer triggers

getRunLimit

public long getRunLimit(long previousTickedMs)

Description copied from interface: SleepIntervalSupplier

Gets the run limit from previous ticked.

Specified by:

getRunLimit in interface SleepIntervalSupplier

Parameters:

previousTickedMs - previous ticked time stamp in millisecond

Returns:

the run limit

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object