注册会员 | 设为首页 | 加入收藏夹
您好，欢迎光临本网站！[请登录] ！[注册会员]！  

搜索资源列表

  1. flink-source-code-analysis:Apache Flink源码分析系列，基于git tag 1.1.2-源码

  2. flink-源代码分析 Apache Flink源码分析系列，基于git tag 1.1.2 Apache Flink被视为第四代的大数据处理框架，它融合了流式计算和批处理【批处理被视为流式计算的特例】 在流式计算方面，使用分布式快照【检查点】实现了高效的数据不丢的机制从而实现准确的一次；使用WaterMark技术实现了窗口计算中延迟数据的处理，同时对流式计算的窗口时间定义分类：处理时间，摄取时间，事件时间 本人觉得flink的这些特性一定程序上可以窥探出大数据的未来方向，所以花了些时间来阅读

  3. 所属分类：其它

  1. flink-training:Apache Flink培训练习-源码

  2. Apache Flink培训练习 练习以及文档中的培训内容。 目录 设置您的开发环境 以下说明将指导您完成设置开发环境的过程，以开发，调试和执行Flink开发人员培训练习和示例的解决方案。 软件需求 Flink支持Linux，OS X和Windows作为Flink程序和本地执行的开发环境。 Flink开发设置需要以下软件，并且应将其安装在系统上： Java 8或Java 11的JDK（JRE不够；不支持Java的其他版本） 吉特 具有Gradle支持的Java（和/或Scala）开发IDE。我

  3. 所属分类：其它

    • 发布日期：2021-03-19
    • 文件大小：197kb
    • 提供者：weixin_42098104

  1. flink-memory-buffer:Apache Flink的内存缓冲区-源码

  2. flink内存缓冲区 Apache Flink的内存中缓冲区，可用于在某些数据偏斜情况下实现更高的吞吐量。 写出： : 用法： import org . apache . flink . streaming . api . scala . _ import extensions . _ import FlinkOps . _ val env : StreamExecutionEnvironment = ??? val words = Seq ( " this " , " is " ,

  3. 所属分类：其它

    • 发布日期：2021-03-07
    • 文件大小：10kb
    • 提供者：weixin_42133415

  1. 平流层：Stratosphere现在是Apache Flink-源码

  2. 存储库已移动 Stratosphere现在是项目，并已重命名为 。 该存储库将不再维护。 请移至以下GitHub存储库： git clone https://github.com/apache/incubator-flink.git 谢谢！ 如果您具有旧的Stratosphere存储库的现有克隆，则可以更新您的遥控器以指向新的存储库： git remote set-url origin https://github.com/apache/incubator-flink.git

  3. 所属分类：其它

  1. gradoop：使用Apache Flink进行分布式图分析-源码

  2. Gradoop：Hadoop上的分布式图分析 是一个基于构建可扩展图形分析的开源（ALv2）研究框架。 它提供了一个图数据模型，该通过逻辑图的概念扩展了广泛的，并进一步提供了可应用于单个逻辑图和逻辑图集合的运算符。 这些运算符的组合允许对图分析工作流进行灵活的声明式定义。 Gradoop可以轻松集成到已经使用Flink:registered:运算符和Flink:registered:库（即Gelly，ML和Table）的工作流中。 Gradoop正在开发中，这意味着API可能会更改。 当前，它

  3. 所属分类：其它

  1. flink-web：Apache Flink网站-源码

  2. 网页链接 该存储库包含Flink网站： : 。 您可以在以下位置找到此存储库的说明： : 。 在本地测试更改 您可以使用如下所示的Docker来构建网站（而无需增加主机环境）。 作为此调用的一部分传递的参数将转发到build.sh 。 # starts website with future post being disabled bash docker-build.sh -p # starts website including also future posts bash doc

  3. 所属分类：其它

    • 发布日期：2021-02-05
    • 文件大小：139mb
    • 提供者：weixin_42120283

  1. flink阴影的：Apache Flink阴影的工件存储库-源码

  2. flink阴影的：Apache Flink阴影的工件存储库

  3. 所属分类：其它

    • 发布日期：2021-02-05
    • 文件大小：50kb
    • 提供者：weixin_42134097

  1. flink-cdc-connectors：更改Apache Flink的数据捕获（CDC）连接器-源码

  2. Flink CDC连接器 Flink CDC连接器是Apache Flink的一组源连接器，使用更改数据捕获（CDC）从不同的数据库中提取更改。 Flink CDC连接器将Debezium集成为引擎来捕获数据更改。 因此，它可以充分利用Debezium的功能。 进一步了解什么是 。 本自述文件旨在简要介绍Flink CDC连接器的核心功能。 有关详细文档，请参阅。 支持（经过测试）的连接器 数据库 版 MySQL 数据库：5.7，8.0.x JDBC驱动程序：8.0.16 PostgreS

  3. 所属分类：其它

    • 发布日期：2021-02-05
    • 文件大小：157kb
    • 提供者：weixin_42144604

  1. flink-deployer：一种工具，可帮助自动部署到Apache Flink集群-源码

  2. Flink部署者 Go命令行实用程序，以方便部署到Apache Flink。 当前，它支持以下功能： 上市工作 部署新工作 更新现有工作 终止现有工作 查询Flink可查询状态 有关命令和标志的完整概述，请运行flink-job-deployer help 如何在本地运行 为了能够在本地测试部署程序，请按照下列步骤操作： 构建CLI工具docker镜像： docker-compose build deployer 可选： cd flink-sample-job; sbt clean as

  3. 所属分类：其它

    • 发布日期：2021-02-04
    • 文件大小：11mb
    • 提供者：weixin_42125826

  1. flink：Apache Flink-源码

  2. Apache Flink Apache Flink是具有强大的流和批处理功能的开源流处理框架。 通过了解有关Flink的更多信息 产品特点 流优先的运行时，支持批处理和数据流程序 Java和Scala中优雅流畅的API 同时支持很高的吞吐量和较低的事件延迟的运行时 基于数据流模型，在DataStream API中支持事件时间和无序处理 跨不同时间语义（事件时间，处理时间）的灵活窗口（时间，计数，会话，自定义触发器） 容错和一次处理保证 流媒体程序中的自然背压 用于图处理（批处理），机器学

  3. 所属分类：其它

    • 发布日期：2021-02-04
    • 文件大小：43mb
    • 提供者：weixin_42140716

  1. pulsar-flink：使用Apache Pulsar和Apache Flink进行弹性数据处理-源码

  2. 脉冲星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发生了很大变化，因此我们主要致力于maste

  3. 所属分类：其它

    • 发布日期：2021-01-30
    • 文件大小：436kb
    • 提供者：weixin_42115513