各位好,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();
