Map Reduce 〜入門編：仕組ã¿ã®ç†è§£ã¨ã‚¢ãƒ«ã‚´ãƒªã‚ºãƒ デザイン〜
This document discusses using sliding windows to aggregate streaming data in MapReduce. It proposes buffering input tuples in mappers until a window is full, then emitting the aggregate. Combiners and reducers combine partial aggregates across windows. Window ranges are initialized and updated during merging to remove outdated data and handle late arrivals. This approach allows streaming aggregati
ãƒãƒ¥ãƒ¼ãƒªãƒ³ã‚°ãƒžã‚·ãƒ³ - Wikipedia
ãƒãƒ¥ãƒ¼ãƒªãƒ³ã‚°ã®ã€Œè¨ˆç®—å¯èƒ½æ•°ã«ã¤ã„ã¦â”€â”€æ±ºå®šå•é¡Œã¸ã®å¿œç”¨ã€ï¼ˆ1936年）ã«ãŠã„ã¦æ示ã•ã‚ŒãŸ[2]。åŒæ§˜ãªã‚‚ã®ã‚’åŒå¹´ã«ã‚¨ãƒŸãƒ¼ãƒ«ãƒ»ãƒã‚¹ãƒˆ (Emil Post) も独立ã«ç™ºè¡¨ã—ã¦ã„ã‚‹[3]。構想ã®ç†ç”±ã€å‹•æ©Ÿã«ã¤ã„ã¦ã¯ãƒã‚¹ãƒˆã®è«–æ–‡ãŒæ˜Žç¢ºã ãŒã€æ©Ÿæ¢°è‡ªä½“ã«é–¢ã™ã‚‹è¨˜è¿°ã¯ãƒãƒ¥ãƒ¼ãƒªãƒ³ã‚°ã®è«–æ–‡ãŒè©³ç´°ã§ã‚る。次ã„ã§ã€åŒæ™‚代ã«æ示ã•ã‚ŒãŸä»–ã®è¨ˆç®—モデルも計算å¯èƒ½æ€§ã®ç†è«–ã‹ã‚‰ã¯åŒç‰ã§ã‚ã‚‹ã“ã¨ãŒç¢ºèªã•ã‚Œã€ãƒãƒ¥ãƒ¼ãƒªãƒ³ã‚°ï¼ãƒãƒ£ãƒ¼ãƒã®ãƒ†ãƒ¼ã‚¼ã¯ãれらを「計算å¯èƒ½ã€ã®å®šç¾©ã¨ã™ã‚‹ã“ã¨ã‚’æå”±ã—ãŸã€‚ ã“ã“ã§ã¯éžå½¢å¼çš„（直感的）ã«è¿°ã¹ã‚‹ã€‚ç†è«–çš„ã«ã¯å½¢å¼çš„ã«è¿°ã¹ã‚‹å¿…è¦ãŒã‚る。 ãƒãƒ¥ãƒ¼ãƒªãƒ³ã‚°ãƒžã‚·ãƒ³ã«ã¯ã€ã„ã‚ゆるãƒãƒ¼ãƒ‰ã‚¦ã‚§ã‚¢ã«ç›¸å½“ã™ã‚‹ã‚‚ã®ã¨ã—ã¦ã€ ãã®è¡¨é¢ã«è¨˜å·ã‚’èªã¿æ›¸ãã§ãるテープ。長ã•ã¯ç„¡åˆ¶é™ï¼ˆå¿…è¦ã«ãªã‚Œã°é †ç•ªã«ã„ãらã§ã‚‚å…ˆã«ã‚·ãƒ¼ã‚¯ã§ãã‚‹[注 1]）ã¨ã™ã‚‹ テープã«è¨˜å·ã‚’èªã¿æ›¸ãã™ã‚‹ãƒ˜ãƒƒãƒ‰ ヘッドã«ã‚ˆã‚‹èªã¿æ›¸ãã¨ã€ãƒ†ãƒ¼ãƒ—ã®å·¦å³ã¸ã®ã‚·ãƒ¼ã‚¯ã‚’
1
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
処ç†ã‚’実行ä¸ã§ã™
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
{{#tags}}- {{label}}
{{/tags}}