Loading [MathJax]/jax/output/CommonHTML/config.js

文章/答案/技术大牛

发布

社区首页 >专栏 >Flink中使用Scala编写出现(...)错误

Flink中使用Scala编写出现(...)错误

CoreDao

发布于 2021-04-12 07:54:05

6410

文章被收录于专栏：BigData_FlinkBigData_Flink

A1 报错

A2 原因

没有导入相应包

A3 解决

在算子前添加 import org.apache.flink.api.scala._

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2021/04/03 ，如有侵权请联系 cloudcommunity@tencent.com 删除

scala

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

登录后参与评论

暂无评论

编辑精选文章

换一批

万字详解高可用架构设计

2497

Go 开发者必备：Protocol Buffers 入门指南

1438

10分钟带你彻底搞懂分布式链路跟踪

950

快速入门Flink (4) —— Flink批处理的DataSources和DataSinks，你都掌握了吗?

flink 批量计算 windows linux yarn

相信经过前面几篇 Flink 文章的学习，大家对于Flink的代码书写一定非常期待。本篇博客，我们就来扒一扒关于Flink的DataSet API的开发。

大数据梦想家

2021/01/27

1.5K0

快速入门Flink (4) —— Flink批处理的DataSources和DataSinks，你都掌握了吗?

Flink - 自己总结了一些学习笔记

api flink 云数据库 SQL Server 大数据 sql

创建一个执行环境，表示当前执行程序的上下文。如果程序是独立调用的，则此方法返回本地执行环境；如果从命令行客户端调用程序以提交到集群，则此方法返回此集群的执行环境，也就是说，getExecutionEnvironment 会根据查询运行的方式决定返回什么样的运行环境，是最常用的一种创建执行环境的方式。

用砖头敲代码

2022/08/30

9460

【Flink】基于 Flink 实时计算商品订单流失量

flink 大数据编程算法正则表达式

第三条规则可以理解为数据流去重，我在上一节已经介绍过了。为了更加专注于计算商品的订单流失量，本篇文章不再关注数据去重。

阿泽 Crz

2020/09/28

1.7K0

从零开始构建Flink开发项目-Scala版

scala 打包大数据

今天要做一个Flink的测试，因此需要创建一个简单的Flink项目，于是找到了下面这种方式来创建一个Flink启动项目。

kongxx

2019/05/17

1.8K0

快速入门Flink (8) —— DataStream 的 Transformation常用操作

flink python css api javascript

写在前面：博主是一名大数据的初学者，昵称来源于《爱丽丝梦游仙境》中的Alice和自己的昵称。作为一名互联网小白，写博客一方面是为了记录自己的学习历程，一方面是希望能够帮助到很多和自己一样处于起步阶段的萌新。由于水平有限，博客中难免会有一些错误，有纰漏之处恳请各位大佬不吝赐教！个人小站:http://alices.ibilibili.xyz/ , 博客主页:https://alice.blog.csdn.net/ 尽管当前水平可能不及各位大佬，但我还是希望自己能够做得更好，因为一天的生活就是一生的缩影。

大数据梦想家

2021/01/27

6230

快速入门Flink (8) —— DataStream 的 Transformation常用操作

大数据Flink进阶（七）：Flink批和流案例总结

大数据处理套件 TBDS flink

在Flink批处理过程中不需要执行execute触发执行，在流式处理过程中需要执行env.execute触发程序执行。

Lansonli

2023/03/27

1.4K0

构建第一个Flink应用-WordCount

flink maven scala 大数据批量计算

使用maven初始化第一个flink的wordcount应用，将应用打包上传到flink-standalone集群，运行起来。

Eights

2020/07/10

4420

快速入门Flink (6) —— Flink的广播变量、累加器与分布式缓存

flink 缓存编程算法分布式大数据

大数据梦想家

2021/01/27

2.8K0

快速入门Flink (7) —— 小白都喜欢看的Flink流处理之DataSources和DataSinks

flink kafka 大数据 windows 数据库

不知不觉，这已经是快速入门Flink系列的第7篇博客了。早在第4篇博客中，博主就已经为大家介绍了在批处理中，数据输入Data Sources 与数据输出Data Sinks的各种分类(传送门:Flink批处理的DataSources和DataSinks)。但是大家是否还记得Flink的概念？Flink是分布式、高性能、随时可用以及准确的为流处理应用程序打造的开源流处理框架。所以光介绍了批处理哪里行呢！本篇博客，我们就来学习Flink流处理的DataSources和DataSinks~

大数据梦想家

2021/01/27

1.1K0

快速入门Flink (7) —— 小白都喜欢看的Flink流处理之DataSources和DataSinks

快速入门Flink (5) ——DataSet必知必会的16种Transformation操作(超详细!建议收藏!)

flink 大数据 java mapreduce scala

大数据梦想家

2021/01/27

1.2K1

快速入门Flink (5) ——DataSet必知必会的16种Transformation操作(超详细!建议收藏!)

大数据Flink进阶（六）：Flink入门案例

java scala api flink 入门

本案例编写Flink代码选择语言为Java和Scala，所以这里我们通过IntelliJ IDEA创建一个目录，其中包括Java项目模块和Scala项目模块，将Flink Java api和Flink Scala api分别在不同项目模块中实现。步骤如下：

Lansonli

2023/03/20

1.2K0

Flink 开发环境搭建

ide maven flink 大数据 linux

Flink 分别提供了基于 Java 语言和 Scala 语言的 API ，如果想要使用 Scala 语言来开发 Flink 程序，可以通过在 IDEA 中安装 Scala 插件来提供语法提示，代码高亮等功能。打开 IDEA , 依次点击 File => settings => plugins 打开插件安装页面，搜索 Scala 插件并进行安装，安装完成后，重启 IDEA 即可生效。

每天进步一点点

2022/07/27

7030

Flink 开发生产问题汇总，亲自解决的才是最宝贵的

yarn node.js hadoop flink 大数据

当一个Flink App背压的时候（例如由外部组件异常引起），Barrier会流动的非常缓慢，导致Checkpoint时长飙升。

kk大数据

2021/02/24

2.9K0

Flink 01 | 十分钟搭建第一个Flink应用和本地集群

maven java scala spark

上一篇文章中我对新一代大数据处理引擎Flink做了简单的介绍，包括：批量计算与流式计算的区别、流式计算引擎的重要性，以及Flink相比其他流式计算引擎的优势。因为Flink性能优秀，解决了之前流式计算引擎的痛点，非常适合电商促销、风险控制、异常检测、金融交易等领域，阿里、腾讯、华为、美团、滴滴等大公司为了保证业务的实时性，正在积极将Flink部署在生产环境。Flink是当前大数据界冉冉升起的新星。比起Hadoop和Spark，精通Flink技术的人才相对较少，因此，掌握Flink技术对于转行或跳槽的朋友来说显得越发重要。

PP鲁

2019/12/26

1.7K0

Flink 的三种WordCount（文末领取Flink书籍）

flink sql 批量计算 scala

今天是 Flink 从 0 到 1 系列的第 2 篇：《WordCount及FlinkSQL》。

Python编程爱好者

2022/09/21

1K0

Flink开发IDEA环境搭建与测试

ide flink 大数据 node.js 编程算法

Flink具有特殊类DataSet并DataStream在程序中表示数据。您可以将它们视为可以包含重复项的不可变数据集合。在DataSet数据有限的情况下，对于一个DataStream元素的数量可以是无界的。

星哥玩云

2022/07/26

1.3K0

大数据-Flink编程

机器学习神经网络深度学习人工智能 flink

groupBy会将一个DataSet转化为一个GroupedDataSet，聚合操作会将GroupedDataSet转化为DataSet。如果聚合前每个元素数据类型是T，聚合后的数据类型仍为T。

码客说

2022/10/04

1.1K0

Flink实现WordCount（实操详细步骤）

flink 大数据 ide maven linux

先说一下我的环境： Flink 1.9 开发工具：Idea Maven版本：3.3.9 Linux：CentOS 7 演示语言：Scala 2.11

bboy枫亭

2020/09/22

4K0

Flink单机版安装与wordCount

spark http 大数据 hadoop

Flink为大数据处理工具，类似hadoop,spark.但它能够在大规模分布式系统中快速处理，与spark相似也是基于内存运算，并以低延迟性和高容错性主城，其核心特性是实时的处理流数据。从此大数据生态圈又再填一员。。。具体详解，还要等之后再分享，这里就先简要带过~

用户3003813

2018/09/06

1.3K0

Flink 实时流Wordcount案例

java scala

Scala版本 import org.apache.flink.api.java.utils.ParameterTool import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment import org.apache.flink.streaming.api.windowing.time.Time object SocketWindowWordCountScala { def main(args: Array[String]

编程那点事

2023/02/25

4320