public static final Duration DEFAULT_SHARD_TRANSACTION_IDLE_TIMEOUT = Duration.create(10, TimeUnit.MINUTES);
public static final int DEFAULT_OPERATION_TIMEOUT_IN_MS = 5000;
public static final int DEFAULT_SHARD_TX_COMMIT_TIMEOUT_IN_SECONDS = 30;
- public static final int DEFAULT_JOURNAL_RECOVERY_BATCH_SIZE = 1000;
+ public static final int DEFAULT_JOURNAL_RECOVERY_BATCH_SIZE = 1;
public static final int DEFAULT_SNAPSHOT_BATCH_COUNT = 20000;
public static final int DEFAULT_HEARTBEAT_INTERVAL_IN_MILLIS = 500;
public static final int DEFAULT_ISOLATED_LEADER_CHECK_INTERVAL_IN_MILLIS = DEFAULT_HEARTBEAT_INTERVAL_IN_MILLIS * 10;
public static final long DEFAULT_SHARD_COMMIT_QUEUE_EXPIRY_TIMEOUT_IN_MS = TimeUnit.MILLISECONDS.convert(2, TimeUnit.MINUTES);
public static final int DEFAULT_SHARD_SNAPSHOT_CHUNK_SIZE = 2048000;
- private static final Set<String> globalDatastoreTypes = Sets.newConcurrentHashSet();
+ private static final Set<String> globalDatastoreNames = Sets.newConcurrentHashSet();
private InMemoryDOMDataStoreConfigProperties dataStoreProperties;
private Duration shardTransactionIdleTimeout = DatastoreContext.DEFAULT_SHARD_TRANSACTION_IDLE_TIMEOUT;
private boolean transactionDebugContextEnabled = false;
private String shardManagerPersistenceId;
- public static Set<String> getGlobalDatastoreTypes() {
- return globalDatastoreTypes;
+ public static Set<String> getGlobalDatastoreNames() {
+ return globalDatastoreNames;
}
private DatastoreContext() {
return logicalStoreType;
}
- /**
- * @deprecated Use {@link #getDataStoreName()} or {@link #getLogicalStoreType()} instead.
- */
- @Deprecated
- public String getDataStoreType(){
- return getDataStoreName();
- }
-
public long getTransactionCreationInitialRateLimit() {
return transactionCreationInitialRateLimit;
}
}
private void setSnapshotDataThresholdPercentage(int shardSnapshotDataThresholdPercentage) {
+ Preconditions.checkArgument(shardSnapshotDataThresholdPercentage >= 0
+ && shardSnapshotDataThresholdPercentage <= 100);
raftConfig.setSnapshotDataThresholdPercentage(shardSnapshotDataThresholdPercentage);
}
return this;
}
- /**
- * @deprecated Use {@link #logicalStoreType(LogicalDatastoreType)} or {@link #dataStoreName(String)}.
- */
- @Deprecated
- public Builder dataStoreType(String dataStoreType){
- return dataStoreName(dataStoreType);
- }
-
public Builder logicalStoreType(LogicalDatastoreType logicalStoreType){
datastoreContext.logicalStoreType = Preconditions.checkNotNull(logicalStoreType);
maxShardDataChangeListenerQueueSize, maxShardDataStoreExecutorQueueSize);
if(datastoreContext.dataStoreName != null) {
- globalDatastoreTypes.add(datastoreContext.dataStoreName);
+ globalDatastoreNames.add(datastoreContext.dataStoreName);
}
return datastoreContext;