to see if there are any problems: # Get the installation directory of PyFlink python3 -c "import pyflink;import os;print(os.path.dirname(os.path.abspath(pyflink.__ ˓→file__)))" # It will output a path messages in the log file as following: # Get the installation directory of PyFlink python3 -c "import pyflink;import os;print(os.path.dirname(os.path.abspath(pyflink.__ ˓→file__)))" (continues on next page) latest version Create a TableEnvironment [1]: # Create a batch TableEnvironment from pyflink.table import EnvironmentSettings, TableEnvironment env_settings = EnvironmentSettings.in_batch_mode() table_env

to see if there are any problems: # Get the installation directory of PyFlink python3 -c "import pyflink;import os;print(os.path.dirname(os.path.abspath(pyflink.__ ˓→file__)))" # It will output a path messages in the log file as following: # Get the installation directory of PyFlink python3 -c "import pyflink;import os;print(os.path.dirname(os.path.abspath(pyflink.__ ˓→file__)))" (continues on next page) latest version Create a TableEnvironment [1]: # Create a batch TableEnvironment from pyflink.table import EnvironmentSettings, TableEnvironment env_settings = EnvironmentSettings.in_batch_mode() table_env

35 / 79 Word Count in Spark Streaming (1/6) ▶ First we create a StreamingContex import org.apache.spark._ import org.apache.spark.streaming._ // Create a local StreamingContext with two working threads