分桶策略在代碼withBucketAssigner中設定

?

?	Flink寫入hive	Hive
分桶策略	寫入hive中的一個文件夾	保存在文件
分區	指的是如何分配到下游算子中進行計算[2]	保存在文件夾

?

也就是說flink的寫入分桶和hive的分桶不是一個概念。

其中的flink分區是用來 流/離線 計算的

?

分桶策略[1]	作用
BasePathBucketAssigner	不分桶，所有文件寫到根目錄
DateTimeBucketAssigner	基于系統時間分桶

Reference:

[1]學習 Flink（十六）：Streaming Parquet File

[2]Flink分區策略

總結

以上是生活随笔為你收集整理的flink的分桶策略BucketAssigner与hive的分区的对应关系的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。