看起来 beam dataframe 支持读取压缩的 json 文件apache_beam.dataframe.io.read_json
但是，当我尝试通过代码读取文件时：
from apache_beam.dataframe.io import read_json,
beam_df = pipeline | read_json(path=input_file, lines=True, compression_type="gzip")
报错
AttributeError: 'CompressedFile' object has no attribute 'writable'
我的实现是否正确？
TIA