开发者社区> 问答> 正文

我发现写入hive只能根据checkpoint去提交分区?可以按照文件大小或者间隔时间来生成吗?

  1. Create hive表(...)with(...) 我发现写入hive只能根据checkpoint去提交分区?可以按照文件大小或者间隔时间来生成吗?

  2. Create table (connector=filesystem,format=json) with(…) 这种方式format只能等于json? 我怎么按照分隔符写入hdfs?*来自志愿者整理的flink邮件归档

展开
收起
游客sadna6pkvqnz6 2021-12-07 16:41:28 555 0
1 条回答
写回答
取消 提交回答
  • 1.  为了保证数据正确性 stream 写文件依赖了 checkpoint 机制,你可以将你的间隔时间和 checkpoint 时间保持一致 2. 按逗号分隔是说 CSV format ?*来自志愿者整理的flink

    2021-12-07 20:15:51
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Hive Bucketing in Apache Spark 立即下载
spark替代HIVE实现ETL作业 立即下载
2019大数据技术公开课第五季—Hive迁移到MaxCompute最佳实践 立即下载