flink 订阅
Apache Flink是由Apache软件基金会开发的开源流处理框架,其核心是用Java和Scala编写的分布式流数据流引擎。Flink以数据并行和流水线方式执行任意流数据程序,Flink的流水线运行时系统可以执行批处理和流处理程序。此外,Flink的运行时本身也支持迭代算法的执行。 [1] 展开全文
Apache Flink是由Apache软件基金会开发的开源流处理框架,其核心是用Java和Scala编写的分布式流数据流引擎。Flink以数据并行和流水线方式执行任意流数据程序,Flink的流水线运行时系统可以执行批处理和流处理程序。此外,Flink的运行时本身也支持迭代算法的执行。 [1]
信息
稳定版本
Apache软件基金会 [1]
类    型
1.8.0 [1]
中文名
弗林克
外文名
Flink [1]
flink开发
Apache Flink是由Apache软件基金会内的Apache Flink社区基于Apache许可证2.0开发的,该项目已有超过100位代码提交者和超过460贡献者。 [2]  是由Apache Flink的创始人创建的公司。目前,该公司已聘用了12个Apache Flink的代码提交者。 [3] 
收起全文
精华内容
下载资源
问答
  • Flink学习 Flink Scala版本 卡夫卡版 1.10.0 2.11+ 0.10+ Maven 模板 : https://www.mvnjar.com/org.apache.flink/flink-quickstart-scala/jar.html <br> 注意 : 当在idea上调试时,先将 es-shade install。...
  • 10. Flink运行架构-Flink并行数据流 11. Flink运行架构-Task和Operator chain 12. Flink运行架构-任务调度与执行 13. Flink运行架构-任务槽与槽共享 第四章 Dataset开发 01.入门案例 02.入门案例-构建工程、log4j....
  • 共课程包含9个章节:Flink安装部署与快速入门、Flink批处理API、Flink流处理API、Flink高级API、Flink-Table与SQL、Flink-Action综合练习、Flink-高级特性和新特性、Flink多语言开发、Flink性能调优 课程目录: ...
  • 分享课程——《Flink动态规则实时智能营销系统(Flink+Clickhouse+Drools整合实现)》,基于Flink1.12.0版本,完整版,附带源码和课件,包含最新2021年8月升级版! 本系统,是一个基于事件驱动且可进行动态规则...
  • doris-flink-connector

    2022-03-25 14:43:18
    <flink.version>1.13.5</flink.version> <libthrift.version>0.13.0 <arrow.version>5.0.0 <maven-compiler-plugin.version>3.8.1 <maven-javadoc-plugin.version>3.3.0 <maven-source-plugin.version>3.2.1...
  • Flink码头工人 Apache Flink码头工人镜像到: 设置运行一个Flink Master和多个Flink Worker的独立集群 在Scala,Java或Python中构建Flink应用程序以在Flink集群上运行 当前支持的版本: 用于Hadoop 3.2和Scala ...
  • 接上文:Flink笔记(十八):Flink 之 StateBackend 介绍 & 使用,本文介绍 Flink 从 Checkpoint 中恢复数据。 当 Flink 任务提交后,只有遇到 1.程序错误、2.人为 Cancel掉,任务就会停止。 1. 任务异常,设置保存 ...
  • flink 1.15.0安装包

    2022-05-06 09:25:23
    flink 1.15.0安装包
  • 当前的版本应该是flink1.12.2,kudu是1.13.0。 按照我自己的环境将flink升级到1.14.0也就是目前最新的版本,kudu降到1.10.0。 由于flink api的改动,所以修改了一丢丢源码,同时最后编译打包时跳过了deprecation警告...
  • CDH6.3.2集成Flink1.14.4

    2022-04-18 16:06:04
    1、资源包括commons-cli-1.5.0,flink-shaded-hadoop-2-uber-3.0.0-cdh6.3.2-10.0放入flink的lib包下使用 2、部署过程中有Redaction rules file doesn't exist, not redacting logs. file: redaction-rules.json和...
  • flink 集成 hive 所需要的依赖包,包括 antlr-runtime-3.5.2.jar flink-connector-hive_2.12-1.14.4.jar flink-shaded-hadoop-3-3.1.1.7.2.9.0-173-9.0.jar flink-sql-connector-hive-3.1.2_2.12-1.14.4.jar hive-...
  • Flink 整合 Kafka 基本步骤,请参考:Flink 基础整合 Kafka。本文仅用来介绍 Flink 整合 Kafka 实现 Exactly-Once。 1.什么是Exactly-Once  恰好处理一次的意思。不管在处理的时候是否有异常发生,计算的结果都...
  • docker安装flink sql组件

    2022-01-26 20:14:21
    flink sql学习组件,里面包含flinkflink sql clienk、kafka 、ES、mysql等,使用docker命令加载即可,适用于macos,linux系统学习flink
  • flink零基础入门.pdf

    2020-06-09 14:19:03
    Apache Flink 进阶(一):Runtime 核心机制剖析 4 Apache Flink 进阶(二):时间属性深度解析 18 Apache Flink 进阶(三):Checkpoint 原理剖析与应用实践 30 Apache Flink 进阶(四):Flink on Yarn/K8s 原理...
  • Flink基础讲义.docx

    2020-08-19 19:59:20
    第一章 Flink简介【了解】 1 1.1. Flink的引入 1 1.2. 什么是Flink 4 1.3. Flink流处理特性 4 1.4. Flink基石 5 1.5. 批处理与流处理 6 第二章 Flink架构体系 8 第三章 Flink集群搭建 12 第四章 DataSet开发 48 第五...
  • flink入门实战

    2021-06-15 00:58:52
    flink处理kafka消息流场景为例,将接受到的kafka消息sink到mysql、elastic、hdfs、kafka,通过真实的案例,助你入门flink计算框架。课程案例代码也可移植到其它业务系统,实现快速开发。
  • Flink源码解析.zip

    2019-06-04 22:45:13
    1、Flink 源码解析 —— 源码编译运行 2、Flink 源码解析 —— 项目结构一览 3、Flink 源码解析—— local 模式启动流程 4、Flink 源码解析 —— standalonesession 模式启动流程 5、Flink 源码解析 —— ...
  • 本文主要来介绍 Flink 读取 Kafka数据,并实时下沉(Sink)数据到 Redis 的过程。  通过如下链接:Flink官方文档,我们知道数据保存到 Redis 的容错机制是 at least once。所以我们通过幂等操作,使用新数据覆盖旧...
  • 在Kubernetes上进行FlinkFlink建筑 一个活动的JobManager(JM) 几个TaskManagers(TM) 每个集群一份工作 不断发展的工作部署理念 将集群生命周期绑定到工作生命周期) 理想情况下,这项工作是一流的。 ...
  • flink-sql-submit-client 执行Flink SQL 文件的客户端 Flink 版本:flink 1.11.0 其他版本待测试 是在的基础上修改而来 使用简单方便 需要指定FLINK_HOME 下载上面code中的jar包 修改 sql-submit.sh 脚本中jar包的...
  • flink1.14.3 cdc jar包

    2022-03-13 14:28:57
    flink-1.14.3 的所有flink cdc jar包,包含 oracle,mysql,postgres,sqlserver,mongodb
  • 基于Apache-Bahir-Kudu连接器改造而来的满足公司内部使用的Kudu连接器,支持特性范围分区,定义哈希分桶数,支持Flink1.11.x动态数据源等,改造后已贡献部分功能给社区。 使用姿势 clone代码后,改造pom项目坐标后...
  • flink 以connector形式连接clickhouse,资源稀缺,阿里云已经找不到了 id Int, age Int, sex Int, create_date Date ) WITH ( 'connector' = 'clickhouse', 'url' = 'jdbc:clickhouse://10.1.3.176:8123/test'...
  • flink 1.12及以上 兼容cdh6所需要的flink-shaded-hadoop jar包
  • 导读:本文重点为大家介绍 Flink Python API 的现状及未来规划,主要内容包括:Apache Flink Python API 的前世今生和未来发展;Apache Flink Python API 架构及开发环境搭建;Apache Flink Python API 核心算子介绍...
  • 基于Flink的大数据实施城市交通监控平台.zip 大学生课程设计 基于flink的课程设计 自己大二写的课程设计
  • Flink原理与实践-Flink的部署和配置.pdf
  • 主要功能是基于Flink从kafka消费数据,并做avro反序列化、解析、统计等,最后结果数据发送到redis或者influxdb(时序数据库)。另外我提供Flink答疑服务,帮助大家快速理解项目和Flink入门,如有需要可添加微信:z...
  • 适用于CDH5.2 - CDH6.3.2 的 flink版本,FLINK-1.14.3-BIN-SCALA_2.12.tar
  • flink安装所需要的第三方jar,即flink-shaded-hadoop-2-uber-2.7.5-10.0.jar

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 118,498
精华内容 47,399
关键字:

flink