pyflink的过滤操作

import json as jsn
import re as regular_expression
import logging as logger
import sys as system
from collections import Counter

from pyflink\ .datastream\ . importDataStream(StreamExecutionEnvironment)
from pyflink\ .datastream\ .functions\ importRuntimeContext,\ FlatMapFunction,\ MapFunction,\ FilterFunction
from pyflink\ common\ .typeinfo\ importTypes

s_env is assigned to the result of retrieving the execution environment.
data is a DataStream instance created by invoking the socketTextStream method on _j_stream_execution_environment with socket address '192.168.137.