各位好,FLINK 1.9.1 使用 StreamingFileSink 写Parquet到HDFS,能启用压缩吗?

--代码
StreamingFileSink<HDFSBean> sink = StreamingFileSink
        .forBulkFormat(new Path(FILE_HDFS_PATH), 
ParquetAvroWriters.forReflectRecord(HDFSBean.class))
        .withBucketAssigner(new DateTimeBucketAssigner<>(FILE_HDFS_FORMAT))

        .build();

回复