510 Pagination Correction . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 512 Batch Split . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 513 Rewriting ',')? ('BATCH_SIZE' '=' batchSize ',')? ('SHARDING_SIZE' '=' shardingSize ',')? (rateLimiter)? ')' writeConfiguration ::= 'WRITE' '(' ('WORKER_THREAD' '=' workerThreadPoolSize ',')? ('BATCH_SIZE' '=' MIGRATION RULE ( READ( WORKER_THREAD=20, BATCH_SIZE=1000, SHARDING_SIZE=10000000, RATE_LIMITER (TYPE(NAME='QPS',PROPERTIES('qps'='500')))), WRITE( WORKER_THREAD=20, BATCH_SIZE=1000, RATE_LIMITER (TYPE(NAME='TPS'

539 Pagination Correction . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 541 x Batch Split . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 542 Rewriting ',')? ('BATCH_SIZE' '=' batchSize ',')? ('SHARDING_SIZE' '=' shardingSize ',')? (rateLimiter)? ')' writeConfiguration ::= 'WRITE' '(' ('WORKER_THREAD' '=' workerThreadPoolSize ',')? ('BATCH_SIZE' '=' MIGRATION RULE ( READ( WORKER_THREAD=20, BATCH_SIZE=1000, SHARDING_SIZE=10000000, RATE_LIMITER (TYPE(NAME='QPS',PROPERTIES('qps'='500')))), WRITE( WORKER_THREAD=20, BATCH_SIZE=1000, RATE_LIMITER (TYPE(NAME='TPS'

5 Core Concept . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 59 Scaling Job . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 59 Inventory Data . 267 Pagination Revision . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 269 Batch Split . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 270 Optimization Concept Scaling Job It refers one complete process of scaling data from old rule to new rule. Inventory Data It refers all existing data stored in data nodes before the scaling job started. Incremental

',')? ('BATCH_SIZE' '=' batchSize ',')? ('SHARDING_SIZE' '=' shardingSize ',')? (rateLimiter)? ')' writeConfiguration ::= 'WRITE' '(' ('WORKER_THREAD' '=' workerThreadPoolSize ',')? ('BATCH_SIZE' '=' MIGRATION RULE ( READ( WORKER_THREAD=20, BATCH_SIZE=1000, SHARDING_SIZE=10000000, RATE_LIMITER (TYPE(NAME='QPS',PROPERTIES('qps'='500')))), WRITE( WORKER_THREAD=20, BATCH_SIZE=1000, RATE_LIMITER (TYPE(NAME='TPS' READ(WORKER_THREAD=20, BATCH_SIZE=1000, SHARDING_SIZE=10000000, RATE_LIMITER (TYPE(NAME='QPS',PROPERTIES('qps'='500')))) ); • 仅修改数据迁移规则中的数据写入配置 ALTER MIGRATION RULE ( WRITE(WORKER_THREAD=20, BATCH_SIZE=1000,

',')? ('BATCH_SIZE' '=' batchSize ',')? ('SHARDING_SIZE' '=' shardingSize ',')? (rateLimiter)? ')' writeConfiguration ::= 'WRITE' '(' ('WORKER_THREAD' '=' workerThreadPoolSize ',')? ('BATCH_SIZE' '=' MIGRATION RULE ( READ( WORKER_THREAD=20, BATCH_SIZE=1000, SHARDING_SIZE=10000000, RATE_LIMITER (TYPE(NAME='QPS',PROPERTIES('qps'='500')))), WRITE( WORKER_THREAD=20, BATCH_SIZE=1000, RATE_LIMITER (TYPE(NAME='TPS' READ(WORKER_THREAD=20, BATCH_SIZE=1000, SHARDING_SIZE=10000000, RATE_LIMITER (TYPE(NAME='QPS',PROPERTIES('qps'='500')))) ); • 仅修改数据迁移规则中的数据写入配置 ALTER MIGRATION RULE ( WRITE(WORKER_THREAD=20, BATCH_SIZE=1000,

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 9 2.3.4 Create Migration Job . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 9 2.3.5 Related documents . . . . 5 Core Concept . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 57 Scaling Job . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 57 Inventory Data . 256 Pagination Revision . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 258 Batch Split . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 259 Optimization

398 Pagination Correction . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 400 Batch Split . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 401 Rewriting CONFIGURATION ( READ( WORKER_THREAD=40, BATCH_SIZE=1000, SHARDING_SIZE=10000000, RATE_LIMITER (TYPE(NAME='QPS',PROPERTIES('qps'='500'))) ), WRITE( WORKER_THREAD=40, BATCH_SIZE=1000, RATE_LIMITER (TYPE(NAME='TPS' size of all the data from the source side. If it is not configured, the default value is used. BATCH_SIZE=1000, -- The maximum number of records returned by a query operation. If it is not configured

',')? ('BATCH_SIZE' '=' batchSize ',')? ('SHARDING_SIZE' '=' shardingSize ',')? (rateLimiter)? ')' writeConfiguration ::= 'WRITE' '(' ('WORKER_THREAD' '=' workerThreadPoolSize ',')? ('BATCH_SIZE' '=' MIGRATION RULE ( READ( WORKER_THREAD=20, BATCH_SIZE=1000, SHARDING_SIZE=10000000, RATE_LIMITER (TYPE(NAME='QPS',PROPERTIES('qps'='500')))), WRITE( WORKER_THREAD=20, BATCH_SIZE=1000, RATE_LIMITER (TYPE(NAME='TPS' TYPE(NAME='MEMORY',PROPERTIES('block-queue-size'='2000'))) ); 保留字 ALTER、MIGRATION、RULE、READ、WRITE、WORKER_THREAD、BATCH_SIZE、SHARDING_SIZE、 STREAM_CHANNEL、TYPE、NAME、PROPERTIES 相关链接 • 保留字 REGISTER MIGRATION SOURCE STORAGE

371 Pagination Correction . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 373 Batch Split . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 374 Rewriting CONFIGURATION ( READ( WORKER_THREAD=40, BATCH_SIZE=1000, SHARDING_SIZE=10000000, RATE_LIMITER (TYPE(NAME='QPS',PROPERTIES('qps'='500'))) ), WRITE( WORKER_THREAD=40, BATCH_SIZE=1000, RATE_LIMITER (TYPE(NAME='TPS' size of all the data from the source side. If it is not configured, the default value is used. BATCH_SIZE=1000, -- The maximum number of records returned by a query operation. If it is not configured

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 9 2.3.4 4. Create Migration Job . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 9 2.3.5 5. Related documents . . . 5 Core Concept . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 60 Scaling Job . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 60 Inventory Data . 246 Pagination Revision . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 248 Batch Split . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 249 Optimization