alluxio.master.file.meta

Class CheckpointedIdHashSet

java.lang.Object

alluxio.collections.DelegatingSet<Long>

alluxio.master.file.meta.CheckpointedIdHashSet

All Implemented Interfaces:

Checkpointed, Iterable<Long>, Collection<Long>, Set<Long>

Direct Known Subclasses:

PinnedInodeFileIds, ReplicationLimitedFileIds, ToBePersistedFileIds

@ThreadSafe
public abstract class CheckpointedIdHashSet
extends DelegatingSet<Long>
implements Checkpointed

A concurrent hash set of Long values that supports writing to and restoring from checkpoints.

Constructor Summary

Constructors

Constructor and Description
CheckpointedIdHashSet() Constructs a new checkpointed id hash set.

Method Summary

Modifier and Type	Method and Description
void	restoreFromCheckpoint(CheckpointInputStream input) Restores state from a checkpoint.
void	writeToCheckpoint(OutputStream output) Writes a checkpoint of all state to the given output stream.

Methods inherited from class alluxio.collections.DelegatingSet

add, addAll, clear, contains, containsAll, equals, forEach, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.master.journal.checkpoint.Checkpointed

getCheckpointName

Constructor Detail

CheckpointedIdHashSet

public CheckpointedIdHashSet()

Constructs a new checkpointed id hash set.

Method Detail

writeToCheckpoint

public void writeToCheckpoint(OutputStream output)
                       throws IOException

Description copied from interface: Checkpointed

Writes a checkpoint of all state to the given output stream. Implementations should make an effort to throw InterruptedException if they get interrupted while running.

Specified by:

writeToCheckpoint in interface Checkpointed

Parameters:

output - the output stream to write to

Throws:

IOException

restoreFromCheckpoint

public void restoreFromCheckpoint(CheckpointInputStream input)
                           throws IOException

Description copied from interface: Checkpointed

Restores state from a checkpoint.

Specified by:

restoreFromCheckpoint in interface Checkpointed

Parameters:

input - an input stream with checkpoint data

Throws:

IOException