ALTER MIGRATION RULE
描述
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 ',' propertiesDefinition ')' ')'
workerThreadPoolSize ::=
int
batchSize ::=
int
shardingSize ::=
int
rateLimiter ::=
'RATE_LIMITER' '(' 'TYPE' '(' 'NAME' '=' algorithmName ',' propertiesDefinition ')' ')'
algorithmName ::=
string
propertiesDefinition ::=
'PROPERTIES' '(' key '=' value (',' key '=' value)* ')'
key ::=
string
value ::=
literal
示例
ALTER 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',PROPERTIES('tps'='2000')))),
STREAM_CHANNEL ( TYPE(NAME='MEMORY',PROPERTIES('block-queue-size'='2000')))
);
保留字
ALTER
、MIGRATION
、RULE
、READ
、WRITE
、WORKER_THREAD
、BATCH_SIZE
、SHARDING_SIZE
、STREAM_CHANNEL
、TYPE
、NAME
、PROPERTIES
相关链接
当前内容版权归 ShardingSphere 或其关联方所有,如需对内容或内容相关联开源项目进行关注与资助,请访问 ShardingSphere .