阿帕奇跨域_阿帕奇齿轮泵

阿帕奇跨域

Apache Gearpump是一个实时大数据流引擎。 它于2014年中期在GitHub上作为一个开源项目在英特尔构想,并于2016年3月8日进入Apache孵化。Gearpump的名称是对工程术语“齿轮泵”的指称,它是一个超级简单的泵,由以下组成只有两个齿轮,但是在流水方面非常强大。 与其他流引擎不同,Gearpump的引擎基于事件/消息。 根据初始基准测试,我们能够在4节点群集上每秒处理1800万条消息(消息长度为100字节),延迟为8ms。

亮点

  • 超高吞吐量和低延迟流处理
  • 可配置的消息传递保证(至少一次,恰好一次)
  • 应用程序热重新部署
  • 全面的仪表板,用于应用程序监视
  • 本机Storm应用程序兼容性
  • 萨摩亚本地应用程序兼容性
  • 友好且可扩展的API

在提交和运行第一个Gearpump应用程序之前,您将需要一个正在运行的Gearpump服务。 有多种方法可以运行Gearpump 本地模式 , 独立模式 , YARN模式或Docker模式 。

最简单的方法是在本地模式下运行Gearpump。 任何Linux,MacOSX或Windows桌面都可以零配置使用。

在下面的示例中,我们假设您以本地模式运行。 如果您以其他方式之一运行Gearpump,则需要通过在classpath中设置gear.conf配置路径来配置Gearpump客户端以连接到Gearpump服务。 在此文件中,您需要将参数gearpump.cluster.masters更改为正确的Gearpump主文件。

提交您的第一个申请的步骤

步骤1:提交申请

群集启动后,您可以向该群集提交示例单词计数应用程序

打开另一个外壳,

### To run WordCount example
bin/gear app -jar examples/wordcount-2.11-0.8.4-assembly.jar org.apache.gearpump.streaming.examples.wordcount.WordCount

步骤2:查看应用程序状态和指标。

要查看应用程序状态和指标,请启动Web UI服务,然后浏览至http://127.0.0.1:8090以检查状态。 默认的用户名和密码为“ admin:admin”,您可以检查UI身份验证以找到如何管理用户。

[1] https://gearpump.apache.org/overview.html [2] https://www.slideshare.net/manuzhang/apache-gearpump-lightweight-runtime-streaming-engine [3] http:// incubator .apache.org / projects / gearpump.html [4] https://gearpump.apache.org/releases/latest/introduction/submit-your-1st-application/index.html

翻译自: https://www.javacodegeeks.com/2018/02/apache-gearpump.html

阿帕奇跨域

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/333775.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

正则表达式之 NFA 引擎匹配原理详解

文章目录一、为什么要了解引擎匹配原理二、正则表达式引擎三、预备知识(一)字符串组成(二)占有字符和零宽度(三)控制权和传动四、正则表达式简单匹本过程(一)基础匹配过程&#xff0…

阿帕奇跨域_阿帕奇光束

阿帕奇跨域Apache Beam是一个开放源代码统一模型,用于定义批处理和流数据并行处理管道。 使用一种开源的Beam SDK,您可以构建一个定义管道的程序。 然后,该管道由Beam支持的分布式处理后端之一执行,这些后端包括Apache Apex &…

unity 启动相机_Unity3D研究院之打开照相机与本地相册进行裁剪显示(三十三)...

最近做项目需要用到这个功能,就是在Unity中调用Android本地相册或直接打开摄像机拍照并且裁剪一部分用于用户头像,今天研究了一下,那么研究出成果了MOMO一定要分享给大家。Unity与Android的交互还有谁不会?? 如果有不会…

深度学习pytorch--MNIST数据集

图像分类数据集(Fashion-MNIST) 在介绍softmax回归的实现前我们先引入一个多类图像分类数据集。它将在后面的章节中被多次使用,以方便我们观察比较算法之间在模型精度和计算效率上的区别。图像分类数据集中最常用的是手写数字识别数据集MNIS…

html 元素的属性

全局属性 全局属性是可与所有 HTML 元素一起使用的属性。 事件属性 用来定义某个事件的操作的属性叫事件属性,例如,οnclick“script”,元素上发生鼠标点击时触发 click 事件,click 事件被触发就会执行对应的脚本代码。事件属性…

nosql和rdnms_用于SaaS和NoSQL的Jdbi

nosql和rdnms一个自然的接口,用于与CRM,ERP,会计,营销自动化,NoSQL,平面文件等基于Java的数据集成 Jdbi是用于JavaSQL便利库,它为JDBC提供更自然的Java数据库接口,该接口易于绑定到…

matlab 功率谱密度 汉宁窗_如何理解随机振动的功率谱密度?

一、随机信号和正太分布有什么关系? 二、时域、频域之间功率守恒? 三、自相关又是个什么玩意?作为一个工程师,很多人对随机振动看着熟悉,却又实际陌生。熟悉是因为几乎每个产品在出厂时都要求要做随机振动试验&#xf…

深度学习pytorch--softmax回归(二)

softmax回归的从零开始实现实验前思考获取和读取数据获取数据集查看数据集查看下载后的.pt文件查看mnist_train和mnist_test读取数据集查看数据迭代器内容初始化模型参数定义softmax函数定义模型定义损失函数计算分类准确率模型评价--准确率开始训练可视化总结完整代码实验前思…

HTML块级元素/块标签/块元素

文章目录块元素的特点块元素清单block level element. 块级元素想在同一行显示需浮动或者 display:inline。 块元素的特点 每个块级元素都是独自占一行,其后的元素也只能另起一行,并不能两个元素共用一行; 元素的高度、宽度、行高、顶边距、…

物联卡查询流量_电信物联卡官网是多少?如何快速查询流量信息?

高速率设备的使用场景需要用到5G,中速率LET-Cat1应用范围更广,而低速率则要靠窄带物联网NB-IOT去维护了。这三种网络制式全都与物联网息息相关,这就能知道为什么国家层面对物联网基础设施建设这么重视了。电信物联卡在智能化硬件中有优秀表现…

java8日期转时间戳_Java 8日期和时间

java8日期转时间戳如今,一些应用程序仍在使用java.util.Date和java.util.Calendar API,包括使我们的生活更轻松地使用这些类型的库,例如JodaTime。 但是,Java 8引入了新的API来处理日期和时间,这使我们可以对日期和时间…

HTML行内元素/行级元素/内联元素/行标签/内联标签/行内标签/行元素

文章目录行内元素的特点行内元素清单可变元素列表inline element. 也叫行级元素、内联元素。行内元素默认设置宽度是不起作用,需设置 display:inline-block 或者 block 才行。 行内元素的特点 可以和其他元素处于一行,不用必须另起一行; 元…

深度学习pytorch--softmax回归(三)

softmax回归的简洁实现获取和读取数据定义和初始化模型softmax和交叉熵损失函数定义优化算法模型评价训练模型小结完整代码前两篇链接: 深度学习pytorch–softmax回归(一) 深度学习pytorch–softmax回归(二) 本文使用框架来实现模型。 获取和读取数据 我们仍然使用Fashion-M…

正则表达式的分类

文章目录一、正则表达式引擎二、正则表达式分类三、正则表达式比较四、Linux/OS X 下常用命令与正则表达式的关系一、正则表达式引擎 正则引擎大体上可分为不同的两类:DFA 和 NFA,而 NFA 又基本上可以分为传统型 NFA 和 POSIX NFA。 DFA(Deterministic …

spock测试_使用Spock测试您的代码

spock测试Spock是针对Java和Groovy应用程序的测试和规范框架。 Spock是: 极富表现力 简化测试的“给定/何时/然后” 语法 与大多数IDE和CI服务器兼容。 听起来不错? 通过快速访问Spock Web控制台,您可以非常快速地开始使用Spock。 当您有…

深度学习pytorch--多层感知机(一)

多层感知机隐藏层激活函数ReLU函数sigmoid函数tanh函数多层感知机小结我们已经介绍了包括线性回归和softmax回归在内的单层神经网络。然而深度学习主要关注多层模型。在本节中,我们将以多层感知机(multilayer perceptron,MLP)为例…

太阳能板如何串联_光伏板清洁专用的清洁毛刷

光伏发电是利用半导体界面的光生伏特效应将光能直接转变为电能的一种技术。主要由太阳电池板(组件)、控制器和逆变器三大部分组成。主要部件由电子元器件构成。太阳能电池经过串联后进行封装保护可形成大面积的太阳电池组件,再配合上功率控制…

java 异步等待_Java中的异步等待

java 异步等待编写异步代码很困难。 试图了解异步代码应该做什么的难度更大。 承诺是尝试描述延迟执行流程的一种常见方式:首先做一件事,然后再做另一件事,以防万一出错时再做其他事情。 在许多语言中,承诺已成为协调异步行为的实…

cass生成曲线要素_干货在线 | CASS入门指南——道路断面计算土方

CASS操作指南——道路断面计算土方法小伙伴们赶紧学起来!道路类的土方工程,主要用CASS的断面法土方计算之道路断面来计算。整个计算过程主要分为以下四步:菜单截图第一步:绘制道路中心线道路的中心线,一般由直线段和缓…

正则表达式的捕获性分组/反向引用

文章目录分组捕获性分组和反向引用分组 正则的分组主要通过小括号来实现,括号包裹的子表达式作为一个分组,括号后可以紧跟限定词表示重复次数。如下,小括号内包裹的 abc 便是一个分组: // (abc) 表示匹配一个或多个"abc"&#xf…