问答 2022-06-21 来自:开发者社区

有没有大佬实现Flink自定义es source的

如题

文章 2022-06-10 来自:开发者社区

Flink 实现自定义滑动窗口

背景一般情况下 Flink 提供的窗口可以满足我们大部分的场景,但是有时候我们需要计算一个固定时间范围内的数据,比如实时计算每天凌晨到第二天凌晨的数据,或者每天上午 7 点到第二天上午 7 点。类似于这种情况 Flink 默认提供的窗口是不支持的,因为 Flink 计算窗口的开始时间和结束时间是根据数据本身携带的时间戳然后把数据划分到不同的窗口的,所以它不是一个固定的范围。这个时候就需要我们自己....

文章 2022-06-09 来自:开发者社区

Flink 1.14.0 消费 kafka 数据自定义反序列化类

在最近发布的 Flink 1.14.0 版本中对 Source 接口进行了重构,细节可以参考 FLIP-27: Refactor Source Interface重构之后 API 层面的改动还是非常大的,那在使用新的 API 消费 kafka 数据的时候如何自定义序列化类呢?Kafka SourceKafkaSource<String> source = KafkaSource.&am...

文章 2022-06-09 来自:开发者社区

Flink SQL 自定义 redis connector

一般情况下,我们不需要创建新的 connector,因为 Flink SQL 已经内置了丰富的 connector 供我们使用,但是在实际生产环境中我们的存储是多种多样的,所以原生的 connector 并不能满足所有用户的需求,这个时候就需要我们自定义 connector,这篇文章的重点就是介绍一下如何实现自定义 Flink SQL connector ?先来看一下官网的一张 connecto....

Flink SQL 自定义 redis connector
文章 2022-05-30 来自:开发者社区

【源码解读】Flink-Kafka连接器自定义序列器和分区器

@TOC开篇导语Flink将数据sink至Kafka的过程中,在初始化生产者对象FlinkKafkaProducer时通常会采用默认的分区器和序列化器,这样数据只会发送至指定Topic的某一个分区中。对于存在多分区的Topic我们一般要自定义分区器和序列化器,指定数据发送至不同分区的逻辑。此篇博客所涉及的组件版本Flink:1.10.0Kafka:2.3.0序列化器在Kafka生产者将数据写入至....

问答 2022-04-24 来自:开发者社区

我自定义了一个Kafka reporter用来上报flink的metric,但是写不到Kafka

自定义了一个Kafka reporter继承abstractreporter类,实现scheduled接口,重写了report方法,将数据发送至Kafka,在配置文件也正确配置了,但是Kafka里没数据

文章 2022-04-11 来自:开发者社区

Flink的sink实战之四:自定义

欢迎访问我的GitHub这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos继承关系在正式编码前,要先弄清楚对sink能力是如何实现的,前面我们实战过的print、kafka、cassandra等sink操作,核心类的继承关系如下图所示:可见实现sink能力的关键,是实现RichFunction和SinkFunction接口,前者....

Flink的sink实战之四:自定义
文章 2022-04-02 来自:开发者社区

Flink的DataSource三部曲之三:自定义

欢迎访问我的GitHub这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos本篇概览本文是《Flink的DataSource三部曲》的终篇,前面都是在学习Flink已有的数据源功能,但如果这些不能满足需要,就要自定义数据源(例如从数据库获取数据),也就是今天实战的内容,如下图红框所示:环境和版本本次实战的环境和版本如下:JDK:1....

Flink的DataSource三部曲之三:自定义
文章 2022-01-09 来自:开发者社区

Flink cdc自定义format格式数据源

总览变更数据捕获 (CDC) 已成为一种流行的模式,用于从数据库捕获已提交的变更并将这些变更传播给下游消费者,例如保持多个数据存储同步并避免常见的陷阱,例如双重写入。 能够轻松地将这些变更日志摄取和解释到 Table API/SQL 中一直是 Flink 社区的一个非常需要的功能,现在 Flink 1.11 可以实现。为了将 Table API/SQL 的范围扩展到 CDC 等用例,Flink ....

Flink cdc自定义format格式数据源
问答 2021-12-09 来自:开发者社区

Flink 流处理API的编程中如何自定义实现Sink?

Flink 流处理API的编程中如何自定义实现Sink?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注