选择的分区方案有点不幸。不过，你还是可以做一些事情。我所依赖的事实是，您可以在hive中原子地更改分区的位置（altertable。。。分区。。。设置位置）：
将分区的hdfs目录复制到其他位置
压缩复制的数据
复制自步骤1以来接收的新文件
“更改表格…”。。。分区。。。设置位置“以将配置单元指向新的压缩位置。
开始摄取到这个新的位置（如果这个步骤很棘手的话，你也可以用压缩的版本替换原来分区位置中的“小”文件，然后做“alter table…”。。。分区。。。再次设置location“以将配置单元指向原始分区位置。
您必须使这个进程连续地逐分区迭代运行。

谢谢你的建议，非常感谢。
我对hdfs的概念非常陌生，所以请不要介意基本问题，
在执行将未压缩文件与压缩文件交换（alter table。。。分区。。。设置位置）。我相信这些查询可能会失败。我们能把影响降到最低吗？
将分区的hdfs目录复制到其他位置
因为我们在一个表中有两个分区，state和store，所以我需要遍历每个子分区吗？
/tablename/state=ca/store=macys/file1.parquet/tablename/state=ca/store=macys/file2.parquet
/tablename/state=ca/store=jcp/file2.parquet/tablename/state=ca/store=jcp/file2.parquet
/tablename/state=ny/store=macys/file1.parquet/tablename/state=ny/store=macys/file2.parquet
/tablename/state=ny/store=jcp/file2.parquet/tablename/state=ny/store=jcp/file2.parquet

For each state
    for each store
        get list of files in this dir to replace later
        compact 
            /tableName/state=$STATE/store=$STORE (SPARK JOb?)
        replace uncompacted files with compacted files
        alter table ... partition ... set location

我更希望您在第5步中的其他建议“也可以用压缩版本替换原始分区位置中的“小”文件”
我将如何继续实现它，最好是使用脚本、scala或其他编程语言。我有基本的脚本知识，有很好的java经验，对scala还不熟悉，但几天内就能学会。
你好，p