ALTER MIGRATION RULE
语法用于修改数据迁移规则
AlterMigrationRule ::=
'ALTER' 'MIGRATION' 'RULE' ( '(' (readConfiguration ',')? (writeConfiguration ',')? (dataChannel)? ')' )?
readConfiguration ::=
'READ' '(' ('WORKER_THREAD' '=' workerThreadPoolSize ',')? ('BATCH_SIZE' '=' batchSize ',')? ('SHARDING_SIZE' '=' shardingSize ',')? (rateLimiter)? ')'
writeConfiguration ::=
'WRITE' '(' ('WORKER_THREAD' '=' workerThreadPoolSize ',')? ('BATCH_SIZE' '=' batchSize ',')? ('SHARDING_SIZE' '=' shardingSize ',')? (rateLimiter)? ')'
dataChannel ::=
'STREAM_CHANNEL' '(' 'TYPE' '(' 'NAME' '=' algorithmName ',' 'PROPERTIES' '(' propertyDefinition ')'
workerThreadPoolSize ::=
int
batchSize ::=
int
shardingSize ::=
int
rateLimiter ::=
'RATE_LIMITER' '(' 'TYPE' '(' 'NAME' '=' algorithmName ',' 'PROPERTIES' '(' propertyDefinition ')'
algorithmName ::=
string
propertyDefinition ::=
( key '=' value ) ( ',' key '=' value )*
key ::=
string
value ::=
string
ALTER MIGRATION RULE
可以只修改数据迁移规则中一项配置并不影响其他配置ALTER MIGRATION RULE (
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',PROPERTIES('tps'='2000')))),
STREAM_CHANNEL ( TYPE(NAME='MEMORY',PROPERTIES('block-queue-size'='10000')))
);
ALTER MIGRATION RULE (
READ(WORKER_THREAD=40, BATCH_SIZE=1000, SHARDING_SIZE=10000000, RATE_LIMITER (TYPE(NAME='QPS',PROPERTIES('qps'='500'))))
);
ALTER MIGRATION RULE (
WRITE(WORKER_THREAD=40, BATCH_SIZE=1000, SHARDING_SIZE=10000000, RATE_LIMITER (TYPE(NAME='QPS',PROPERTIES('qps'='500'))))
);
ALTER MIGRATION RULE (
STREAM_CHANNEL ( TYPE( NAME='MEMORY', PROPERTIES('block-queue-size'='10000')))
);
ALTER
、MIGRATION
、RULE
、READ
、WRITE
、WORKER_THREAD
、BATCH_SIZE
、SHARDING_SIZE
、STREAM_CHANNEL
、TYPE
、NAME
、PROPERTIES