1、概述
1)webUI依赖
org.apache.flink flink-runtime-web_${scala.binary.version}${flink.version}
2)调用StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(configuration);
3)可以通过configuration配置webUI的端口号
2、代码实现
import org.apache.flink.configuration.Configuration; import org.apache.flink.streaming.api.datastream.DataStreamSink; import org.apache.flink.streaming.api.datastream.DataStreamSource; import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; public class LocalWebUI { public static void main(String[] args) throws Exception { // 创建本地执行环境,并设置 webUI 参数 Configuration configuration = new Configuration(); configuration.setInteger("rest.port", 8081); // 创建一个带 webUI 的本地执行环境 StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(configuration); // 从端口接入数据 DataStreamSourcelines = env.socketTextStream("localhost", 8888); // 使用map方法对输入的单词转为大写 SingleOutputStreamOperator uppered = lines.map(line -> line.toUpperCase()); DataStreamSink print = uppered.print(); env.execute(); } }
3、执行结果
1)输入测试数据
nc -lk 8888 hello
控制台输出执行结果
HELLO
2)localhost:8081查看webUI
猜你喜欢
- 12天前(a级景区评定机构)全国A级旅游景区创建与提升培训班在敦煌市举办
- 12天前(香港航空三亚航线复航了吗)香港航空三亚航线复航
- 12天前(中旅酒店 维景)中旅酒店首次AI数字人直播亮相南京维景
- 12天前(安徽民航君澜大饭店装饰设计招标)集东方文化气息,品徽派隽美风韵----安徽民航君澜大饭店静待绽放
- 12天前(甘肃文旅项目)甘肃省文旅产业链招商引资推介会在天水成功举办
- 12天前(云南滇陇工程咨询有限公司)陇滇携手谋发展 文旅合作谱新篇
- 12天前(新西兰航空官方网站)新西兰航空85周年焕新启航 全方位客舱升级,飞「悦」快意时光
- 12天前(万豪旅享家活动2021)精彩上新,漫享夏日----跟随万豪旅享家新开酒店解锁夏日旅行灵感
- 12天前(星级饭店的发展困境)星级饭店转型之路:从市场逻辑到行业实践的深度探索
- 12天前(美诺酒店集团旗下臻选品牌m collection)美诺酒店集团启动盛橡品牌战略焕新 开启全球扩张新篇章
网友评论
- 搜索
- 最新文章
- (2020广州车展哈弗)你的猛龙 独一无二 哈弗猛龙广州车展闪耀登场
- (哈弗新能源suv2019款)智能科技颠覆出行体验 哈弗重塑新能源越野SUV价值认知
- (2021款全新哈弗h5自动四驱报价)新哈弗H5再赴保障之旅,无惧冰雪护航哈弗全民电四驱挑战赛
- (海南航空现况怎样)用一场直播找到市场扩张新渠道,海南航空做对了什么?
- (visa jcb 日本)优惠面面俱到 JCB信用卡邀您畅玩日本冰雪季
- (第三届“堡里有年味·回村过大年”民俗花灯会活动)第三届“堡里有年味·回村过大年”民俗花灯会活动
- (展示非遗魅力 长安启源助力铜梁龙舞出征)展示非遗魅力 长安启源助力铜梁龙舞出征
- (阿斯塔纳航空公司)阿斯塔纳航空机队飞机数量增至50架
- (北京香港航班动态查询)香港快运航空北京大兴新航线今日首航
- (我在港航“呵护”飞机 每一次安全着陆就是最好的荣誉)我在港航“呵护”飞机 每一次安全着陆就是最好的荣誉
- 热门文章