1. 阿里云>
  2. 云栖社区>
  3. 主题地图>
  4. K>
  5. kafka scala api

当前主题:kafka scala api

玩转社区开源贡献,看这篇就够了!

云栖号资讯:【点击查看更多行业资讯】 在这里您可以找到不同行业的第一手的上云资讯,还在等什么,快来! 作为最早一批非谷歌的 TensorFlow 社区贡献者,同时也是 TensorFlow committer 和 SIG IO maintainer,我将在这

阅读全文

从未如此简单:10分钟带你逆袭Kafka!

云栖号资讯:【点击查看更多行业资讯】 在这里您可以找到不同行业的第一手的上云资讯,还在等什么,快来! 【编者的话】Apache Kafka 是一个快速、可扩展的、高吞吐的、可容错的分布式“发布-订阅”消息系统, 使用 Scala 与 Java 语言编写,能够

阅读全文

Flink 1.11 新特性之 SQL Hive Streaming 简单示例

7月7日,Flink 1.11 版本发布,与 1.10 版本相比,1.11 版本最为显著的一个改进是 Hive Integration 显著增强,也就是真正意义上实现了基于 Hive 的流批一体。 本文用简单的本地示例来体验 Hive Streaming 的

阅读全文

Flink 1.11:更好用的流批一体 SQL 引擎

许多的数据科学家,分析师和 BI 用户依赖交互式 SQL 查询分析数据。Flink SQL 是 Flink 的核心模块之一。作为一个分布式的 SQL 查询引擎。Flink SQL 提供了各种异构数据源的联合查询。开发者可以很方便地在一个程序中通过 SQL 编

阅读全文

官宣 | 千呼万唤,Apache Flink 1.11.0 正式发布啦!

来源 | Apache Flink 官方博客翻译 | 高赟(云骞) Apache Flink 社区很荣幸的宣布 Flink 1.11.0 版本正式发布!超过 200 名贡献者参与了 Flink 1.11.0 的开发,提交了超过 1300 个修复或优化。这些修

阅读全文

解决问题 1474 个,Flink 1.11 究竟有哪些易用性上的改善?

作者 | 王治江,Apache Flink PMC 7月7日,Flink 1.11.0 正式发布了,作为这个版本的 release manager 之一,我想跟大家分享一下其中的经历感受以及一些代表性 feature 的解读。在进入深度解读前,我们先简单了解

阅读全文

Flink 1.11.0 发布,有哪些值得关注的新特性?

云栖号资讯:【点击查看更多行业资讯】 在这里您可以找到不同行业的第一手的上云资讯,还在等什么,快来! ![image](https://yqfile.alicdn.com/85998512eedd2e1b7c32f2501b41be28d170fbc4.pn

阅读全文

Flink 1.10 SQL、HiveCatalog 与事件时间整合示例

Flink 1.10 与 1.9 相比又是个创新版本,在我们感兴趣的很多方面都有改进,特别是 Flink SQL。本文用根据埋点日志计算 PV、UV 的简单示例来体验 Flink 1.10 的两个重要新特性: 一是 SQL DDL 对事件时间的支持; 二是

阅读全文

kafka scala api相关问答

查看更多 提问题

Flink 的 Scala API 怎么指定 时间字段

代码如下 ```scala import com.alibaba.fastjson.JSON import com.alibaba.fastjson.serializer.SerializeFilter import org.apache.flink.

阅读全文

flink表api异常

"我正在使用flink表api,使用kafka作为输入源,使用json作为表模式。提交程序时出现此错误:```程序完成以下异常: org.apache.flink.client.program.ProgramInvocationException: Th

阅读全文

如何在Scala中使用Flink的KafkaSource?

尝试用Flink的KafkaSource运行一个简单的测试程序,内容如下: Flink 0.9 Scala 2.10.4 Kafka 0.8.2.1 import org.apache.flink.streaming.api.scala._ impo

阅读全文

kafka.common.KafkaException:错误的请求类型18

我正在运行这段代码。streamingInputDF是Kafka主题的readStream。我正在运行spark 2.4.0和Kafka 0.10.2 val activityQuery = streamingInputDF.writeStream .

阅读全文

在java中如何获取或初始化scala.collection.immutable.Map?

java调用kafka API时需要一个一个scala.collection.immutable.Map参数,但不知道如何初始化或通过其他API获取

阅读全文

Flink 从Checkpoint恢复失败

``` import java.util.Properties import org.apache.flink.api.common.serialization.SimpleStringSchema import org.apache.flink.str

阅读全文

flink消费kafka报错 Couldn't retrieve the JobExecutionResult from the JobManager

Starting execution of program Submitting job with JobID: aca099531abda417700799ace53e0fbd. Waiting for job completion. -------

阅读全文

试图将Fuple写入Flink Kafka接收器

我正在尝试编写一个流媒体应用程序,它既可以读取也可以写入Kafka。我目前有这个,但我必须把我的元组课程串起来。 object StreamingJob { def main(args: Array[String]) { // set u

阅读全文