Sparkã®è³‡æ–™ - Scala日記Sparkã®ç´ 晴らã—ã„資料ãŒå…¬é–‹ã•ã‚Œã¾ã—ãŸã€‚ã“れを見れã°ã™ãã«MapReduceã§PMIãŒè¨ˆç®—ã§ãるよã†ã«ãªã‚Šã¾ã™ã€‚ Apache Spark ãƒãƒ¥ãƒ¼ãƒˆãƒªã‚¢ãƒ« from K Yamaguchi www.slideshare.net
Apache Spark ãƒãƒ¥ãƒ¼ãƒˆãƒªã‚¢ãƒ«
4. ç´ æœ´ãªå®Ÿè£… 3 frequency = defaultdict(int) for line in opened_file: for word in some_splitter(line): frequency[word] += 1 for word in frequency: some_output(word, frequency[word]) ファイル frequency メモリ㫠辞書/ãƒãƒƒã‚·ãƒ¥/ 連想é…列/Mapã‚’ æŒã¤é »åº¦(Pythonic) frequency = collections.Counter( word for line in opened_file for word in some_splitter(line)) for word, count in frequency.iteritems(): some_output(word, count)
1
ランã‚ング
ランã‚ング
ランã‚ング
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
処ç†ã‚’実行ä¸ã§ã™
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
HOME | deactivate-domain
{{#tags}}- {{label}}
{{/tags}}