in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeDescriptor.java [390:700]
private void loadRatisConsensusConfig(TrimProperties properties) {
conf.setDataRegionRatisConsensusLogAppenderBufferSize(
Long.parseLong(
properties.getProperty(
"data_region_ratis_log_appender_buffer_size_max",
String.valueOf(conf.getDataRegionRatisConsensusLogAppenderBufferSize()))));
conf.setConfigNodeRatisConsensusLogAppenderBufferSize(
Long.parseLong(
properties.getProperty(
"config_node_ratis_log_appender_buffer_size_max",
String.valueOf(conf.getConfigNodeRatisConsensusLogAppenderBufferSize()))));
conf.setSchemaRegionRatisConsensusLogAppenderBufferSize(
Long.parseLong(
properties.getProperty(
"schema_region_ratis_log_appender_buffer_size_max",
String.valueOf(conf.getSchemaRegionRatisConsensusLogAppenderBufferSize()))));
conf.setDataRegionRatisSnapshotTriggerThreshold(
Long.parseLong(
properties.getProperty(
"data_region_ratis_snapshot_trigger_threshold",
String.valueOf(conf.getDataRegionRatisSnapshotTriggerThreshold()))));
conf.setConfigNodeRatisSnapshotTriggerThreshold(
Long.parseLong(
properties.getProperty(
"config_node_ratis_snapshot_trigger_threshold",
String.valueOf(conf.getConfigNodeRatisSnapshotTriggerThreshold()))));
conf.setSchemaRegionRatisSnapshotTriggerThreshold(
Long.parseLong(
properties.getProperty(
"schema_region_ratis_snapshot_trigger_threshold",
String.valueOf(conf.getSchemaRegionRatisSnapshotTriggerThreshold()))));
conf.setDataRegionRatisLogUnsafeFlushEnable(
Boolean.parseBoolean(
properties.getProperty(
"data_region_ratis_log_unsafe_flush_enable",
String.valueOf(conf.isDataRegionRatisLogUnsafeFlushEnable()))));
conf.setConfigNodeRatisLogUnsafeFlushEnable(
Boolean.parseBoolean(
properties.getProperty(
"config_node_ratis_log_unsafe_flush_enable",
String.valueOf(conf.isConfigNodeRatisLogUnsafeFlushEnable()))));
conf.setSchemaRegionRatisLogUnsafeFlushEnable(
Boolean.parseBoolean(
properties.getProperty(
"schema_region_ratis_log_unsafe_flush_enable",
String.valueOf(conf.isSchemaRegionRatisLogUnsafeFlushEnable()))));
conf.setDataRegionRatisLogSegmentSizeMax(
Long.parseLong(
properties.getProperty(
"data_region_ratis_log_segment_size_max_in_byte",
String.valueOf(conf.getDataRegionRatisLogSegmentSizeMax()))));
conf.setConfigNodeRatisLogSegmentSizeMax(
Long.parseLong(
properties.getProperty(
"config_node_ratis_log_segment_size_max_in_byte",
String.valueOf(conf.getConfigNodeRatisLogSegmentSizeMax()))));
conf.setSchemaRegionRatisLogSegmentSizeMax(
Long.parseLong(
properties.getProperty(
"schema_region_ratis_log_segment_size_max_in_byte",
String.valueOf(conf.getSchemaRegionRatisLogSegmentSizeMax()))));
conf.setConfigNodeSimpleConsensusLogSegmentSizeMax(
Long.parseLong(
properties.getProperty(
"config_node_simple_consensus_log_segment_size_max_in_byte",
String.valueOf(conf.getConfigNodeSimpleConsensusLogSegmentSizeMax()))));
conf.setDataRegionRatisGrpcFlowControlWindow(
Long.parseLong(
properties.getProperty(
"data_region_ratis_grpc_flow_control_window",
String.valueOf(conf.getDataRegionRatisGrpcFlowControlWindow()))));
conf.setConfigNodeRatisGrpcFlowControlWindow(
Long.parseLong(
properties.getProperty(
"config_node_ratis_grpc_flow_control_window",
String.valueOf(conf.getConfigNodeRatisGrpcFlowControlWindow()))));
conf.setSchemaRegionRatisGrpcFlowControlWindow(
Long.parseLong(
properties.getProperty(
"schema_region_ratis_grpc_flow_control_window",
String.valueOf(conf.getSchemaRegionRatisGrpcFlowControlWindow()))));
conf.setDataRegionRatisGrpcLeaderOutstandingAppendsMax(
Integer.parseInt(
properties.getProperty(
"data_region_ratis_grpc_leader_outstanding_appends_max",
String.valueOf(conf.getDataRegionRatisGrpcLeaderOutstandingAppendsMax()))));
conf.setConfigNodeRatisGrpcLeaderOutstandingAppendsMax(
Integer.parseInt(
properties.getProperty(
"config_node_ratis_grpc_leader_outstanding_appends_max",
String.valueOf(conf.getConfigNodeRatisGrpcLeaderOutstandingAppendsMax()))));
conf.setSchemaRegionRatisGrpcLeaderOutstandingAppendsMax(
Integer.parseInt(
properties.getProperty(
"schema_region_ratis_grpc_leader_outstanding_appends_max",
String.valueOf(conf.getSchemaRegionRatisGrpcLeaderOutstandingAppendsMax()))));
conf.setDataRegionRatisLogForceSyncNum(
Integer.parseInt(
properties.getProperty(
"data_region_ratis_log_force_sync_num",
String.valueOf(conf.getDataRegionRatisLogForceSyncNum()))));
conf.setConfigNodeRatisLogForceSyncNum(
Integer.parseInt(
properties.getProperty(
"config_node_ratis_log_force_sync_num",
String.valueOf(conf.getConfigNodeRatisLogForceSyncNum()))));
conf.setSchemaRegionRatisLogForceSyncNum(
Integer.parseInt(
properties.getProperty(
"schema_region_ratis_log_force_sync_num",
String.valueOf(conf.getSchemaRegionRatisLogForceSyncNum()))));
conf.setDataRegionRatisRpcLeaderElectionTimeoutMinMs(
Long.parseLong(
properties.getProperty(
"data_region_ratis_rpc_leader_election_timeout_min_ms",
String.valueOf(conf.getDataRegionRatisRpcLeaderElectionTimeoutMinMs()))));
conf.setConfigNodeRatisRpcLeaderElectionTimeoutMinMs(
Long.parseLong(
properties.getProperty(
"config_node_ratis_rpc_leader_election_timeout_min_ms",
String.valueOf(conf.getConfigNodeRatisRpcLeaderElectionTimeoutMinMs()))));
conf.setSchemaRegionRatisRpcLeaderElectionTimeoutMinMs(
Long.parseLong(
properties.getProperty(
"schema_region_ratis_rpc_leader_election_timeout_min_ms",
String.valueOf(conf.getSchemaRegionRatisRpcLeaderElectionTimeoutMinMs()))));
conf.setDataRegionRatisRpcLeaderElectionTimeoutMaxMs(
Long.parseLong(
properties.getProperty(
"data_region_ratis_rpc_leader_election_timeout_max_ms",
String.valueOf(conf.getDataRegionRatisRpcLeaderElectionTimeoutMaxMs()))));
conf.setConfigNodeRatisRpcLeaderElectionTimeoutMaxMs(
Long.parseLong(
properties.getProperty(
"config_node_ratis_rpc_leader_election_timeout_max_ms",
String.valueOf(conf.getConfigNodeRatisRpcLeaderElectionTimeoutMaxMs()))));
conf.setSchemaRegionRatisRpcLeaderElectionTimeoutMaxMs(
Long.parseLong(
properties.getProperty(
"schema_region_ratis_rpc_leader_election_timeout_max_ms",
String.valueOf(conf.getSchemaRegionRatisRpcLeaderElectionTimeoutMaxMs()))));
conf.setConfigNodeRatisRequestTimeoutMs(
Long.parseLong(
properties.getProperty(
"config_node_ratis_request_timeout_ms",
String.valueOf(conf.getConfigNodeRatisRequestTimeoutMs()))));
conf.setSchemaRegionRatisRequestTimeoutMs(
Long.parseLong(
properties.getProperty(
"schema_region_ratis_request_timeout_ms",
String.valueOf(conf.getSchemaRegionRatisRequestTimeoutMs()))));
conf.setDataRegionRatisRequestTimeoutMs(
Long.parseLong(
properties.getProperty(
"data_region_ratis_request_timeout_ms",
String.valueOf(conf.getDataRegionRatisRequestTimeoutMs()))));
conf.setConfigNodeRatisMaxRetryAttempts(
Integer.parseInt(
properties.getProperty(
"config_node_ratis_max_retry_attempts",
String.valueOf(conf.getConfigNodeRatisMaxRetryAttempts()))));
conf.setConfigNodeRatisInitialSleepTimeMs(
Long.parseLong(
properties.getProperty(
"config_node_ratis_initial_sleep_time_ms",
String.valueOf(conf.getConfigNodeRatisInitialSleepTimeMs()))));
conf.setConfigNodeRatisMaxSleepTimeMs(
Long.parseLong(
properties.getProperty(
"config_node_ratis_max_sleep_time_ms",
String.valueOf(conf.getConfigNodeRatisMaxSleepTimeMs()))));
conf.setDataRegionRatisMaxRetryAttempts(
Integer.parseInt(
properties.getProperty(
"data_region_ratis_max_retry_attempts",
String.valueOf(conf.getDataRegionRatisMaxRetryAttempts()))));
conf.setDataRegionRatisInitialSleepTimeMs(
Long.parseLong(
properties.getProperty(
"data_region_ratis_initial_sleep_time_ms",
String.valueOf(conf.getDataRegionRatisInitialSleepTimeMs()))));
conf.setDataRegionRatisMaxSleepTimeMs(
Long.parseLong(
properties.getProperty(
"data_region_ratis_max_sleep_time_ms",
String.valueOf(conf.getDataRegionRatisMaxSleepTimeMs()))));
conf.setSchemaRegionRatisMaxRetryAttempts(
Integer.parseInt(
properties.getProperty(
"schema_region_ratis_max_retry_attempts",
String.valueOf(conf.getSchemaRegionRatisMaxRetryAttempts()))));
conf.setSchemaRegionRatisInitialSleepTimeMs(
Long.parseLong(
properties.getProperty(
"schema_region_ratis_initial_sleep_time_ms",
String.valueOf(conf.getSchemaRegionRatisInitialSleepTimeMs()))));
conf.setSchemaRegionRatisMaxSleepTimeMs(
Long.parseLong(
properties.getProperty(
"schema_region_ratis_max_sleep_time_ms",
String.valueOf(conf.getSchemaRegionRatisMaxSleepTimeMs()))));
conf.setConfigNodeRatisPreserveLogsWhenPurge(
Long.parseLong(
properties.getProperty(
"config_node_ratis_preserve_logs_num_when_purge",
String.valueOf(conf.getConfigNodeRatisPreserveLogsWhenPurge()))));
conf.setSchemaRegionRatisPreserveLogsWhenPurge(
Long.parseLong(
properties.getProperty(
"schema_region_ratis_preserve_logs_num_when_purge",
String.valueOf(conf.getSchemaRegionRatisPreserveLogsWhenPurge()))));
conf.setDataRegionRatisPreserveLogsWhenPurge(
Long.parseLong(
properties.getProperty(
"data_region_ratis_preserve_logs_num_when_purge",
String.valueOf(conf.getDataRegionRatisPreserveLogsWhenPurge()))));
conf.setRatisFirstElectionTimeoutMinMs(
Long.parseLong(
properties.getProperty(
"ratis_first_election_timeout_min_ms",
String.valueOf(conf.getRatisFirstElectionTimeoutMinMs()))));
conf.setRatisFirstElectionTimeoutMaxMs(
Long.parseLong(
properties.getProperty(
"ratis_first_election_timeout_max_ms",
String.valueOf(conf.getRatisFirstElectionTimeoutMaxMs()))));
conf.setConfigNodeRatisLogMax(
Long.parseLong(
properties.getProperty(
"config_node_ratis_log_max_size",
String.valueOf(conf.getConfigNodeRatisLogMax()))));
conf.setSchemaRegionRatisLogMax(
Long.parseLong(
properties.getProperty(
"schema_region_ratis_log_max_size",
String.valueOf(conf.getSchemaRegionRatisLogMax()))));
conf.setDataRegionRatisLogMax(
Long.parseLong(
properties.getProperty(
"data_region_ratis_log_max_size",
String.valueOf(conf.getDataRegionRatisLogMax()))));
conf.setConfigNodeRatisPeriodicSnapshotInterval(
Long.parseLong(
properties.getProperty(
"config_node_ratis_periodic_snapshot_interval",
String.valueOf(conf.getConfigNodeRatisPeriodicSnapshotInterval()))));
conf.setSchemaRegionRatisPeriodicSnapshotInterval(
Long.parseLong(
properties.getProperty(
"schema_region_ratis_periodic_snapshot_interval",
String.valueOf(conf.getSchemaRegionRatisPeriodicSnapshotInterval()))));
conf.setDataRegionRatisPeriodicSnapshotInterval(
Long.parseLong(
properties.getProperty(
"data_region_ratis_periodic_snapshot_interval",
String.valueOf(conf.getDataRegionRatisPeriodicSnapshotInterval()))));
conf.setEnablePrintingNewlyCreatedPartition(
Boolean.parseBoolean(
properties.getProperty(
"enable_printing_newly_created_partition",
String.valueOf(conf.isEnablePrintingNewlyCreatedPartition()))));
conf.setForceWalPeriodForConfigNodeSimpleInMs(
Long.parseLong(
properties.getProperty(
"force_wal_period_for_confignode_simple_in_ms",
String.valueOf(conf.getForceWalPeriodForConfigNodeSimpleInMs()))));
}