alluxio.master.file.meta

Class CheckpointedIdHashSet

java.lang.Object

alluxio.collections.DelegatingSet<java.lang.Long>

alluxio.master.file.meta.CheckpointedIdHashSet

All Implemented Interfaces:

Checkpointed, java.lang.Iterable<java.lang.Long>, java.util.Collection<java.lang.Long>, java.util.Set<java.lang.Long>

Direct Known Subclasses:

PinnedInodeFileIds, ReplicationLimitedFileIds, ToBePersistedFileIds

@ThreadSafe
public abstract class CheckpointedIdHashSet
extends DelegatingSet<java.lang.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)
void	writeToCheckpoint(java.io.OutputStream output)

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(java.io.OutputStream output)
                       throws java.io.IOException

Specified by:

writeToCheckpoint in interface Checkpointed

Throws:

java.io.IOException

restoreFromCheckpoint

public void restoreFromCheckpoint(CheckpointInputStream input)
                           throws java.io.IOException

Specified by:

restoreFromCheckpoint in interface Checkpointed

Throws:

java.io.IOException