Apache Flink:哪些方法调用会引起执行?
创始人
2024-09-04 02:30:22
0

在Apache Flink中,有几种方法调用可以触发执行任务,包括以下几种:

  1. 执行环境的execute()方法:这是启动Flink作业执行的方法,调用该方法将触发作业的执行。
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
// 定义作业逻辑
DataStream dataStream = env.fromElements("Hello", "World");
dataStream.print();
// 执行作业
env.execute("My Job");
  1. 数据源的操作方法:当调用数据源的操作方法时,例如source.map()source.filter()等,这些方法会触发作业执行。
DataStream source = env.fromElements("Hello", "World");
DataStream result = source.map(new MapFunction() {
    @Override
    public Integer map(String value) throws Exception {
        return value.length();
    }
});
result.print();
  1. 算子的操作方法:当调用算子的操作方法时,例如map()filter()reduce()等,这些方法也会触发作业执行。
DataStream source = env.fromElements("Hello", "World");
DataStream result = source.map(new MapFunction() {
    @Override
    public Integer map(String value) throws Exception {
        return value.length();
    }
}).filter(new FilterFunction() {
    @Override
    public boolean filter(Integer value) throws Exception {
        return value > 5;
    }
});
result.print();
  1. 调用executeAndCollect()方法:该方法与execute()方法类似,但它不仅执行作业,还将结果收集到本地变量中。
DataStream source = env.fromElements("Hello", "World");
DataStream result = source.map(new MapFunction() {
    @Override
    public Integer map(String value) throws Exception {
        return value.length();
    }
});
List resultList = env.executeAndCollect("My Job", result);
for (Integer value : resultList) {
    System.out.println(value);
}

这些方法调用将触发Flink作业的执行,执行过程中将会依次执行定义的算子逻辑。

相关内容

热门资讯

三分钟了解(Wepoke俱乐部... WePoker透视辅助版本稳定性对比与推荐‌:三分钟了解(Wepoke俱乐部)外挂透明挂辅助工具(透...
专业讨论(德扑之星埋牌)外挂透... 专业讨论(德扑之星埋牌)外挂透明挂辅助器安装(透视)竟然是真的有挂(wpk教程)(哔哩哔哩);玩家必...
揭秘真相(pokerrrr2挂... 揭秘真相(pokerrrr2挂)外挂透明挂辅助机制(辅助挂)果真是真的有挂(细节揭秘)(哔哩哔哩);...
最新研发(wpk插件挂)外挂透... 最新研发(wpk插件挂)外挂透明挂辅助器(透视)竟然是真的有挂(详细教程)(哔哩哔哩);wpk插件挂...
传递经验(微扑克ai)外挂透明... 相信很多朋友都在电脑上玩过微扑克ai吧,但是很多朋友都在抱怨用电脑玩起来不方便。为此小编给大家带来了...
必知教程(德州ai人工智能)外... 必知教程(德州ai人工智能)外挂透明挂辅助APP(透视)其实是真的有挂(2024新版总结)(哔哩哔哩...
透明神器(WPK代码)外挂透明... 透明神器(WPK代码)外挂透明挂辅助app(透视)的确是真的有挂(解密教程)(哔哩哔哩)相信很多朋友...
重大来袭(Wepoke插件)外... 此外,数据分析德州(Wepoke插件)辅助神器app还具备辅助透视行为开挂功能,通过对客户Wepok...
一分钟揭秘(新版Wepoke)... 一分钟揭秘(新版Wepoke)外挂透明挂辅助软件(辅助挂)其实是真的有挂(第三方教程)(哔哩哔哩);...
玩家必备科技(德州ai智能系统... 玩家必备科技(德州ai智能系统)外挂透明挂辅助器安装(辅助挂)确实是真的有挂(存在挂教程)(哔哩哔哩...