[B! stream] ikosinã®ãƒ–ãƒƒã‚¯ãƒžãƒ¼ã‚¯

ikosin id:ikosin

streamã«é–¢ã™ã‚‹ikosinã®ãƒ–ãƒƒã‚¯ãƒžãƒ¼ã‚¯ (26)

${{author_name}}$

{{{comment_expanded}}}

{{label}}

{{#is_bookmark}}ãƒªã‚¹ãƒˆ{{/is_bookmark}}{{^is_bookmark}}ãƒªãƒ³ã‚¯{{/is_bookmark}}

${{author_name}}$
{{author_name}}{{created}}
{{ #comment }}{{ comment }}{{ /comment }}
- {{ label }}

${{author_name}}$

{{{comment_expanded}}}

{{label}}

{{#is_bookmark}}ãƒªã‚¹ãƒˆ{{/is_bookmark}}{{^is_bookmark}}ãƒªãƒ³ã‚¯{{/is_bookmark}}

Streaming 101: The world beyond batch
Join the O'Reilly online learning platform. Get a free trial today and find answers on the fly, or master something new and useful. Learn more As someone whoâ€™s worked on massive-scale streaming systems at Google for the last five+ years (MillWheel, Cloud Dataflow), Iâ€™m delighted by this streaming zeitgeist, to say the least. Iâ€™m also interested in making sure that folks understand everything that
ikosin 2024/11/29
spark

stream
ãƒªãƒ³ã‚¯
ãƒãƒƒãƒå‡¦ç†ãŠã˜ã•ã‚“ãŒã‚¹ãƒˆãƒªãƒ¼ãƒ å‡¦ç†ã®ã‚·ã‚¹ãƒ†ãƒ ã‚’é–‹ç™ºã™ã‚‹ã«ã‚ãŸã£ã¦èª¿ã¹ãŸã“ã¨
ã»ã¨ã‚“ã©ãƒãƒƒãƒå‡¦ç†ã—ã‹æ›¸ã„ãŸã“ã¨ã®ãªã„è€…ã ãŒã‚¹ãƒˆãƒªãƒ¼ãƒ å‡¦ç†ã®ã‚·ã‚¹ãƒ†ãƒ ã‚’é–‹ç™ºã™ã‚‹ã“ã¨ã«ãªã£ãŸã€‚ ãã‚Œã«ã‚ãŸã£ã¦ç‹¬å¦ã§èª¿ã¹ãŸã“ã¨ãªã©ã¾ã¨ã‚ã¦ãŠãã€‚ ã‚¹ãƒˆãƒªãƒ¼ãƒ å‡¦ç†ã¨ã¯#ãã‚‚ãã‚‚ â€œã‚¹ãƒˆãƒªãƒ¼ãƒ å‡¦ç†â€ ã¨ã¯ä½•ã‚’æŒ‡ã—ã¦ã„ã‚‹ã®ã‹ã€‚ ä»¥ä¸‹ã®å¼•ç”¨ãŒç°¡æ½”ã«ç¤ºã—ã¦ã„ã‚‹ã€‚ a type of data processing engine that is designed with infinite data sets in mind. Nothing more. â€“ Streaming 101: The world beyond batch ã“ã¡ã‚‰ã¯ â€œstreaming systemâ€ ã«ã¤ã„ã¦è¿°ã¹ãŸã‚‚ã®ã ãŒã€ã¤ã¾ã‚Šçµ‚ã‚ã‚Šã®ãªã„ãƒ‡ãƒ¼ã‚¿ã‚’æ‰±ã†ã®ãŒã‚¹ãƒˆãƒªãƒ¼ãƒ å‡¦ç†ã¨ã„ã†ã“ã¨ã§ã‚ã‚‹ã€‚ ä¾‹ãˆã° web ã‚µãƒ¼ãƒ“ã‚¹ã‹ã‚‰ç”Ÿã¾ã‚Œç¶šã‘ã‚‹ãƒ¦ãƒ¼ã‚¶è¡Œå‹•ãƒã‚°ã‚’é€æ¬¡çš„ã«å‡¦ç†ã™ã‚‹ã¨ã„ã†ã®ãŒã‚¹ãƒˆãƒªãƒ¼ãƒ å‡¦ç†ã€‚ web ã‚µãƒ¼ãƒ“ã‚¹ãŒçµ‚äº†ã—ãªã„ã‹ãŽã‚Š
ikosin 2024/11/29
ãƒãƒƒãƒ

é–‹ç™º

spark

stream
ãƒªãƒ³ã‚¯
The Definitive TypeScript Guide - Blog | SitePen
Software projects succeed or fail based on the quality of the teams behind them. Expert developers can be hard to find. So how do you get junior developers to level up? Itâ€™s not enough to teach how to use a framework or tech stack. Good developers can follow a pattern.
ikosin 2017/10/11
stream
ãƒªãƒ³ã‚¯
Stream APIå…¥é–€ - Qiita
Nodeã®ã‚¢ãƒ‰ãƒ™ãƒ³ãƒˆã‚«ãƒ¬ãƒ³ãƒ€ãƒ¼ã€æ—¢ã«çµ‚ã‚ã£ãŸæž ãŒç©ºã„ã¦ã„ã¦ã€ã“ã®éš›æ›¸ããŸã„ãƒã‚¿ãŒã‚ã£ãŸã‚“ã§å‚åŠ ã—ã¾ã—ãŸã€‚å®œã—ããŠé¡˜ã„ã—ã¾ã™ã€‚ ã‚¢ãƒ‰ãƒ™ãƒ³ãƒˆã‚«ãƒ¬ãƒ³ãƒ€ãƒ¼ã®æ™‚æœŸã ã‘å‡ºæ²¡ã™ã‚‹å¼±ã„æ—¥æ›œHaskellerã§ã™ã€‚æ™®æ®µã®å®Ÿå‹™ã§ã¯Node.jsã«ãŠä¸–è©±ã«ãªã£ã¦ã¾ã™ã€‚å®œã—ããŠé¡˜ã„ã—ã¾ã™ã€‚ ã•ã¦ã€ã¿ãªã•ã‚“Stream APIä½¿ã£ã¦ã¾ã™ã‹ï¼ŸNode.jsã¨ã„ã£ãŸã‚‰éžåŒæœŸã§ã™ã‚ˆãã€ã‚„ã£ã±ã‚Šã€‚ã—ã‹ã—ãªãŒã‚‰ã€JavaScriptã§ã‚‚ä»–ã®è¨€èªžã§ã‚‚ã€éžåŒæœŸå‡¦ç†è‡ªä½“ã¯æ³¨ç›®ã•ã‚Œã¦ã„ã‚‹ã‚‚ã®ã®ã€ã¾ã experimentalã¨ã„ã†æ„Ÿã˜ã§æ§˜ã€…ãªAPIãŒè€ƒæ¡ˆã•ã‚Œã¦ã¯æ¶ˆãˆã¦ã„ãã€ã¾ãŸå…ƒã€…ãã†ã„ã†æ–‡åŒ–ãŒæ ¹å¼·ããªã‹ã£ãŸã¨ã“ã‚ã‹ã‚‰æ¥ãŸäººãŸã¡ã«ã¨ã£ã¦ã€ã“ã†ã„ã†æ–‡åŒ–ã¯ã¡ã‚‡ã£ã¨ç«‹ã¡å…¥ã‚Šã¥ã‚‰ã„ã¨ã“ã‚ã‚‚ã‚ã‚‹ã‹ã‚‚ã—ã‚Œã¾ã›ã‚“ãã€‚ ä»Šæ—¥ã¯ã€ä¸»ã«ãã†ã„ã†äººãŸã¡ã«å‘ã‘ã¦ã€ã¾ãšéžåŒæœŸã®è‰²ã€…ãªAPIã®ç´¹ä»‹ã€ãã—ã¦ãã®ä¸ã§ã®ã‚¹ãƒˆãƒªãƒ¼ãƒ ã®ãƒ¡ãƒªãƒƒãƒˆã€ãã—ã¦å®Ÿéš›ã®Stream
ikosin 2016/12/25
stream

javascript

node.js
ãƒªãƒ³ã‚¯
Overview
Introduction RxJS is a library for composing asynchronous and event-based programs by using observable sequences. It provides one core type, the Observable, satellite types (Observer, Schedulers, Subjects) and operators inspired by Array#extras (map, filter, reduce, every, etc) to allow handling asynchronous events as collections. Think of RxJS as Lodash for events. ReactiveX combines the Observer
ikosin 2016/12/25
rx

stream
ãƒªãƒ³ã‚¯
Fetch ã§ã® Stream ã‚’ç”¨ã„ãŸãƒ—ãƒã‚°ãƒ¬ã‚¹å–å¾—ã¨ã‚ãƒ£ãƒ³ã‚»ãƒ« | blog.jxck.io
Intro WHATWG ãŒå®šç¾©ã™ã‚‹ Fetch API ã¯ã€å‡ºãŸã°ã‹ã‚Šã®ä»•æ§˜ã§ã¯ã€é€”ä¸ã§ã®ã‚ãƒ£ãƒ³ã‚»ãƒ«ã‚„ã€ãƒ—ãƒã‚°ãƒ¬ã‚¹ã‚¤ãƒ™ãƒ³ãƒˆã®å–å¾—ãŒå«ã¾ã‚Œã¦ã„ãªã‹ã£ãŸã€‚ ã—ã‹ã—ã€å¾Œã®æ›´æ–°ã§ fetch çµæžœã® Response Body ãŒ WHATWG Stream API ã‚’å®Ÿè£…ã™ã‚‹ã“ã¨ã«ãªã£ãŸãŸã‚ã€ç¾åœ¨ã®ä»•æ§˜ã§ã¯ãƒ—ãƒã‚°ãƒ¬ã‚¹ã‚’å–ã‚‹ã“ã¨ã‚‚ã‚ãƒ£ãƒ³ã‚»ãƒ«ã‚’ã™ã‚‹ã“ã¨ã‚‚å¯èƒ½ã¨ãªã£ã¦ã„ã‚‹ã€‚ ä»Šå›žã¯ã€ã“ã†ã—ãŸ API ã®ã‚¢ãƒƒãƒ—ãƒ‡ãƒ¼ãƒˆã«ã¤ã„ã¦è¨˜ã™ã€‚ Update æœ€åˆã®å…¬é–‹æ™‚ã«ã¯ã€ä»¥ä¸‹ã®ã‚ˆã†ã«æ›¸ã„ã¦ã„ãŸã€‚ ã€ŒXHR ã§ã¯ã§ãã‚‹ãŒ Fetch ã§ã¯ã§ããªã„ã€ã“ã¨ãŒã€ä»•æ§˜ä¸Šã¯ç„¡ããªã£ãŸã“ã¨ã‚’æ„å‘³ã™ã‚‹ã€‚ ã—ã‹ã—ã€ç¾æ™‚ç‚¹ã§ä»•æ§˜ã¨ã—ã¦ã¾ã å‡ºæ¥ãªã„ã“ã¨ãŒã‚ã‚‹ã“ã¨ãŒåˆ¤æ˜Žã—ãŸã€‚ Upload ã® Progress ã“ã‚Œã«ä¼´ã„ã€è¨˜äº‹ã®ä¸€éƒ¨ã‚’ä¿®æ£ã—ãŸã€‚ Fetch æœ€æ–°ã® Fetch ã®ä»•æ§˜ã¯ä»¥ä¸‹ã§ç¢ºèªã§ãã‚‹ã€‚ Fetch Spec ä»•æ§˜
ikosin 2016/07/22
stream

HTTP

api
ãƒªãƒ³ã‚¯
History Of Streams
The history of streamscontentsprehistory (streams before a stream api)streams 1summer of streams, userland vs corestreams2 (one step forward, 2 steps back)streams3conclusionprehistoryin node.jsâ€™s early days back in 2010, the node.js website featured an example of a tcp echo server. on feb 9th, 2010 the tcp streamâ€™s events were named â€œreceiveâ€ and â€œeofâ€. Shorly later, by feb 18th, 2010 those events
ikosin 2016/06/01
stream

node.js
ãƒªãƒ³ã‚¯
Open Sourcing Twitter Heron
Last year we announced the introduction of our new distributed stream computation system, Heron. Today we are excited to announce that we are open sourcing Heron under the permissive Apache v2.0 license. Heron is a proven, production-ready, real-time stream processing engine, which has been powering all of Twitterâ€™s real-time analytics for over two years. Prior to Heron, we used Apache Storm, whic
ikosin 2016/05/26
stream
ãƒªãƒ³ã‚¯
Developers Summit 2016ã§éžåŒæœŸå‡¦ç†ã«ã¤ã„ã¦è©±ã—ã¦ãã¾ã—ãŸ - from scratch
ã ã„ã¶é–“ãŒç©ºã„ã¦ã—ã¾ã£ãŸã‚“ã§ã™ãŒã€ãƒ‡ãƒ–ã‚µãƒŸ 2016 ã§éžåŒæœŸå‡¦ç†ã«ã¤ã„ã¦è©±ã—ã¦ãã¾ã—ãŸã€‚ event.shoeisha.jp ãƒˆãƒ”ãƒƒã‚¯ã¨ã—ã¦ã‚‚ã®ã™ã”ãçªå‡ºã—ã¦ãŸã®ã§æˆç«‹ã™ã‚‹ã‹ä¸å®‰ã ã£ãŸã®ã§ã™ãŒã€ãªã‚“ã¨ãªãçµè«–ã‚ã„ãŸã‚‚ã®ã¯ã§ã¾ã—ãŸã€‚ è©³ã—ãã¯ takezoe ã•ã‚“ã®ãƒ–ãƒã‚°ã‚’è¦‹ã¦é ‚ã‘ã‚‹ã¨è‰¯ã„ã‹ã¨æ€ã„ã¾ã™ã€‚ takezoe.hatena blog.com çµè«–ã¿ãŸã„ãªã‚‚ã® ã¾ãã‚„ã£ã±ã‚ŠåŒæœŸå‡¦ç†ã¨éžåŒæœŸå‡¦ç†ã¯ã€Žæ„è˜ã—ã¦ä½¿ã„åˆ†ã‘ãªãã¦ã‚‚è¨€èªžãªã‚Šãƒ•ãƒ¬ãƒ¼ãƒ ãƒ¯ãƒ¼ã‚¯ãªã‚Šã§å¸åŽã™ã‚‹ã‚ˆã†ã«ãªã£ã¦ã„ãã‚“ã˜ã‚ƒãªã„ã‹ã€ã¨ã„ã†ã®ãŒ1ã¤ã®çµè«–ã®ã‚ˆã†ãªå½¢ã«ãªã£ãŸã€‚ES.Nextã® async/await ã¯ãã®1ã¤ã®å½¢ã ã¨æ€ã†ã€‚"æ„è˜ã—ãªã„ã§"ã¨ã„ã†ã®ã¯é›£ã—ã„ãŒã€ã»ã¨ã‚“ã©åŒæœŸå‡¦ç†ã¨å¤‰ã‚ã‚‰ãªã„å½¢ã§æ›¸ã‘ã‚‹ã‚ˆã†ã«ãªã‚‹ã€‚ Node.js ã¯ coreã®ä¸ã§ã‚‚ Promise ã‚’æŽ¡ç”¨ã™ã‚‹ã‚ˆã†ã«åªä»Šæ§‹æƒ³ä¸ã ã—ã€ãƒ¦ãƒ¼ã‚¶ãƒ¼ãƒ©ãƒ³ãƒ‰ã®å ´åˆã¯P
ikosin 2016/03/01
éžåŒæœŸ

promise

node.js

stream
ãƒªãƒ³ã‚¯
Java8 Streamã§ãƒãƒªãƒãƒªã‚„ã‚Œã‚‹ã‚ˆã†ã«ãªã‚ŠãŸã„äººã®ãŸã‚ã®Functional Interfaceã¾ã¨ã‚ - mike-neckã®ãƒ–ãƒã‚°
ã“ã‚“ã«ã¡ã‚ã€ã¿ã‘ã§ã™ã€‚ ã‚‚ã†ã€Streamã®æ›¸ãã™ãŽã§ã€ ãªã‚“ã ã‹ã€foræ–‡ãŒæ›¸ã‘ãªã„èº«ä½“ã«ãªã£ã¦ã—ã¾ã„ã¾ã—ãŸ(å¤§è¢ˆè£Ÿ) ã¨ã„ã†ã‚ã‘ã§ã€Streamãªã®ã§ã™ãŒã€ æ…£ã‚Œã¦ã„ãªã„ã¨ ã€Œã¯ã‚ˆï¼Supplier<?>ã€BinaryConsumer<?, ?>ã‚’ã¯ã‚ˆï¼ã€ ã¨IDEã«ã›ã‹ã•ã‚Œã¦ã€ ã‚ã‚Œã£ï¼Ÿã“ã‚Œã£ã¦ãªã‚“ã ã£ã‘ï¼Ÿã£ã¦ãªã£ã¦ã—ã¾ã† ã®ã§ã¯ãªã„ã‹ã¨æ€ã„ã¾ã™ã€‚ ã¨ã„ã†ã‚ã‘ã§ã€Streamã§ä½¿ã†ç”¨é€”ã§ Functional Interfaceã‚’ã¾ã¨ã‚ã¦ã¿ã‚‹ã“ã¨ã«ã—ã¾ã—ãŸã€‚ Streamã®ç”Ÿæˆ(source)ã«ç”¨ã„ã‚‹ã‚‚ã® Supplier<T> å¼•æ•°ãªã—ã§ã€ã‚ªãƒ–ã‚¸ã‚§ã‚¯ãƒˆã‚’ç”Ÿæˆã™ã‚‹Functional Interfaceã§ã™ã€‚ Stream#generateãƒ¡ã‚½ãƒƒãƒ‰ã§åˆ©ç”¨ã—ã¾ã™ã€‚ ä¾‹ @Test public void supplier_Tã®ã‚µãƒ³ãƒ—ãƒ« () { final AtomicInteger
ikosin 2016/02/15
java

stream
ãƒªãƒ³ã‚¯
https://cero-t.hatenadiary.jp/entry/20151212/1449929908
ikosin 2015/12/21
Java

stream
ãƒªãƒ³ã‚¯
PipelineDBâ€”The Streaming SQL Database
Mencari slot gacor hari ini? Anda berada di tempat yang tepat! Dalam dunia perjudian online, istilah "gacor" sering digunakan untuk menggambarkan slot yang sedang "panas" atau memiliki peluang tinggi untuk memberikan kemenangan besar kepada pem ain. Dalam artikel panjang ini, kita akan membahas segala sesuatu tentang slot gacor: cara menemukannya, strategi untuk bermain, dan tentu saja, rekomendasi
ikosin 2015/07/09
db

stream
ãƒªãƒ³ã‚¯
Reactive Streams å…¥é–€ #jjug
2015/06/24 JJUG ãƒŠã‚¤ãƒˆã‚»ãƒŸãƒŠãƒ¼ ã€ŒReactive Streamsç‰¹é›†ã€ by @okapies https://jjug.doorkeeper.jp/events/26547 è£œè¶³è¨˜äº‹: http://okapies.hateblo.jp/entry/2015/06/26/024505
ikosin 2015/07/05
reactive

ãƒ—ãƒã‚°ãƒ©ãƒŸãƒ³ã‚°

stream
ãƒªãƒ³ã‚¯
2014 akka-streams-tokyo-japanese
Akka Streams (0.7) talk for the Tokyo Scala User Group, hosted by Dwango. Akka streams are an reactive streams implementation which allows for asynchronous back-pressured processing of data in complext pipelines. This talk aims to highlight the details about how reactive streams work as well as some of the ideas behind akka streams.Read less
ikosin 2015/03/09
reactive

stream

akka
ãƒªãƒ³ã‚¯
Reactive Streamsã¨ã¯ï¼Ÿ - ãŸã‘ãžã†ç€•æ»ãƒ–ãƒã‚°
Reactive Streamsã¨ã„ã†ã®ã¯ãƒŽãƒ³ãƒ–ãƒãƒƒã‚ãƒ³ã‚°ãªback pressureå¯èƒ½ãªéžåŒæœŸã‚¹ãƒˆãƒªãƒ¼ãƒ å‡¦ç†ã®æ¨™æº–çš„ãªä»•æ§˜ã‚’æä¾›ã—ã‚ˆã†ã¨ã„ã†ã‚‚ã®ã§ã€å®Ÿè£…ã¨ã—ã¦ã¯Akka Streamsã€RxJavaã€Reactor Composableã€Ratpackãªã©ãŒã‚ã‚Šã¾ã™ã€‚ Reactive Streamsã«ã¤ã„ã¦ã¯Akkaã®ã‚³ãƒŸãƒƒã‚¿ã§ã‚ã‚‹Konrad Malawskiã•ã‚“ã®ä»¥ä¸‹ã®ã‚¹ãƒ©ã‚¤ãƒ‰ãŒã¨ã¦ã‚‚ã‚ã‹ã‚Šã‚„ã™ã„ã§ã™ã€‚ 2014 akka-streams-tokyo-japanese from Konrad Malawski ã‚¹ãƒˆãƒªãƒ¼ãƒ å‡¦ç†ï¼ˆã¨ã„ã†ã‹éžåŒæœŸãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ãƒ³ã‚°å…¨èˆ¬ã«è¨€ãˆã‚‹ã“ã¨ã§ã™ãŒï¼‰ã§ã¯å—ä¿¡å´ã®å‡¦ç†èƒ½åŠ›ã‚’è¶…ãˆã‚‹ãƒ‡ãƒ¼ã‚¿ã‚’é€ä¿¡ã—ç¶šã‘ã‚‹ã¨ã„ãšã‚Œã‚ãƒ£ãƒ‘ã‚·ãƒ†ã‚£ã‚’è¶…ãˆã¦ã‚ªãƒ¼ãƒãƒ¼ãƒ•ãƒãƒ¼ãŒç™ºç”Ÿã—ã¦ã—ã¾ã†ãŸã‚ã€é€ä¿¡å´ã«æ¯”ã¹ã¦å—ä¿¡å´ã®å‡¦ç†èƒ½åŠ›ãŒä½Žã„å ´åˆã¯é€ä¿¡å´ãŒæ‰‹åŠ æ¸›ã—ã¦ãƒ‡ãƒ¼ã‚¿ã‚’é€ä¿¡ã™ã‚‹å¿…è¦ãŒã‚ã‚Šã¾ã™ã€‚ãª
ikosin 2015/03/09
FRP

reactive

stream

akka

rxjava

spray

vert.x
ãƒªãƒ³ã‚¯
Streamä»Šæ˜”ç‰©èªž - from scratch
ã“ã®è¨˜äº‹ã¯ Node.js Advent Calendar 2014 ã® 1æ—¥ç›®ã®è¨˜äº‹ã§ã™ã€‚ ã“ã‚“ã«ã¡ã¯ã€ä»£è¡¨ã§ã™ã€‚ Streamå¤§å¥½ããªã¿ã‚“ãªã®ãŸã‚ã«Streamã®éŽåŽ»ã¨ç¾åœ¨ã€ãã—ã¦æœªæ¥ã«ã¤ã„ã¦ãŠè©±ã™ã‚‹ã‚ˆï¼ï¼ Streamã‚’ä½•æ•…ä½¿ã†ã®ã‹ã£ã¦ã„ã†è©±ã¨æ´å²çš„ãªè©±ã‚’ã—ã¾ã™ï¼ï¼ Streamã¨ã¯ ãƒ‡ãƒ¼ã‚¿ã®æµã‚Œã‚’æ‰±ã†ãŸã‚ã®æŠ½è±¡åŒ–ã•ã‚ŒãŸãƒ¢ã‚¸ãƒ¥ãƒ¼ãƒ«ã§ã™ã€‚ã‚‚ã†ã¿ã‚“ãªè€³ã«ã‚¿ã‚³ã‹ã‚‚ã—ã‚Œã¾ã›ã‚“ãŒã€Streamã‚’ä½¿ã†ã¨ãƒ‡ãƒ¼ã‚¿ã®æµã‚Œã‚’ç¶ºéº—ã«æ›¸ãã“ã¨ãŒã§ãã¾ã™ã€‚ã¡ãªã¿ã«ä»Šã«å§‹ã¾ã£ãŸæ¦‚å¿µã§ã¯ãªãã¦ã€C++ã«ã‚‚C#ã«ã‚‚StreamãŒã‚ã‚Šã¾ã™ã—ã€Java8ã®æ–°æ©Ÿèƒ½ã«ã‚‚StreamãŒã‚ã‚Šã¾ã™ã€‚ã€Œãƒ‡ãƒ¼ã‚¿ã‚’æ‰±ã†ã¨ãã®æŠ½è±¡åŒ–ã•ã‚ŒãŸæµã‚Œã€ã‚’æŒ‡ã™åºƒç¾©ã®Streamã¨ã„ã†æ„å‘³ã§ã¯ä»Šæ—¥ã®è¨€èªžã§ã¯ã ã„ãŸã„å®Ÿè£…ã•ã‚Œã¦ã„ã¾ã™ã€‚ Node.jsã§ã¯ã€ä»¥ä¸‹ã®ãƒªãƒ³ã‚¯ãŒå‚è€ƒã«ãªã‚‹ã§ã—ã‚‡ã†ã€‚ Node.js ã® Stream API ã§ã€Œãƒ‡ãƒ¼ã‚¿ã®æµã‚Œã€
ikosin 2014/12/06
node.js

stream

æ´å²
ãƒªãƒ³ã‚¯
Vert.xã‹ã‚‰ã¿ãŸReactive Streams
ikosin 2014/10/28
vert.x

rxjava

stream

reactive
ãƒªãƒ³ã‚¯
GitHub - twitter/summingbird: Streaming MapReduce with Scalding and Storm
You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session. You switched accounts on another tab or window. Reload to refresh your session. Dismiss alert
ikosin 2014/09/06
scala

hadoop

stream
ãƒªãƒ³ã‚¯
ã‚¹ãƒˆãƒªãƒ¼ãƒ è¡¨ç¾ã¨ãã®å¤‰æ› - âœ˜â•¹â—¡â•¹âœ˜
ãƒ‡ãƒ¼ã‚¿ã‚’ã‚¹ãƒˆãƒªãƒ¼ãƒ ã¨ã—ã¦è¡¨ç¾ã™ã‚‹æ–¹æ³•ã¨ã€ã‚¹ãƒˆãƒªãƒ¼ãƒ ã‚’å¤‰æ›ã™ã‚‹æ–¹æ³•ã‚’ç´¹ä»‹ã™ã‚‹ã€‚ ã‚¹ãƒˆãƒªãƒ¼ãƒ ã¯ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ãŒæµã‚Œã‚‹å·ã§ã‚ã‚‹ Pub/Subãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ãƒ³ã‚°ãƒ¢ãƒ‡ãƒ«ã§ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ã‚’æµã™ãŸã‚ã®ã‚ªãƒ–ã‚¸ã‚§ã‚¯ãƒˆã®ã“ã¨ã‚’ã‚¹ãƒˆãƒªãƒ¼ãƒ ã¨å‘¼ã¶ã“ã¨ã«ã™ã‚‹ã€‚ã‚¹ãƒˆãƒªãƒ¼ãƒ ã«ã¯ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ã‚’Publishã§ãã€ã¾ãŸãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ã‚’å—ã‘å–ã£ãŸã¨ãã®å‡¦ç†ã‚’Subscribeã§ãã‚‹ã€‚ä¾‹ãˆã°ã‚ãƒ¼ãƒœãƒ¼ãƒ‰ã‹ã‚‰ã®å…¥åŠ›ã‚’Publishã—ã¦ã€å†…å®¹ã‚’ã‚³ãƒ³ã‚½ãƒ¼ãƒ«ã«å‡ºåŠ›ã™ã‚‹ã‚ˆã†ãªå‡¦ç†ã‚’Subscribeã§ãã‚‹ã€‚ kamo.jsã§ã‚¹ãƒˆãƒªãƒ¼ãƒ ã‚’è¡¨ç¾ã™ã‚‹ ã‚¹ãƒˆãƒªãƒ¼ãƒ ã«ã¤ã„ã¦èª¬æ˜Žã™ã‚‹ãŸã‚ã«ã€kamo.jsã¨ã„ã†ã‚¹ãƒˆãƒªãƒ¼ãƒ ã‚’è¡¨ç¾ã™ã‚‹ãŸã‚ã®ãƒ©ã‚¤ãƒ–ãƒ©ãƒªã‚’ã¤ãã£ãŸã€‚kamo.jsã¯ã€ã‚¹ãƒˆãƒªãƒ¼ãƒ ã‚’ä½œæˆã™ã‚‹ãŸã‚ã®kamo.Streamã¨ã„ã†ã‚³ãƒ³ã‚¹ãƒˆãƒ©ã‚¯ã‚¿é–¢æ•°ã‚’æä¾›ã™ã‚‹ã€‚ã“ã®ã‚³ãƒ³ã‚¹ãƒˆãƒ©ã‚¯ã‚¿é–¢æ•°ã‹ã‚‰ä½œæˆã•ã‚ŒãŸã‚ªãƒ–ã‚¸ã‚§ã‚¯ãƒˆã¯ã€publishã¨subscribeã¨ã„ã†ãƒ¡ã‚½ãƒƒãƒ‰(â€»ãƒ—ãƒãƒ‘
ikosin 2014/08/21
stream

javascript
ãƒªãƒ³ã‚¯
Stream2ã®åŸºæœ¬
2. Stream ã¯å¤§äº‹ãªã‚¯ãƒ©ã‚¹ events.EventEm itter stream.Stream net.Socket tls.CleartextStream http.ServerRequest http.ClientResponse http.ServerResponse http.ClientRequest http.IncomingMessage http.outgoingMessage node-v0.8 3. Stream ã¯å¤§äº‹ãªã‚¯ãƒ©ã‚¹ events.EventEm itter stream.Stream node-v0.10 stream.Readable stream.Writable http.outgoingMessagestream.Duplex stream.Transf orm net.Socket tls.CleartextStream ãã®ä»–cryptoç³»
ikosin 2014/04/24
stream

node.js
ãƒªãƒ³ã‚¯
1 2 æ¬¡ã®ãƒšãƒ¼ã‚¸