Tormenta 分布式系统的脚本包开源项目

我要开发同款
匿名用户2015年05月18日
66阅读
开发技术JavaScala
所属分类分布式应用/网格、服务器软件
授权协议Apache

作品详情

Tormenta是Storm分布式计算机系统的Scala扩展包。Tormenta在Storm的Kafka和Kestrelspouts消息上添加了一个安全类型的包装器。此安全类型允许用户推送映射消息和筛选转换信息到spout消息层上去。

代码示例:

import com.twitter.tormenta.scheme._import com.twitter.tormenta.spout._// produces strings:val scheme: Scheme[String] = Scheme { bytes => Some(new String(bytes)) }// produces integers w/ string length:val mappedScheme: Scheme[Int] = scheme.map(_.length)// filters out all tuples less than 5:val filteredScheme: Scheme[Int] = mappedScheme.filter(_ > 5)// produces lengths for input strings > length of 5val spout: KestrelSpout[Int] = new KestrelSpout(filteredScheme, hostSeq, "spout")
声明:本文仅代表作者观点,不代表本站立场。如果侵犯到您的合法权益,请联系我们删除侵权资源!如果遇到资源链接失效,请您通过评论或工单的方式通知管理员。未经允许,不得转载,本站所有资源文章禁止商业使用运营!
下载安装【程序员客栈】APP
实时对接需求、及时收发消息、丰富的开放项目需求、随时随地查看项目状态

评论