Package | Description |
---|---|
io.siddhi.core.util.persistence | |
io.siddhi.core.util.persistence.util | |
io.siddhi.core.util.snapshot |
Modifier and Type | Method and Description |
---|---|
List<IncrementalSnapshotInfo> |
IncrementalPersistenceStore.getListOfRevisionsToLoad(long restoreTime,
String siddhiAppName) |
List<IncrementalSnapshotInfo> |
IncrementalFileSystemPersistenceStore.getListOfRevisionsToLoad(long restoreTime,
String siddhiAppName) |
Modifier and Type | Method and Description |
---|---|
byte[] |
IncrementalPersistenceStore.load(IncrementalSnapshotInfo snapshotInfo) |
byte[] |
IncrementalFileSystemPersistenceStore.load(IncrementalSnapshotInfo snapshotInfo) |
void |
IncrementalPersistenceStore.save(IncrementalSnapshotInfo snapshotInfo,
byte[] snapshot) |
void |
IncrementalFileSystemPersistenceStore.save(IncrementalSnapshotInfo snapshotInfo,
byte[] snapshot) |
Modifier and Type | Method and Description |
---|---|
static IncrementalSnapshotInfo |
PersistenceHelper.convertRevision(String revision) |
Modifier and Type | Method and Description |
---|---|
void |
SnapshotService.restore(Map<String,Map<String,Map<String,Map<Long,Map<IncrementalSnapshotInfo,byte[]>>>>> snapshot) |
Constructor and Description |
---|
AsyncIncrementalSnapshotPersistor(byte[] snapshots,
IncrementalPersistenceStore incrementalPersistenceStore,
IncrementalSnapshotInfo snapshotInfo) |
Copyright © 2019. All rights reserved.