// in-memory journal can use before it needs to snapshot
private int snapshotDataThresholdPercentage = 12;
+ private int snaphotChunkSize = SNAPSHOT_CHUNK_SIZE;
+
private long electionTimeoutFactor = 2;
public void setHeartBeatInterval(FiniteDuration heartBeatInterval) {
this.snapshotDataThresholdPercentage = snapshotDataThresholdPercentage;
}
+ public void setSnaphotChunkSize(int snaphotChunkSize) {
+ this.snaphotChunkSize = snaphotChunkSize;
+ }
+
public void setJournalRecoveryLogBatchSize(int journalRecoveryLogBatchSize) {
this.journalRecoveryLogBatchSize = journalRecoveryLogBatchSize;
}
@Override
public int getSnapshotChunkSize() {
- return SNAPSHOT_CHUNK_SIZE;
+ return snaphotChunkSize;
}
@Override