K
- The key type of the set.V
- The value type of the set.public class TimelineHashMap<K,V> extends Object implements Map<K,V>
Constructor and Description |
---|
TimelineHashMap(SnapshotRegistry snapshotRegistry,
int expectedSize) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
boolean |
containsKey(Object key) |
boolean |
containsKey(Object key,
long epoch) |
boolean |
containsValue(Object value) |
Set<Map.Entry<K,V>> |
entrySet() |
Set<Map.Entry<K,V>> |
entrySet(long epoch) |
boolean |
equals(Object o) |
void |
executeRevert(long targetEpoch,
org.apache.kafka.timeline.Delta delta)
Revert to the target epoch.
|
V |
get(Object key) |
V |
get(Object key,
long epoch) |
int |
hashCode() |
boolean |
isEmpty() |
boolean |
isEmpty(long epoch) |
Set<K> |
keySet() |
Set<K> |
keySet(long epoch) |
V |
put(K key,
V value) |
void |
putAll(Map<? extends K,? extends V> map) |
V |
remove(Object key) |
void |
reset()
Reverts to the initial value.
|
int |
size() |
int |
size(long epoch) |
Collection<V> |
values() |
Collection<V> |
values(long epoch) |
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, putIfAbsent, remove, replace, replace, replaceAll
public TimelineHashMap(SnapshotRegistry snapshotRegistry, int expectedSize)
public int size(long epoch)
public boolean isEmpty(long epoch)
public boolean containsKey(Object key)
containsKey
in interface Map<K,V>
public boolean containsKey(Object key, long epoch)
public boolean containsValue(Object value)
containsValue
in interface Map<K,V>
public Collection<V> values(long epoch)
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()