上云无忧 > 文档中心 > 百度数据仓库 Palo SQL语法手册 - ALTER-ROUTINE-LOAD
百度数据仓库 Palo Doris版
百度数据仓库 Palo SQL语法手册 - ALTER-ROUTINE-LOAD

文档简介:
ALTER-ROUTINE-LOAD Description: ALTER ROUTINE LOAD FOR [db.]job_name [PROPERTIES( "prop1" = "val1", ... )] [FROM kafka( "prop1" = "val1", ... )] 该命令用于修改一个 Routine Load 作业的属性。
*此产品及展示信息均由百度智能云官方提供。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

ALTER-ROUTINE-LOAD

Description

ALTER ROUTINE LOAD FOR [db.]job_name [PROPERTIES( "prop1" = "val1", ... )] [FROM kafka( "prop1" = "val1", ... )]

该命令用于修改一个 Routine Load 作业的属性。

只能修改处于暂停(PASUE)状态的 Routine Load 作业。

当前支持如下属性的修改:

  1. 作业属性

    • desired_concurrent_number
    • max_error_number
    • max_batch_interval
    • max_batch_rows
    • max_batch_size
    • jsonpaths
    • json_root
    • num_as_string
    • fuzzy_parse
    • strip_outer_array
    • timezone
    • strict_mode
  2. Kafka 属性

    • kafka_partitions
    • kafka_offsets
    • kafka_default_offsets
    • kafka_broker_list
    • kafka_topic
    • 自定义 property,如 property.group.id

关于以上属性的详细说明,请参见 ROUTINE-LOAD 手册。

Example

  1. 修改作业的每批次消费数量,以及消费offset。

    ALTER ROUTINE LOAD FOR db1.job1
    PROPERTIES( "max_batch_interval" = "60", "max_batch_rows" = "1000000", "max_batch_size"
  2.  = "500000", ) FROM KFAK ( "kafka_partitions" = "0,1,2", "kafka_offsets" = "2021-05-01 00:00:00
  3. , 2021-05-01 00:00:00, 2021-05-01 00:00:00" )

Keywords

ALTER, ROUTINE, LOAD

最佳实践

  1. 从指定位置重新消费数据

    某些情况下,用户希望能够重新指定消费位置并重新消费数据,比如一些数据回溯等场景。此时可以先将当前需要修改的例行导入作业暂停。然后通过这个命令修改offset,再重启这个作业即可。

相似文档
  • BACKUP Description: 该语句用于备份指定数据库下的数据。该命令为异步操作。提交成功后,需通过 SHOW BACKUP 命令查看进度。 仅支持备份 OLAP 类型的表。 BACKUP SNAPSHOT [db_name.]snapshot_name TO `repository_name` ON ( `table_name` [PARTITION (`p1`, ...)], ... ) PROPERTIES ("key"="value", ...);
  • BROKER LOAD Description: 该命令主要用于通过 Broker 服务进程来导入远端存储(如BOS、HDFS)上的数据。 LOAD LABEL load_label ( data_desc1[, data_desc2, ...] ) WITH BROKER broker_name [broker_properties] [load_properties];
  • EXPORT Description: 该语句用于将指定表的数据导出到指定位置。 这是一个异步操作,任务提交成功则返回。执行后可使用 SHOW EXPORT 命令查看进度。 EXPORT TABLE table_name [PARTITION (p1[,p2])] TO export_path [opt_properties] WITH BROKER [broker_properties];
  • INSERT Description: INSERT INTO table_name [ PARTITION (p1, ...) ] [ WITH LABEL label] [ (column [, ...]) ] { VALUES ( { expression | DEFAULT } [, ...] ) [, ...] | query } table_name: 需要导入数据的表名。
  • RESTORE Description: 该语句用于将之前通过 BACKUP 命令备份的数据,恢复到指定数据库下。 该命令为异步操作。提交成功后,需通过 SHOW RESTORE 命令查看进度。 仅支持恢复 OLAP 类型的表。
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部