PyFlink -如何使用指定的文件输入格式(而不是文本格式) readFile()？

from pyflink.common.serialization import DeserializationSchema
from pyflink.datastream import StreamExecutionEnvironment

class CustomFileFormat(DeserializationSchema):
    def deserialize(self, value):
        # 解析文件数据并返回PyFlink中的数据类型
        pass

    def is_end_of_stream(self, next_element):
        return False

    def get_produced_type(self):
        # 返回解析后的数据类型
        pass

env = StreamExecutionEnvironment.get_execution_environment()
env.set_parallelism(1)

# 创建自定义的文件输入格式对象
file_format = CustomFileFormat()

# 读取文件并使用自定义的文件输入格式
data_stream = env.read_text_file("path/to/file").from_source(file_format)

# 对数据流进行处理
data_stream.print()

# 执行作业
env.execute("Read File with Custom Format")