以下是FlinkSQL写入Hive时常用的WITH选项配置及其中文注释:

  1. partition.by - 指定分区列
  2. partition.default-name - 指定默认分区名
  3. hive.database - 指定Hive数据库名
  4. hive.table-name - 指定Hive表名
  5. hive.partition-spec - 指定分区规范(例如:dt='20220101')
  6. hive.format - 指定写入Hive表的文件格式(例如:ORC、PARQUET、TEXT)
  7. hive.file.name - 指定写入Hive表的文件名
  8. hive.file.path - 指定写入Hive表的文件路径
  9. hive.conf - 指定Hive配置属性(例如:hive.exec.dynamic.partition.mode=nonstrict)
  10. sink.buffer-flush.max-rows - 指定每个批次最大写入行数
  11. sink.buffer-flush.interval - 指定每个批次最大等待时间
  12. sink.partition-commit.policy.kind - 指定分区提交策略
  13. sink.partition-commit.delay - 指定分区提交延迟时间
  14. sink.partition-commit.trigger - 指定分区提交触发器
  15. sink.partition-commit.success-file-name - 指定分区提交成功标记文件名
  16. sink.partition-commit.failure-file-name - 指定分区提交失败标记文件名
  17. sink.partition-commit.partial-failure-file-name - 指定分区提交部分失败标记文件名
  18. sink.partition-commit.max-retries - 指定分区提交最大重试次数
  19. sink.partition-commit.retry-interval - 指定分区提交重试间隔时间
  20. sink.partition-commit.failure-handler - 指定分区提交失败处理程序
  21. sink.partition-commit.failure-max-tolerate - 指定分区提交失败最大容忍次数
  22. sink.partition-commit.failure-rollback-on-retries-exhausted - 指定分区提交失败时是否回滚
  23. sink.partition-commit.failure-rollback-on-exception - 指定分区提交出现异常时是否回滚
  24. sink.partition-commit.failure-rollback-on-interrupt - 指定分区提交被中断时是否回滚
  25. sink.partition-commit.failure-rollback-on-job-failover - 指定分区提交失败时是否回滚

注意:以上选项并非全部必须选项,可以根据实际情况选择性配置

请帮我罗列出flinksql写入hive的所有WITH选项配置并用中文注释

原文地址: https://www.cveoy.top/t/topic/fHG1 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录