Flink SourceFunction/SinkFunction

一.简介

Source 是Flink的输入，可以串行，并行，延迟，设置时间窗口等等。

Sink是Flink的输出，设置任意源。

Flink的编程模型就可以概况成接入Source，然后进行数据转换操作，再将处理结果Sink出来。

二.SourceFunction

非并行

class CustomNonParallelSourceFunction extends SourceFunction[Long] {var count = 0Lvar isRunning = trueoverride def run

Flink SourceFunction/SinkFunction相关推荐

flink SourceFunction could not be inferred. Support for synthetic interfaces, lambdas, and generic
2.The types of the interface org.apache.flink.streaming.api.functions.source.SourceFunction could no ...
flink DataStream API使用及原理
传统的大数据处理方式一般是批处理式的,也就是说,今天所收集的数据,我们明天再把今天收集到的数据算出来,以供大家使用,但是在很多情况下,数据的时效性对于业务的成败是非常关键的. Spark 和 Flin ...
1.10.Flink DataStreamAPI(API的抽象级别、Data Sources、connectors、Source容错性保证、Sink容错性保证、自定义sink、partition等)
1.10.Flink DataStreamAPI 1.10.1.Flink API的抽象级别 1.10.2.DatSource部分详解 1.10.2.1.DataStream API之Data Sou ...
HBase读写的几种方式（三）flink篇
1. HBase连接的方式概况主要分为: 纯Java API读写HBase的方式: Spark读写HBase的方式: Flink读写HBase的方式: HBase通过Phoenix读写的方式: 第一 ...
Flink常见流处理API
Flink 流处理API的编程可以分为environment,source,transform,sink四大部分 1 Flink支持的数据类型在Flink底层因为要对所有的数据序列化,反序列化对 ...
flink source和sink
flink中的source作为整个stream中的入口,而sink作为整个stream的终点. SourceFunction为所有flink中source的根接口,其定义了run()方法和cancel ...
【Flink】基于 Flink CEP 实时计算商品订单流失量
1.概述转载:https://blog.csdn.net/tzs_1041218129/article/details/108786597 假设有个需求需要实时计算商品的订单流失量,规则如下: 用户 ...
Flink流式计算从入门到实战三
文章目录四.Flink DataStream API 1.Flink程序的基础运行模型 2.Environment 运行环境 3.Source 3.1 基于File的数据源 3.2 基于Socket ...
看完就会flink基础API
文章目录一.执行环境(Execution Environment) 1.创建执行环境 2.执行模式(Execution Mode) 3.触发程序执行二.源算子(Source) 1.数据源类准备 2 ...

Flink SourceFunction/SinkFunction

一.简介

二.SourceFunction

Flink SourceFunction/SinkFunction相关推荐

最新文章

热门文章