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

搜索资源列表

  1. 不仅仅是流计算：Apache Flink实践

  2. 不仅仅是流计算：Apache Flink实践 Flink 如何为整个阿里集团平稳度过双十一立下汗马功劳？ 如何为满足滴滴极为复杂的业务需求提供简单直观的 API 支持？ 如何在字节跳动逐步取代原有的 JStorm 引擎，成为公司内部流式数据处理的唯一标准？

  3. 所属分类：flink

    • 发布日期：2019-03-11
    • 文件大小：4mb
    • 提供者：yexf0206

  1. gelly-streaming, 一个面向 Apache Flink的实验图形.zip

  2. gelly-streaming, 一个面向 Apache Flink的实验图形 Gelly流一个用于单通道图流分析的experiemental API，在 上进行。图流模型在unbounded图流的基础上，实现了一种基于加权分布图的在线处理图统计。集集。一次算法和图形 Windows 等方法。 我们的工作构建在

  3. 所属分类：其它

    • 发布日期：2019-09-18
    • 文件大小：101kb
    • 提供者：weixin_38744207

  1. 大数据之flink教程-TableAPI和SQL.pdf

  2. 第一章 整体介绍 2 1.1 什么是 Table API 和 Flink SQL 2 1.2 需要引入的依赖 2 1.3 两种 planner（old & blink）的区别 4 第二章 API 调用 5 2.1 基本程序结构 5 2.2 创建表环境 5 2.3 在 Catalog 中注册表 7 2.3.1 表（Table）的概念 7 2.3.2 连接到文件系统（Csv 格式） 7 2.3.3 连接到 Kafka 8 2.4 表的查询 9 2.4.1 Table API 的调用 9 2.4.2

  3. 所属分类：flink

  1. kafka知识总结

  2. 1.什么是kafka？ Kafka是一个分布式的基于发布/订阅模式的消息队列，主要应用于大数据实时处理领域。 2.流式计算？ 大体包括storm、 sparkStreaming 、flink storm：来一条数据，处理一条，实时性好 sparkStreaming ：微批处理，延迟性较差，但是兼容性好 flink：一个流系统，采用原生的流处理系统，保证了低延迟性，在API和容错性上也是做的比较完善，使用起来相对来说也是比较简单的，部署容易 3.JMS 消息传输模型？ 点对点模式（一对一，消费者主

  3. 所属分类：其它

    • 发布日期：2021-01-07
    • 文件大小：178kb
    • 提供者：weixin_38655987

  1. flink流处理API

  2. Environment getExecutionEnvironment 创建一个执行环境，表示当前执行程序的上下文。 如果程序是独立调用的，则此方法返回本地执行环境；如果从命令行客户端调用程序以提交到集群，则此方法返回此集群的执行环境，也就是说，getExecutionEnvironment会根据查询运行的方式决定返回什么样的运行环境，是最常用的一种创建执行环境的方式。 val env: ExecutionEnvironment = ExecutionEnvironment.getExecuti

  3. 所属分类：其它

    • 发布日期：2021-01-07
    • 文件大小：365kb
    • 提供者：weixin_38683193

  1. Flink的流处理

  2. 概述 Flink是一个用于对*和有界数据流进行有状态计算的框架。Flink在不同的抽象级别提供多个API，并为常见用例提供专用库。 流媒体应用程序的构建块 可以由流处理框架构建和执行的应用程序类型由框架控制流，状态和时间的程度来定义。在下文中，我们描述了流处理应用程序的这些构建块，并解释了Flink处理它们的方法。 流 显然，流是流处理的一个基本方面。但是，流可以具有不同的特征，这些特征会影响流的处理方式。Flink是一个多功能的处理框架，可以处理任何类型的流。 有界和*流：流可以是*

  3. 所属分类：其它

    • 发布日期：2021-01-07
    • 文件大小：102kb
    • 提供者：weixin_38614825

  1. 深入理解ApacheFlink核心技术

  2. ApacheFlink（下简称Flink）项目是大数据处理领域最近冉冉升起的一颗新星，其不同于其他大数据项目的诸多特性吸引了越来越多人的关注。本文将深入分析Flink的一些关键技术与特性，希望能够帮助读者对Flink有更加深入的了解，对其他大数据系统开发者也能有所裨益。本文假设读者已对MapReduce、Spark及Storm等大数据处理框架有所了解，同时熟悉流处理与批处理的基本概念。Flink核心是一个流式的数据流执行引擎，其针对数据流的分布式计算提供了数据分布、数据通信以及容错机制等功能。基

  3. 所属分类：其它

    • 发布日期：2021-02-26
    • 文件大小：508kb
    • 提供者：weixin_38708461

  1. 动态表的持续查询

  2. 越来越多的公司采用流处理，并将现有的批处理应用迁移到流处理，或者对新的用例采用流处理实现的解决方案。其中许多应用集中在流数据分析上，分析的数据流来自各种源，例如数据库事务、点击、传感器测量或IoT设备。ApacheFlink非常适用于流分析应用程序，因为它支持事件时间语义，确保只处理一次，以及同时实现了高吞吐量和低延迟。因为这些特性，Flink能够近实时对大量的输入数据计算出一个确定和精确的结果，并且在发生故障的时候提供一次性语义。Flink的核心流处理API，DataStreamAPI，非常具

  3. 所属分类：其它

    • 发布日期：2021-02-25
    • 文件大小：912kb
    • 提供者：weixin_38547397

  1. ApacheBeam实战指南之基础入门

  2. 随着大数据2.0时代悄然到来，大数据从简单的批处理扩展到了实时处理、流处理、交互式查询和机器学习应用。早期的处理模型(Map/Reduce)早已经力不从心，而且也很难应用到处理流程长且复杂的数据流水线上。另外，近年来涌现出诸多大数据应用组件，如HBase、Hive、Kafka、Spark、Flink等。开发者经常要用到不同的技术、框架、API、开发语言和SDK来应对复杂应用的开发。这大大增加了选择合适工具和框架的难度，开发者想要将所有的大数据组件熟练运用几乎是一项不可能完成的任务。面对这种情况，

  3. 所属分类：其它

    • 发布日期：2021-02-25
    • 文件大小：314kb
    • 提供者：weixin_38632624

  1. ApacheBeam实战指南|玩转KafkaIO与Flink

  2. 随着大数据2.0时代悄然到来，大数据从简单的批处理扩展到了实时处理、流处理、交互式查询和机器学习应用。近年来涌现出诸多大数据应用组件，如HBase、Hive、Kafka、Spark、Flink等。开发者经常要用到不同的技术、框架、API、开发语言和SDK来应对复杂应用的开发，这大大增加了选择合适工具和框架的难度，开发者想要将所有的大数据组件熟练运用几乎是一项不可能完成的任务。面对这种情况，Google在2016年2月宣布将大数据流水线产品（GoogleDataFlow）贡献给Apache基金会孵

  3. 所属分类：其它

    • 发布日期：2021-02-24
    • 文件大小：608kb
    • 提供者：weixin_38616139

  1. Flink动态表的连续查询

  2. 越来越多的公司采用流处理，并将现有的批处理应用迁移到流处理，或者对新的用例采用流处理实现的解决方案。其中许多应用集中在流数据分析上，分析的数据流来自各种源，例如数据库事务、点击、传感器测量或IoT设备。ApacheFlink非常适用于流分析应用程序，因为它支持事件时间语义，确保只处理一次，以及同时实现了高吞吐量和低延迟。因为这些特性，Flink能够近实时对大量的输入数据计算出一个确定和精确的结果，并且在发生故障的时候提供一次性语义。Flink的核心流处理API，DataStreamAPI，非常具

  3. 所属分类：其它

    • 发布日期：2021-02-24
    • 文件大小：909kb
    • 提供者：weixin_38564003

  1. 《深入理解Flink核心设计与实践原理》随书，书中讲解的Flink特性完全可运行的代码供读者运行和测试。整个工程共有【182个Java文件】，你要的Demo这里都有，相关特性见正文的目录-源码

  2. 1.《深入理解Flink核心设计与实践原理》-随书代码 整个工程共有【182个Java文件】，你要的Demo这里都有。 《深入理解Flink核心设计与实践原理》一书中针对该工程中的Flink示例代码进行逐步的详细讲解，并推荐大家购买《深入理解Flink核心设计与实践原理》一书来获得更好的学习体验。 本书从Apache Flink的缘起开始，由浅入深，理论结合实践，全方位地介绍Apache Flink这一处理海量数据集的高性能工具。本书围绕部署，流处理，批处理，表格API和SQL四大模块进行讲解，

  3. 所属分类：其它

  1. flink：Apache Flink-源码

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

  3. 所属分类：其它

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

  1. TweetMap：一个实时的Tweet趋势图和情感分析Web应用程序，在云上部署了kafka，Angular，Spring Boot，Flink，Elasticsearch，Kibana，Docker和Kubernetes-源码

  2. 趋势图 构建一个java Tweet Collector以使用Twitter Streaming API收集实时Tweet 将收集的推文推送到Kafka集群 利用Apache Flink流处理（解析，过滤和转换）tweet 将处理过的推文接收到Elasticsearch以获取数据持久性和索引 开发SpringBoot RESTful API server以查询来自Elasticsearch的推文 使用Frontend Angular Web应用程序可视化实时推文趋势 使用Kibana显示地理

  3. 所属分类：其它

  1. 动态表的持续查询

  2. 越来越多的公司采用流处理，并将现有的批处理应用迁移到流处理，或者对新的用例采用流处理实现的解决方案。其中许多应用集中在流数据分析上，分析的数据流来自各种源，例如数据库事务、点击、传感器测量或IoT设备。ApacheFlink非常适用于流分析应用程序，因为它支持事件时间语义，确保只处理一次，以及同时实现了高吞吐量和低延迟。因为这些特性，Flink能够近实时对大量的输入数据计算出一个确定和精确的结果，并且在发生故障的时候提供一次性语义。Flink的核心流处理API，DataStreamAPI，非常具

  3. 所属分类：其它

    • 发布日期：2021-01-27
    • 文件大小：909kb
    • 提供者：weixin_38713801

  1. flink-sql在flink上运行sql和构建数据流的平台基于apache flink 1.10.0 - xianxiash / fiflow-源码

  2. 基于flink的数据流处理系统 基于 apache flink1.10 如何运行 运行 FiflowWebMain 访问 如何使用 在输入框中输入 help 给出提示信息; demo mysql : jdbc 示例 demo kafka : kafka 示例 demo elasticsearch : elasticsearch 示例 demo mysql-binlog : mysql-binlog 示例 doing 模块划分 fiflow-ui web页面

  3. 所属分类：其它

    • 发布日期：2021-01-27
    • 文件大小：10mb
    • 提供者：weixin_38685538

  1. ApacheBeam实战指南|玩转KafkaIO与Flink

  2. 随着大数据2.0时代悄然到来，大数据从简单的批处理扩展到了实时处理、流处理、交互式查询和机器学习应用。近年来涌现出诸多大数据应用组件，如 HBase、Hive、Kafka、Spark、Flink等。开发者经常要用到不同的技术、框架、API、开发语言和 SDK来应对复杂应用的开发，这大大增加了选择合适工具和框架的难度，开发者想要将所有的大数据组件熟练运用几乎是一项不可能完成的任务。面对这种情况，Google在2016年2月宣布将大数据流水线产品（Google

  3. 所属分类：其它

    • 发布日期：2021-01-27
    • 文件大小：581kb
    • 提供者：weixin_38598745

  1. Flink流处理之迭代案例

  2. 当前Flink将迭代的重心集中在批处理上，之前我们谈及了批量迭代和增量迭代主要是针对批处理（DataSet）API而言的，并且Flink为批处理中的迭代提供了针对性的优化。但是对于流处理（DataStream），Flink同样提供了对迭代的支持，这一节我们主要来分析流处理中的迭代，我们将会看到流处理中的迭代相较于批处理有相似之处，但差异也是十分之明显。 可迭代的流处理程序允许定义“步函数”（stepfunction）并将其内嵌到一个可迭代的流（IterativeStream）中。因为一个流处理程

  3. 所属分类：其它

    • 发布日期：2021-01-27
    • 文件大小：89kb
    • 提供者：weixin_38618540

  1. Flink动态表的连续查询

  2. 越来越多的公司采用流处理，并将现有的批处理应用迁移到流处理，或者对新的用例采用流处理实现的解决方案。其中许多应用集中在流数据分析上，分析的数据流来自各种源，例如数据库事务、点击、传感器测量或IoT设备。ApacheFlink非常适用于流分析应用程序，因为它支持事件时间语义，确保只处理一次，以及同时实现了高吞吐量和低延迟。因为这些特性，Flink能够近实时对大量的输入数据计算出一个确定和精确的结果，并且在发生故障的时候提供一次性语义。Flink的核心流处理API，DataStreamAPI，非常具

  3. 所属分类：其它

    • 发布日期：2021-01-27
    • 文件大小：909kb
    • 提供者：weixin_38724919

  1. Flink之Table API

  2. Table API是流处理和批处理通用的关系型API，Table API可以基于流输入或者批输入来运行而不需要进行任何修改。Table API是SQL语言的超集并专门为Apache Flink设计的，Table API是Scala和Java语言集成式的API。与常规SQL语言中将查询指定为字符串不同，Table API查询是以Java或Scala中的语言嵌入样式来定义的，具有IDE支持如:自动完成和语法检测。 1 需要引入的pom依赖 org.apache.flink flin

  3. 所属分类：其它

    • 发布日期：2021-01-20
    • 文件大小：29kb
    • 提供者：weixin_38548817
« 12 »