ALTER MIGRATION RULE

描述

ALTER MIGRATION RULE 语法用于修改数据迁移规则。

语法

语法 铁路图

  1. AlterMigrationRule ::=
  2. 'ALTER' 'MIGRATION' 'RULE' ('(' (readConfiguration ',')? (writeConfiguration ',')? (dataChannel)? ')')?
  3. readConfiguration ::=
  4. 'READ' '(' ('WORKER_THREAD' '=' workerThreadPoolSize ',')? ('BATCH_SIZE' '=' batchSize ',')? ('SHARDING_SIZE' '=' shardingSize ',')? (rateLimiter)? ')'
  5. writeConfiguration ::=
  6. 'WRITE' '(' ('WORKER_THREAD' '=' workerThreadPoolSize ',')? ('BATCH_SIZE' '=' batchSize ',')? ('SHARDING_SIZE' '=' shardingSize ',')? (rateLimiter)? ')'
  7. dataChannel ::=
  8. 'STREAM_CHANNEL' '(' 'TYPE' '(' 'NAME' '=' algorithmName ',' propertiesDefinition ')' ')'
  9. workerThreadPoolSize ::=
  10. int
  11. batchSize ::=
  12. int
  13. shardingSize ::=
  14. int
  15. rateLimiter ::=
  16. 'RATE_LIMITER' '(' 'TYPE' '(' 'NAME' '=' algorithmName ',' propertiesDefinition ')' ')'
  17. algorithmName ::=
  18. string
  19. propertiesDefinition ::=
  20. 'PROPERTIES' '(' key '=' value (',' key '=' value)* ')'
  21. key ::=
  22. string
  23. value ::=
  24. literal

示例

  1. ALTER MIGRATION RULE (
  2. READ( WORKER_THREAD=20, BATCH_SIZE=1000, SHARDING_SIZE=10000000, RATE_LIMITER (TYPE(NAME='QPS',PROPERTIES('qps'='500')))),
  3. WRITE( WORKER_THREAD=20, BATCH_SIZE=1000, RATE_LIMITER (TYPE(NAME='TPS',PROPERTIES('tps'='2000')))),
  4. STREAM_CHANNEL ( TYPE(NAME='MEMORY',PROPERTIES('block-queue-size'='2000')))
  5. );

保留字

ALTERMIGRATIONRULEREADWRITEWORKER_THREADBATCH_SIZESHARDING_SIZESTREAM_CHANNELTYPENAMEPROPERTIES

相关链接