阿帕奇跨域
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
阿帕奇跨域