| Package | Description |
|---|---|
| com.hazelcast.spi.hotrestart |
SPI for the Hot Restart store.
|
| com.hazelcast.spi.hotrestart.impl |
Implementation code for the Hot Restart store SPI.
|
| com.hazelcast.spi.hotrestart.impl.gc |
Implementation of garbage collection for the
Hot Restart store.
|
| Modifier and Type | Method and Description |
|---|---|
void |
HotRestartStore.hotRestart(boolean failIfAnyData,
int storeCount,
com.hazelcast.internal.util.concurrent.ConcurrentConveyor<RestartItem>[] keyConveyors,
com.hazelcast.internal.util.concurrent.ConcurrentConveyor<RestartItem> keyHandleConveyor,
com.hazelcast.internal.util.concurrent.ConcurrentConveyor<RestartItem>[] valueConveyors)
Performs hot restart: reads the data from persistent storage and pushes it
to its associated
RamStoreRegistry. |
| Modifier and Type | Class and Description |
|---|---|
static class |
RestartItem.WithSetOfKeyHandle
Used both for the "remove null keys" item and for the "submitter gone" item.
|
| Modifier and Type | Field and Description |
|---|---|
static RestartItem |
RestartItem.END |
| Modifier and Type | Method and Description |
|---|---|
static RestartItem |
RestartItem.clearedItem(ChunkFileRecord rec)
Constructs an item that corresponds to a cleared record (interred by a prefix tombstone).
|
| Modifier and Type | Method and Description |
|---|---|
void |
ConcurrentHotRestartStore.hotRestart(boolean failIfAnyData,
int storeCount,
com.hazelcast.internal.util.concurrent.ConcurrentConveyor<RestartItem>[] keyConveyors,
com.hazelcast.internal.util.concurrent.ConcurrentConveyor<RestartItem> keyHandleConveyor,
com.hazelcast.internal.util.concurrent.ConcurrentConveyor<RestartItem>[] valueConveyors) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
Rebuilder.accept(RestartItem item)
Called when encountering a record which is not interred by a prefix tombstone.
|
void |
Rebuilder.acceptCleared(RestartItem item)
Called when encountering a record which is interred by a prefix tombstone.
|
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.