请帮我罗列出flinksql写入hive的所有WITH选项配置并用中文注释
以下是FlinkSQL写入Hive时常用的WITH选项配置及其中文注释:
- partition.by - 指定分区列
- partition.default-name - 指定默认分区名
- hive.database - 指定Hive数据库名
- hive.table-name - 指定Hive表名
- hive.partition-spec - 指定分区规范(例如:dt='20220101')
- hive.format - 指定写入Hive表的文件格式(例如:ORC、PARQUET、TEXT)
- hive.file.name - 指定写入Hive表的文件名
- hive.file.path - 指定写入Hive表的文件路径
- hive.conf - 指定Hive配置属性(例如:hive.exec.dynamic.partition.mode=nonstrict)
- sink.buffer-flush.max-rows - 指定每个批次最大写入行数
- sink.buffer-flush.interval - 指定每个批次最大等待时间
- sink.partition-commit.policy.kind - 指定分区提交策略
- sink.partition-commit.delay - 指定分区提交延迟时间
- sink.partition-commit.trigger - 指定分区提交触发器
- sink.partition-commit.success-file-name - 指定分区提交成功标记文件名
- sink.partition-commit.failure-file-name - 指定分区提交失败标记文件名
- sink.partition-commit.partial-failure-file-name - 指定分区提交部分失败标记文件名
- sink.partition-commit.max-retries - 指定分区提交最大重试次数
- sink.partition-commit.retry-interval - 指定分区提交重试间隔时间
- sink.partition-commit.failure-handler - 指定分区提交失败处理程序
- sink.partition-commit.failure-max-tolerate - 指定分区提交失败最大容忍次数
- sink.partition-commit.failure-rollback-on-retries-exhausted - 指定分区提交失败时是否回滚
- sink.partition-commit.failure-rollback-on-exception - 指定分区提交出现异常时是否回滚
- sink.partition-commit.failure-rollback-on-interrupt - 指定分区提交被中断时是否回滚
- sink.partition-commit.failure-rollback-on-job-failover - 指定分区提交失败时是否回滚
注意:以上选项并非全部必须选项,可以根据实际情况选择性配置
原文地址: https://www.cveoy.top/t/topic/fHG1 著作权归作者所有。请勿转载和采集!