文件名称:缩放:用于级联的Scala API
文件大小:1.25MB
文件格式:ZIP
更新时间:2024-03-11 21:04:26
Scala
烫 扩展是一个Scala库,可轻松指定Hadoop MapReduce作业。 扩展是在之上构建的, 是一个Java库,用于抽象出低级Hadoop细节。 缩放与相当,但是提供与Scala的紧密集成,为您的MapReduce工作带来了Scala的优势。 字数 Hadoop是一个用于统计单词的分布式系统。 这是在缩放中的完成方式。 package com . twitter . scalding . examples import com . twitter . scalding . _ import com . twitter . scalding . source . TypedText class WordCountJob ( args : Args ) extends Job (args) { TypedPipe .from( TextLine (args( " input "