Tormeta是Storm分布式计算机系统的Scala扩展包。Tormeta在Storm的Kafka和Kestrelspouts消息上添加了一个安全类型的包装器。此安全类型允许用户推送映射消息和筛选转换信息到spout消息层上去。
代码示例：
import com.twitter.tormeta.scheme._import com.twitter.tormeta.spout._// produces strigs:val scheme: Scheme[Strig] = Scheme { bytes => Some(ew Strig(bytes)) }// produces itegers w/ strig legth:val mappedScheme: Scheme[It] = scheme.map(_.legth)// filters out all tuples less tha 5:val filteredScheme: Scheme[It] = mappedScheme.filter(_ > 5)// produces legths for iput strigs > legth of 5val spout: KestrelSpout[It] = ew KestrelSpout(filteredScheme, hostSeq, "spout")
评论