import json import re import logging import sys from collections import Counter from pyflink.datastream import StreamExecutionEnvironment, RuntimeExecutionMode, WindowFunction from pyflink.datastream import DataStream, StreamExecutionEnvironment from pyflink.datastream.functions import RuntimeContext, FlatMapFunction, MapFunction from pyflink.common.typeinfo import Types from pyflink.common import ExecutionMode s_env = StreamExecutionEnvironment.get_execution_environment() config=(s_env.get_config()) print(config.set_execution_mode(ExecutionMode.BATCH))
3、Flink执行模式(流/批)详解(上)
2024-04-28 19:56:04 38 阅读