alluxio.master.file.meta

Class TtlBucket

java.lang.Object

alluxio.master.file.meta.TtlBucket

All Implemented Interfaces:

Comparable<TtlBucket>

@ThreadSafe
public final class TtlBucket
extends Object
implements Comparable<TtlBucket>

A bucket with all inodes whose ttl value lies in the bucket's time interval. The bucket's time interval starts at a certain time and lasts for PropertyKey.MASTER_TTL_CHECKER_INTERVAL_MS.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_RETRY_ATTEMPTS

Constructor Summary

Constructors

Constructor and Description
TtlBucket(long startTimeMs) Creates a new instance of TtlBucket.

Method Summary

Modifier and Type	Method and Description
void	addInode(Inode inode) Adds an inode with default num of retry attempt to expire.
void	addInode(Inode inode, int numOfRetry) Adds an inode to the bucket with a specific left retry number.
int	compareTo(TtlBucket ttlBucket) Compares this bucket's TTL interval start time to that of another bucket.
boolean	equals(Object o) Compares to a specific object.
Collection<Map.Entry<Long,Integer>>	getInodeExpiries() Get collection of inode to its left ttl process retry attempts.
Collection<Long>	getInodeIds()
long	getTtlIntervalEndTimeMs()
static long	getTtlIntervalMs()
long	getTtlIntervalStartTimeMs()
int	hashCode() Returns the hash code for the TtlBucket.
void	removeInode(InodeView inode) Removes an inode from the bucket.
int	size()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_RETRY_ATTEMPTS

public static final int DEFAULT_RETRY_ATTEMPTS

See Also:

Constant Field Values

Constructor Detail

TtlBucket

public TtlBucket(long startTimeMs)

Creates a new instance of TtlBucket.

Parameters:

startTimeMs - the start time to use

Method Detail

getTtlIntervalStartTimeMs

public long getTtlIntervalStartTimeMs()

Returns:

the ttl interval start time in milliseconds

getTtlIntervalEndTimeMs

public long getTtlIntervalEndTimeMs()

Returns:

the ttl interval end time in milliseconds

getTtlIntervalMs

public static long getTtlIntervalMs()

Returns:

the ttl interval in milliseconds

getInodeIds

public Collection<Long> getInodeIds()

Returns:

an unmodifiable view of all inodes ids in the bucket

getInodeExpiries

public Collection<Map.Entry<Long,Integer>> getInodeExpiries()

Get collection of inode to its left ttl process retry attempts.

Returns:

collection of inode to its left ttl process retry attempts

addInode

public void addInode(Inode inode)

Adds an inode with default num of retry attempt to expire.

Parameters:

inode -

addInode

public void addInode(Inode inode,
                     int numOfRetry)

Adds an inode to the bucket with a specific left retry number.

Parameters:

inode - the inode to be added

numOfRetry - num of retries left when added to the ttlbucket

removeInode

public void removeInode(InodeView inode)

Removes an inode from the bucket.

Parameters:

inode - the inode to be removed

size

public int size()

Returns:

the number of inodes in the bucket

compareTo

public int compareTo(TtlBucket ttlBucket)

Compares this bucket's TTL interval start time to that of another bucket.

Specified by:

compareTo in interface Comparable<TtlBucket>

Parameters:

ttlBucket - the bucket to be compared to

Returns:

0 when return values of getTtlIntervalStartTimeMs() from the two buckets are the same, -1 when that value of current instance is smaller, otherwise, 1

equals

public boolean equals(Object o)

Compares to a specific object.

Overrides:

equals in class Object

Parameters:

o - the object to compare

Returns:

true if object is also TtlBucket and represents the same TtlIntervalStartTime

hashCode

public int hashCode()

Returns the hash code for the TtlBucket.

Overrides:

hashCode in class Object

Returns:

The hash code value for this TtlBucket