PyFlink的核心数据流函数及其返回值机制

//yield

import json
import re
import logging
import sys
from collections import Counter

from pyflink.datastream importDataStream,StreamExecutionEnvironment
from pyflink.datastream.functions importRuntimeContext,FlatMapFunction,MapFunction,KeySelector
from pyflink.common.typeinfo importTypes

s_env被赋值为StreamExecutionEnvironment获取的执行环境实例。
通过将来自s_env._j_stream_execution_environment socketTextStream的数据连接到192.168.137.201上的端口8899上。
该数据流将被用于后续处理流程。
使用print方法输出到控制台。
定义一个返回固定字符串'999'的函数get_key。
LogEvent类初始化时默认属性world设置为空字符串。

定义初始化方法接收三个参数：自变量self、世界坐标world以及计数值count。
在初始化过程中：
将世界坐标