the primary and secondary databases may be inconsistent for a short time. Load balancer policy Channel query requests to different secondary databases through load balancer policy. 8.3.7 Limitations Column Description read Data reading configuration write Data writing configuration stream_channel Data channel Example • Query migration rule SHOW MIGRATION RULE; mysql> SHOW MIGRATION RULE; +--- -----+ | read | write 9.2. ShardingSphere-Proxy 330 Apache ShardingSphere document | stream_channel | +--------------------------------------------------------------+------------------- --------

the primary and secondary databases may be inconsistent for a short time. Load balancer policy Channel query requests to different secondary databases through load balancer policy. 8.3.7 Limitations Column Description read Data reading configuration write Data writing configuration stream_channel Data channel Example • Query migration rule SHOW MIGRATION RULE; mysql> SHOW MIGRATION RULE; +--- -------------------+-------------------------------------------------------+ | read | write | stream_channel | +--------------------------------------------------------------+------------------- --------

ShowMigrationRule ::= 'SHOW' 'MIGRATION' 'RULE' 返回值说明 列 说明 read 数据读取配置 write 数据写入配置 stream_channel 数据通道 示例 • 查询数据迁移规则 SHOW MIGRATION RULE; mysql> SHOW MIGRATION RULE; +---------------------- -------------------+-------------------------------------------------------+ | read | write | stream_channel | +--------------------------------------------------------------+------------------- -------- batchSize ',')? ('SHARDING_SIZE' '=' shardingSize ',')? (rateLimiter)? ')' dataChannel ::= 'STREAM_CHANNEL' '(' 'TYPE' '(' 'NAME' '=' algorithmName ',' propertiesDefinition ')' ')' workerThreadPoolSize

ShowMigrationRule ::= 'SHOW' 'MIGRATION' 'RULE' 返回值说明 列 说明 read 数据读取配置 write 数据写入配置 stream_channel 数据通道 9.2. ShardingSphere-Proxy 292 Apache ShardingSphere document 示例 • 查询数据迁移规则 SHOW MIGRATION -------------------+-------------------------------------------------------+ | read | write | stream_channel | +--------------------------------------------------------------+------------------- -------- (rateLimiter)? ')' 9.2. ShardingSphere-Proxy 293 Apache ShardingSphere document dataChannel ::= 'STREAM_CHANNEL' '(' 'TYPE' '(' 'NAME' '=' algorithmName ',' propertiesDefinition ')' ')' workerThreadPoolSize

ShowMigrationRule ::= 'SHOW' 'MIGRATION' 'RULE' 返回值说明 列 说明 read 数据读取配置 write 数据写入配置 stream_channel 数据通道 9.2. ShardingSphere-Proxy 286 Apache ShardingSphere document 示例 • 查询数据迁移规则 SHOW MIGRATION -------------------+-------------------------------------------------------+ | read | write | stream_channel | +--------------------------------------------------------------+------------------- -------- (rateLimiter)? ')' 9.2. ShardingSphere-Proxy 287 Apache ShardingSphere document dataChannel ::= 'STREAM_CHANNEL' '(' 'TYPE' '(' 'NAME' '=' algorithmName ',' propertiesDefinition ')' ')' workerThreadPoolSize

(algorithmDefinition) rateLimiter: RATE_LIMITER (algorithmDefinition) streamChannel: STREAM_CHANNEL (algorithmDefinition) workerThread: WORKER_THREAD=intValue batchSize: BATCH_SIZE=intValue intValue: WORKER_THREAD=40, BATCH_SIZE=1000 ), OUTPUT( WORKER_THREAD=40, BATCH_SIZE=1000 ), STREAM_CHANNEL(TYPE(NAME=MEMORY, PROPERTIES("block-queue-size"=10000))), COMPLETION_DETECTOR(TYPE(NAME=IDLE, P scaling rule input data read configuration output data write configuration stream_channel algorithm of stream channel completion_detector algorithm of completion detecting data_consistency_checker algorithm

(algorithmDefinition) rateLimiter: RATE_LIMITER (algorithmDefinition) streamChannel: STREAM_CHANNEL (algorithmDefinition) workerThread: WORKER_THREAD=intValue batchSize: BATCH_SIZE=intValue intValue: BATCH_SIZE=1000 ), 5.2. ShardingSphere-Proxy 170 Apache ShardingSphere document, v5.1.1 STREAM_CHANNEL(TYPE(NAME=MEMORY, PROPERTIES("block-queue-size"=10000))), COMPLETION_DETECTOR(TYPE(NAME=IDLE, P scaling rule input data read configuration output data write configuration stream_channel algorithm of stream channel completion_detector algorithm of completion detecting data_consistency_checker algorithm

the primary and secondary databases may be inconsistent for a short time. Load balancer policy Channel query requests to different secondary databases through load balancer policy. 3.3.7 Limitations sources dynamically correct the primary/secondary relationship of read/write splitting and properly channel read/write traffic. 3.4. HA 38 Apache ShardingSphere document, v5.2.1 3.4.7 Limitations Supported -------------------+------------------------------------------------------+ | read | write | stream_channel | +--------------------------------------------------------------+------------------- --------

the primary and secondary databases may be inconsistent for a short time. Load balancer policy Channel query requests to different secondary databases through load balancer policy. 3.3.7 Limitations sources dynamically correct the primary/secondary relationship of read/write splitting and properly channel read/write traffic. 3.4. HA 39 Apache ShardingSphere document, v5.2.0 3.4.7 Limitations Supported -------------------+------------------------------------------------------+ | read | write | stream_channel | +--------------------------------------------------------------+------------------- --------

(algorithmDefinition) rateLimiter: RATE_LIMITER (algorithmDefinition) streamChannel: STREAM_CHANNEL (algorithmDefinition) workerThread: WORKER_THREAD=intValue batchSize: BATCH_SIZE=intValue intValue: WORKER_THREAD=40, BATCH_SIZE=1000 ), OUTPUT( WORKER_THREAD=40, BATCH_SIZE=1000 ), STREAM_CHANNEL(TYPE(NAME=MEMORY, PROPERTIES("block-queue-size"=10000))), COMPLETION_DETECTOR(TYPE(NAME=IDLE, P sharding_broadcast_tables 广播表名称 Sharding Scaling Rule 列 说明 name 弹性伸缩配置名称 input 数据读取配置 output 数据写入配置 stream_channel 数据通道配置 completion_detector 作业完成检测算法配置 data_consistency_checker 数据一致性校验算法配置 示例 Sharding Table