public class CheckpointManager
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
CheckpointManager.CheckpointAction |
class |
CheckpointManager.CheckpointExecutor |
static class |
CheckpointManager.CheckpointStats |
Constructor and Description |
---|
CheckpointManager(DataspaceStore store) |
public CheckpointManager(DataspaceStore store)
public void setCheckpointInterval(java.lang.String value)
public void setCheckpointIntervalRepeat(java.lang.String value)
public void setCheckpointIntervalCritical(java.lang.String value)
public void setCheckpointLockTimeout1(java.lang.String value)
public void setCheckpointLockTimeout2(java.lang.String value)
public long getLogSizeMax()
public void setLogSizeMax(long logSizeMax)
public void setLogSizeCritical(long logSizeCritical)
public CheckpointManager.CheckpointStats getTotalStats()
public long getCheckpointInterval()
public long getCheckpointIntervalRepeat()
public long getCheckpointIntervalCritical()
public long getLogSizeCritical()
public long getCheckpointLockTimeout1()
public long getCheckpointLockTimeout2()
public long getLastCheckpointAttemptTimestamp()
public long getLastCheckpointSuccessfulTimestamp()
public long getNextCheckpointTimestamp()
public void start()
public void stop()
public void join()
public com.streamscape.ds.parser.statement.Statement getCheckpointStatement(boolean withDefrag, boolean auto, long lockTimeout, CheckpointManager.CheckpointStats.CheckpointAttempt checkpointAttempt)
public long getRecoveryLogSize()
public long getLogSize()
public boolean enqueueCheckpointMVCC()
public void enqueueCheckpointRequired()
public void setCheckpointManagedByMVCC()
public void setLastCheckpointAttemptTimestamp(boolean auto)
public void updateCheckpointResult(com.streamscape.ds.result.Result result)
public void addCheckpointAttempt(CheckpointManager.CheckpointStats.CheckpointAttempt checkpointAttempt)
public boolean isCheckpointManagedByMVCC()
public boolean isCheckpointRequired()
public boolean isCheckpointInProgress()
public CheckpointManager.CheckpointExecutor getCheckpointExecutor()
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.