Table

Hive表相关类

BaseMetastoreCatalog�
HiveCatalog�

所有表操作相关都封装到如下类
BaseMetastoreTableOperations
HiveTableOperations��

TableMetadata�
�

写文件相关

PartitionedFanoutWriter中包含一个Map�
一个RollingFileWriter对应一个文件。

PartitionSpec�和Schema生成 PartitionKey
PartitionKey.partition(StructLike�)

PartitionSpec#partitionToPath��(StructLike�)

分区转换
例如：Timestamp转Year分区
都在Transform�类

Flink分区写
RowDataTaskWriterFactory� -> RowDataPartitionedFanoutWriter�

SnapshotSummary�
SnapshotProducer�

在commitUpToCheckpoint�方法保存Snapshot数据