使用一个pyflink的HelloWorld的方法是什么？

from pyflink.common import WatermarkStrategy
from pyflink.datastream import StreamExecutionEnvironment
from pyflink.datastream.connectors import FileSource, StreamFormat

if __name__ == '__main__':
    # 1. 创建流式处理环境
    env = StreamExecutionEnvironment.get_execution_environment()

    # 2. 创建source
    file_source = FileSource \
        .for_record_stream_format(StreamFormat.text_line_format(), "./test.log") \
        .build()

    # 3. 将source添加到环境中，环境会生成一个datastream，也就是我们进行操作的数据类
    ds = env.from_source(file_source, WatermarkStrategy.for_monotonous_timestamps(), "test")

    # 4. transform
    ds = ds.map(lambda x: x)

    # 5. sink
    ds.print()

    # 6. 真正执行代码
    env.execute("ANY_NAME")