public class IncrementalFileSystemPersistenceStore extends Object implements IncrementalPersistenceStore
Constructor and Description |
---|
IncrementalFileSystemPersistenceStore() |
IncrementalFileSystemPersistenceStore(String storageFilePath) |
Modifier and Type | Method and Description |
---|---|
void |
clearAllRevisions(String siddhiAppName)
Clear all the revisions of Persistence Store
of given Siddhi App
|
String |
getLastRevision(String siddhiAppName) |
List<IncrementalSnapshotInfo> |
getListOfRevisionsToLoad(long restoreTime,
String siddhiAppName) |
byte[] |
load(IncrementalSnapshotInfo snapshotInfo) |
void |
save(IncrementalSnapshotInfo snapshotInfo,
byte[] snapshot) |
void |
setProperties(Map properties) |
public IncrementalFileSystemPersistenceStore()
public IncrementalFileSystemPersistenceStore(String storageFilePath)
public void save(IncrementalSnapshotInfo snapshotInfo, byte[] snapshot)
save
in interface IncrementalPersistenceStore
public void setProperties(Map properties)
setProperties
in interface IncrementalPersistenceStore
public byte[] load(IncrementalSnapshotInfo snapshotInfo)
load
in interface IncrementalPersistenceStore
public List<IncrementalSnapshotInfo> getListOfRevisionsToLoad(long restoreTime, String siddhiAppName)
getListOfRevisionsToLoad
in interface IncrementalPersistenceStore
public String getLastRevision(String siddhiAppName)
getLastRevision
in interface IncrementalPersistenceStore
public void clearAllRevisions(String siddhiAppName)
IncrementalPersistenceStore
clearAllRevisions
in interface IncrementalPersistenceStore
Copyright © 2019. All rights reserved.