T
- The value type of the set.public class TimelineHashSet<T> extends Object implements Set<T>
Constructor and Description |
---|
TimelineHashSet(SnapshotRegistry snapshotRegistry,
int expectedSize) |
Modifier and Type | Method and Description |
---|---|
boolean |
add(T newValue) |
boolean |
addAll(Collection<? extends T> collection) |
void |
clear() |
boolean |
contains(Object key) |
boolean |
contains(Object object,
long epoch) |
boolean |
containsAll(Collection<?> collection) |
boolean |
equals(Object o) |
void |
executeRevert(long targetEpoch,
org.apache.kafka.timeline.Delta delta)
Revert to the target epoch.
|
int |
hashCode() |
boolean |
isEmpty() |
boolean |
isEmpty(long epoch) |
Iterator<T> |
iterator() |
Iterator<T> |
iterator(long epoch) |
boolean |
remove(Object value) |
boolean |
removeAll(Collection<?> collection) |
void |
reset()
Reverts to the initial value.
|
boolean |
retainAll(Collection<?> collection) |
int |
size() |
int |
size(long epoch) |
Object[] |
toArray() |
<R> R[] |
toArray(R[] a) |
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
spliterator
parallelStream, removeIf, stream
public TimelineHashSet(SnapshotRegistry snapshotRegistry, int expectedSize)
public int size()
public int size(long epoch)
public boolean isEmpty()
public boolean isEmpty(long epoch)
public boolean contains(Object key)
public boolean contains(Object object, long epoch)
public Object[] toArray()
public <R> R[] toArray(R[] a)
public boolean add(T newValue)
public boolean remove(Object value)
public boolean containsAll(Collection<?> collection)
containsAll
in interface Collection<T>
containsAll
in interface Set<T>
public boolean addAll(Collection<? extends T> collection)
public boolean retainAll(Collection<?> collection)
public boolean removeAll(Collection<?> collection)
public void clear()
public int hashCode()
public boolean equals(Object o)
public void executeRevert(long targetEpoch, org.apache.kafka.timeline.Delta delta)
targetEpoch
- The epoch to revert to.delta
- The delta associated with this epoch for this object.public void reset()