alluxio.master.file.meta

Class TtlBucketList

java.lang.Object

alluxio.master.file.meta.TtlBucketList

@ThreadSafe
public final class TtlBucketList
extends Object

A list of non-empty TtlBuckets sorted by ttl interval start time of each bucket.

Two adjacent buckets may not have adjacent intervals since there may be no inodes with ttl value in the skipped intervals.

Constructor Summary

Constructors

Constructor and Description
TtlBucketList() Creates a new list of TtlBuckets.

Method Summary

Modifier and Type	Method and Description
Set<TtlBucket>	getExpiredBuckets(long time) Retrieves buckets whose ttl interval has expired before the specified time, that is, the bucket's interval start time should be less than or equal to (specified time - ttl interval).
void	insert(Inode<?> inode) Inserts an Inode to the appropriate bucket where its ttl end time lies in the bucket's interval, if no appropriate bucket exists, a new bucket will be created to contain this inode, if ttl value is Constants.NO_TTL, the inode won't be inserted to any buckets and nothing will happen.
void	remove(Inode<?> inode) Removes a inode from the bucket containing it if the inode is in one of the buckets, otherwise, do nothing.
void	removeBuckets(Set<TtlBucket> buckets) Removes all buckets in the set.

Methods inherited from class java.lang.Object

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

Constructor Detail

TtlBucketList

public TtlBucketList()

Creates a new list of TtlBuckets.

Method Detail

insert

public void insert(Inode<?> inode)

Inserts an Inode to the appropriate bucket where its ttl end time lies in the bucket's interval, if no appropriate bucket exists, a new bucket will be created to contain this inode, if ttl value is Constants.NO_TTL, the inode won't be inserted to any buckets and nothing will happen.

Parameters:

inode - the inode to be inserted

remove

public void remove(Inode<?> inode)

Removes a inode from the bucket containing it if the inode is in one of the buckets, otherwise, do nothing.

Assume that no inode in the buckets has ttl value that equals Constants.NO_TTL. If a inode with valid ttl value is inserted to the buckets and its ttl value is going to be set to Constants.NO_TTL later, be sure to remove the inode from the buckets first.

Parameters:

inode - the inode to be removed

getExpiredBuckets

public Set<TtlBucket> getExpiredBuckets(long time)

Retrieves buckets whose ttl interval has expired before the specified time, that is, the bucket's interval start time should be less than or equal to (specified time - ttl interval). The returned set is backed by the internal set.

Parameters:

time - the expiration time

Returns:

a set of expired buckets or an empty set if no buckets have expired

removeBuckets

public void removeBuckets(Set<TtlBucket> buckets)

Removes all buckets in the set.

Parameters:

buckets - a set of buckets to be removed