文件名称:
pulsar-flink:使用Apache Pulsar和Apache Flink进行弹性数据处理-源码
开发工具:
文件大小: 436kb
下载次数: 0
上传时间: 2021-01-30
详细说明:脉冲星Flink连接器
Pulsar Flink连接器使用和实现弹性数据处理。
有关中文文档的详细信息,请参见。
先决条件
Java 8或更高版本
Flink 1.9.0或更高版本
Pulsar 2.4.0或更高版本
基本信息
本节介绍有关Pulsar Flink连接器的基本信息。
客户
当前,支持以下Flink版本。
Flink :它们维护在。
Flink 1.11:它在维护。
Flink 1.12:它在维护。
注意由于Flink的API发生了很大变化,因此我们主要致力于master分支中的新功能,并修复其他分支中的错误。
JAR包位于。
对于使用SBT,Maven或Gradle的项目,可以为项目设置以下参数。
FLINK_VERSION :目前,版本1.9 , 1.11 ,和1.12可用。
SCALA_BINARY_VERSION :此参数定义Flink使用的Scala版本。 提供版本2.11和2.12 。
PULSAR_FLINK_VERSION :它是Pulsar Flink连接器的版本。 通常,对于主发行版,请使用三位数版本(例如,版本2.7.0 );对
(系统自动生成,下载前可以参看下载内容)
下载文件列表
相关说明
- 本站资源为会员上传分享交流与学习,如有侵犯您的权益,请联系我们删除.
- 本站是交换下载平台,提供交流渠道,下载内容来自于网络,除下载问题外,其它问题请自行百度。
- 本站已设置防盗链,请勿用迅雷、QQ旋风等多线程下载软件下载资源,下载后用WinRAR最新版进行解压.
- 如果您发现内容无法下载,请稍后再次尝试;或者到消费记录里找到下载记录反馈给我们.
- 下载后发现下载的内容跟说明不相乎,请到消费记录里找到下载记录反馈给我们,经确认后退回积分.
- 如下载前有疑问,可以通过点击"提供者"的名字,查看对方的联系方式,联系对方咨询.