public class SnapshotService extends Object
Constructor and Description |
---|
SnapshotService(SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
void |
clearAllRevisions()
Clear all the revisions of persistence store of Siddhi App
|
byte[] |
fullSnapshot() |
static ThreadLocal<Boolean> |
getSkipStateStorageThreadLocal() |
Map<String,StateHolder> |
getStateHolderMap(String partitionId,
String queryName) |
ConcurrentHashMap<String,io.siddhi.core.util.snapshot.SnapshotService.PartitionIdStateHolder> |
getStates() |
IncrementalSnapshot |
incrementalSnapshot() |
Map<String,Object> |
queryState(String queryName) |
void |
restore(byte[] snapshot) |
void |
restore(Map<String,Map<String,Map<String,Map<Long,Map<IncrementalSnapshotInfo,byte[]>>>>> snapshot) |
String |
restoreLastRevision() |
void |
restoreRevision(String revision) |
public SnapshotService(SiddhiAppContext siddhiAppContext)
public static ThreadLocal<Boolean> getSkipStateStorageThreadLocal()
public ConcurrentHashMap<String,io.siddhi.core.util.snapshot.SnapshotService.PartitionIdStateHolder> getStates()
public Map<String,StateHolder> getStateHolderMap(String partitionId, String queryName)
public byte[] fullSnapshot()
public IncrementalSnapshot incrementalSnapshot()
public void restore(byte[] snapshot) throws CannotRestoreSiddhiAppStateException
public void restore(Map<String,Map<String,Map<String,Map<Long,Map<IncrementalSnapshotInfo,byte[]>>>>> snapshot) throws CannotRestoreSiddhiAppStateException
public void restoreRevision(String revision) throws CannotRestoreSiddhiAppStateException
public String restoreLastRevision() throws CannotRestoreSiddhiAppStateException
public void clearAllRevisions() throws CannotClearSiddhiAppStateException
Copyright © 2021. All rights reserved.