Building Reactive Fast Data & the Data Lake with Akka, Kafka, Spark
Building Reactive Fast Data & the Data Lake with Akka, Kafka, Spark In this session, we will discuss: * reactive architecture tenets * distributed “fast data†streams * application and analytics focused Data Lake Enterprise level concerns and the importance of holistic governance, operational management, and a Metadata Lake will be conceptually investigated. The next level of detail will be to exp
「リアクティブプãƒã‚°ãƒ©ãƒŸãƒ³ã‚°ãŒèªã¿é›£ã„ã€ã¨ã„ã†ã®ã¯æœ¬å½“ãªã®ã‹? - Qiita
追記(2017/05/2) redux-sagaã§ã®éžåŒæœŸãƒãƒ¼ã‚¸ãƒ§ãƒ³ã®ç´¹ä»‹ã¨ãƒªãƒ³ã‚¯ã‚’追記。 追記(2017/2/23ä¿®æ£) 元記事ã®è¿½è¨˜3ã«ã¦è¨€åŠã‚’é ‚ã„ãŸã‚ˆã†ã«ã€ä»¥ä¸‹ã®ã€Œè¦‹æ˜“ã„版ã€ã‚³ãƒ¼ãƒ‰ã¯å…ƒã‚³ãƒ¼ãƒ‰ãŒå®Ÿç¾ã—ã¦ã„ãŸæ©Ÿèƒ½ãŒæŠœã‘ãŠã¡ã¦ã„ã‚‹ã¨ã„ã†èª¤ã‚ŠãŒã‚ã‚Šã¾ã™ã€‚é…ããªã‚Šã¾ã—ãŸãŒã€ãŠè©«ã³ã®ä¸Šä¿®æ£ã•ã›ã¦ã„ãŸã ãã¾ã™ã€‚ ä¿®æ£å†…容ã¯ä»¥ä¸‹ã®ã€Œrefreshボタン押下ã§ã™ã¹ã¦ã®å€™è£œã‚’消去ã€ã®é …ç›®ã«è¿½è¨˜ã—ã¾ã—ãŸã€‚ 上記追記ã®è¶£æ—¨ã¨ã—ã¦ã€ãƒªã‚¢ã‚¯ãƒ†ã‚£ãƒ–プãƒã‚°ãƒ©ãƒŸãƒ³ã‚°ã¯ãã‚Œã»ã©åˆ¤ã‚Šé›£ã„ã®ã ã€ã¨ã„ã†ã”指摘ã«ãªã£ã¦ã„ã¾ã™ãŒã€è¿”ã™è¨€è‘‰ã‚‚ã”ã–ã„ã¾ã›ã‚“。 ã¯ã˜ã‚㫠先日「リアクティブプãƒã‚°ãƒ©ãƒŸãƒ³ã‚°ã¨ã¯ä½•ã ã£ãŸã‹ã€ã¨ã„ã†è¨˜äº‹ã‚’ç›®ã«ã—ã¾ã—ã¦ã€å†…容ã¯ãŸã„ã¸ã‚“興味深ã‹ã£ãŸã®ã§ã™ãŒã€ä»¥ä¸‹ã®è¨˜è¿°ãŒã‚ã‚Šã¾ã—ãŸã€‚ 『宣言的ã€ã¨ã„ãˆãã†ãªã®ã¯ã‚ã‹ã‚Šã¾ã™ã—ã€ãƒ‘ラダイムã¨ã—ã¦å¾“æ¥ã®ã‚³ãƒ¼ãƒ‰ã¨ã¯ä¸€ç·šã‚’ç”»ã™ã‚‚ã®ã§ã‚ã‚‹ã“ã¨ã¯ç¢ºã‹ã§ã™ãŒã€ã©ã†è´”屓目ã«ã¿ã¦ã‚‚ã²ãŸ
Reactive Spring
At SpringOne2GX 2015, Juergen announced plans for Spring Framework 5 with a major focus on reactive architectures. Concrete efforts are already underway and a lot has happened since! At the most basic level, reactive programming models allow for writing non-blocking services and applications. This requires a fundamental shift from writing imperative logic to async, non-blocking, functional-style c
"Reactive Streams" ã®å®Ÿè£…ã¯ã©ã†ãªã£ã¦ã„ã‚‹ã®ï¼Ÿ - Taste of Tech Topics
ã“ã‚“ã«ã¡ã¯ã€‚@kimutanskã§ã™ã€‚ å¤ã®æ—¥å·®ã—ãŒæ—¥ã«æ—¥ã«å¢—ã—ã€ã‚»ãƒŸã‚‚盛んã«é³´ãã¯ã˜ã‚ã¾ã—ãŸãŒã€çš†ã•ã‚“å¤ãƒãƒ†ãªã©ã•ã‚Œã¦ã„ã¾ã›ã‚“ã‹ï¼Ÿ ã•ã¦ã€ä»Šå›žã®å†…容ã¯ã€éžåŒæœŸã‚¹ãƒˆãƒªãƒ¼ãƒ 処ç†ç•Œéšˆã§æ³¨ç›®ã®ã€ŒReactive Streamsã€ã§ã™ã€‚ 先月ã®JJUGナイトセミナーã§ã‚‚å–り上ã’られã¦ãŠã‚Šã€ç§ã¯æ®‹å¿µãªãŒã‚‰å‚åŠ ã¯ã§ããªã‹ã£ãŸã®ã§ã™ãŒ 後ã‹ã‚‰è³‡æ–™ã‚’èªã‚“ã§å‹‰å¼·ã•ã›ã¦ã„ãŸã ãã¾ã—ãŸã€‚jjug.doorkeeper.jp 1. Reactive Streamsã¨ã¯ä½•ã‹ï¼Ÿ Reactive Streamsã¨ã¯ã€ã€ŒJVM 上ã§ã®ãƒŽãƒ³ãƒ–ãƒãƒƒã‚ングãªãƒãƒƒã‚¯ãƒ—レッシャーをæŒã¤éžåŒæœŸã‚¹ãƒˆãƒªãƒ¼ãƒ 処ç†ã®æ¨™æº–ã€ã§ã€ 様々ãªéžåŒæœŸã‚¹ãƒˆãƒªãƒ¼ãƒ 処ç†ã®ã‚¤ãƒ³ã‚¿ãƒ•ã‚§ãƒ¼ã‚¹ã‚’共通化ã—ã¦æ¨™æº–çš„ã«æ‰±ãˆã‚‹ã‚ˆã†ã«ã—よã†ã¨ã„ã†ã‚‚ã®ã§ã™ã€‚ 分散環境ã§ã®éžåŒæœŸã‚¹ãƒˆãƒªãƒ¼ãƒ 処ç†ã«ãŠã„ã¦ã¯ã€ 「上æµã®ã‚³ãƒ³ãƒãƒ¼ãƒãƒ³ãƒˆç¾¤ã®æ–¹ãŒå‡¦ç†èƒ½åŠ›ãŒé«˜ãã€ä¸‹æµã®ã‚³ãƒ³ãƒãƒ¼ãƒãƒ³ãƒˆç¾¤ãŒ
ReactiveX ã¨ã€Œæ™®é€šã®ã‚„ã¤ã‚‰ã®ä¸Šã‚’è¡Œã‘ã€ã®æ„外ãªé–¢ä¿‚ - Okapies' Archive
ã“ã‚Œã¯ã€Œé–¢æ•°åž‹ãƒ—ãƒã‚°ãƒ©ãƒžã®ãŸã‚ã® Rx 入門ã€ã®è£œè¶³è¨˜äº‹ã§ã™ï¼ˆã‚¿ã‚¤ãƒˆãƒ«å¤‰ãˆãŸï¼‰ã€‚ å‰ç·¨ã€å¾Œç·¨ã¨ãŠé€ã‚Šã—ã¦ããŸã“ã®è¨˜äº‹ã ãŒã€ç‰¹ã«å¾Œç·¨ã«ã¤ã„ã¦ã€Œä½•ã‚’言ã£ã¦ã‚‹ã®ã‹åˆ†ã‹ã‚‰ã‚“ã€ã¨ã„ã†ã‚³ãƒ¡ãƒ³ãƒˆã‚’何人ã‹ã®æ–¹ã‹ã‚‰é ‚ã„ãŸã€‚…ãªã‚“ã¨ã„ã†ã‹ã€ã”ã‚ã‚“ãªã•ã„。 ç¹°ã‚Šè¿”ã—ã«ãªã‚‹ãŒã€Rx を使ã†ä¸Šã§é–¢æ•°åž‹ãƒ—ãƒã‚°ãƒ©ãƒŸãƒ³ã‚°ã®çŸ¥è˜ã¯å¿…ãšã—ã‚‚å¿…è¦ã§ã¯ãªã„ã—ã€ã‚€ã—ã‚（関数型ã®ã‚³ãƒ³ã‚»ãƒ—トãŒåŸºç¤Žã«ã‚ã‚‹ã®ã«é–¢ã‚らãšï¼‰çŸ¥ã‚‰ãªãã¦ã‚‚使ãˆã‚‹ã‚ˆã†ã«ãªã£ã¦ã„る。ライブラリã®ä½œè€…ãŸã¡ã¯ã€ŒéŽåº¦ãªæŠ½è±¡åŒ–ã¯å®³ã«ãªã‚‹ã€ã¨ã„ã†ã“ã¨ã‚’å¼ãˆã¦ã„ã‚‹ã®ã ã‚ã†ã€‚ ã—ã‹ã—ã€Rx ã¨é–¢æ•°åž‹ãƒ—ãƒã‚°ãƒ©ãƒŸãƒ³ã‚°ã®é–¢ä¿‚を把æ¡ã—ã¦ãŠãã¨ã€éžåŒæœŸãƒ‡ãƒ¼ã‚¿ã‚¹ãƒˆãƒªãƒ¼ãƒ ã®ãƒ“ルディング・ブãƒãƒƒã‚¯ã®ä½œã‚Šæ–¹ã«ã¤ã„ã¦å¤§ã„ã«è¦–野ãŒåºƒãŒã‚‹ã ã‚ã†ã€‚ã‚‚ã—ã€è²´æ–¹ãŒã“ã®è¨˜äº‹ã®å‰æã¨ãªã‚‹ã€Œé–¢æ•°åž‹ã€ã®ãƒ‘ラダイムã«èˆˆå‘³ã‚’ãŠæŒã¡ãªã‚‰ã€ã¾ãšã¯ã€Œé–¢æ•°ãƒ—ãƒã‚°ãƒ©ãƒŸãƒ³ã‚°å®Ÿè·µå…¥é–€ã€ã‚’ãŠå‹§ã‚ã—ãŸã„。 関数プãƒã‚°ãƒ©ãƒŸãƒ³ã‚°å®Ÿè·µå…¥é–€ ──
関数型プãƒã‚°ãƒ©ãƒžã®ãŸã‚ã® Rx 入門（後編） - Okapies' Archive
å‰ç·¨ã§ã¯ã€Reactive Extensions (Rx) ã®æ©Ÿèƒ½ã‚’関数型プãƒã‚°ãƒ©ãƒŸãƒ³ã‚°ã®è¦–点ã§èªã¿è§£ã„ãŸã€‚続ã„ã¦å¾Œç·¨ã§ã¯ã€å‰ç·¨ã§ç´¹ä»‹ã—㟠Rx ãŒé–¢æ•°åž‹çš„ãªæ©Ÿèƒ½ã‚’æä¾›ã—ã¦ã„る背景ã€ã¤ã¾ã‚Š Observable ã¨ä»–ã®ä¸€èˆ¬çš„ãªã‚³ãƒ³ãƒ†ãƒŠã®é–¢ä¿‚ã«å¯¾ã—ã¦ã‚¹ãƒãƒƒãƒˆãƒ©ã‚¤ãƒˆã‚’当ã¦ã¦ã¿ãŸã„。 ã‚らã‹ã˜ã‚æ–ã£ã¦ãŠãã¨ã€æœ¬ç·¨ã®è©±é¡Œã¯ã€å®Ÿéš›ã« Rx を使ã†ä¸Šã§ç†è§£ã—ã¦ã„ã‚‹å¿…è¦ã¯ï¼ˆã‚ã¾ã‚Šï¼‰ãªã„。ã¨ã‚Šã‚ãˆãšã€ Observable ã¯ã€List ã‚„ Future ã¨åŒã˜ãモナドã®ä¸€ç¨®ã§ã‚ã‚‹ 以下ã®è¡¨ã«å‡ºã¦ãるコンテナã¯ã€éš£åŒå£«ã§äº’ã„ã«ã‚ˆãä¼¼ãŸï¼ˆã‚ã‚‹ã„ã¯æ£å対ã®ï¼‰æ€§è³ªã‚’æŒã£ã¦ã„ã‚‹: å˜æ•° 複数 åŒæœŸ (pull) T/Try[T] Iterable[T] éžåŒæœŸ (push) Future[T] Observable[T] …ã¨ã„ã†è©±ã ã‘記憶ã«ç•™ã‚ã¦ã‚‚らãˆã°ã€ã“ã“ã§å›žã‚Œå³ã—ã¦ã‚‚オーケー。ã¨ã¯ã„ãˆã€èˆˆå‘³ã®ã‚る人ã¯ã“ã®
Reactive Programming in JavaScript - Frontrend Final Conference 資料
Reactive Programming in JavaScript ( 今回ã®ã‚¹ãƒ©ã‚¤ãƒ‰: HTML版 ) ã“ã®ã‚¹ãƒ©ã‚¤ãƒ‰è‡ªä½“㌠Bacon.js ã§æ›¸ã‹ã‚ŒãŸ ahomu/Talkie ã§ä½œã‚‰ã‚Œã¦ã„ã¾ã™ã€‚Rxç³»ã®ãƒ©ã‚¤ãƒ–ラリã«èˆˆå‘³ã‚’æŒãŸã‚ŒãŸæ–¹ã¯ã€ãœã²ã‚³ãƒ¼ãƒ‰ã®ã»ã†ã‚‚ã”覧ã„ãŸã ã‘ã‚Œã°ã€‚ アジェンダ What is Reactive Programming ? Reactive in Frontend JavaScript FRP with Reactive Extensions Reactive Programming ã«ã¤ã„ã¦ç´¹ä»‹ã—ã¾ã—ãŸã€‚今回も懲りãšã«æ–°ãƒã‚¿ã§ã—ゃã¹ã£ãŸæ¬¡ç¬¬ã€‚Reactive ã‚‚ Functional も若干ã“ã‚ã„ã²ã¨ãŸã¡ãŒç”Ÿæ¯ã—ã¦ã„るイメージ（個人ã®æ„Ÿæƒ³ã§ã™ï¼‰ãŒã‚ã‚‹ã®ã§ã€é…延評価ã§é£›ã‚“ã§ãã‚‹æ–§ã ã‘ãŒã“ã‚ã„ :P ノイズé¿ã‘ 率直ãªæ„Ÿæƒ³ã¨ã—ã¦ã€RP/FRP ã‚’å¦ã¼ã†ã¨ã™ã‚‹ã¨æƒ…å ±
2015å¹´ã«å‚™ãˆã¦çŸ¥ã£ã¦ãŠããŸã„リアクティブアーã‚テクãƒãƒ£ã®æ½®æµ - Qiita
ã¯ã˜ã‚ã« ã‚‚ã†ã™ã£ã‹ã‚Šå¹´æœ«ãªã®ã§ã€ã“ã‚Œã‹ã‚‰2015å¹´ã«ã‹ã‘ã¦ã‚¢ãƒ—リケーションアーã‚テクãƒãƒ£ãŒã©ã®ã‚ˆã†ã«ãªã£ã¦ã„ãã®ã‹ã¨ã„ã†å€‹äººçš„ãªè€ƒãˆ/妄想や背景ã«ã¤ã„ã¦ã€ã€Œãƒªã‚¢ã‚¯ãƒ†ã‚£ãƒ–ã€ã¨ã„ã†ã‚ーワードをもã¨ã«ã«ã¾ã¨ã‚ã¦ã¿ãŸã„ã¨æ€ã„ã¾ã™ã€‚ Google Trendsを見るã¨"reactive programming"ã¨ã„ã†è¨€è‘‰ã¯2010å¹´å‰å¾Œã‹ã‚‰ã€ã‚†ã£ãã‚Šã¨ãƒã‚ºã‚’ã—始ã‚ã€ç¾åœ¨ã‚‚上昇を続ã‘ã¦ã„ã¾ã™ã€‚ ã¾ãŸã€ä»•äº‹ã¨ã—ã¦ã¯ã€2010å¹´ã”ã‚ã‹ã‚‰å¤§è¦æ¨¡ãªWebサービス開発ã«ãŠã„ã¦ã€ãƒ•ãƒãƒ³ãƒˆã‚¨ãƒ³ãƒ‰ã€ãƒãƒƒã‚¯ã‚¨ãƒ³ãƒ‰ã€ã‚¢ãƒ«ã‚´ãƒªã‚ºãƒ 改善ã¨ã„ã£ãŸæ§˜ã€…ãªç®‡æ‰€ã§ã€ãƒªã‚¢ã‚¯ãƒ†ã‚£ãƒ–プãƒã‚°ãƒ©ãƒŸãƒ³ã‚°ã®è¦ç´ ã‚’å–り入れãªãŒã‚‰ã€ã‚¢ãƒ¼ã‚テクãƒãƒ£ã®æ”¹å–„を進ã‚ã¦ãã¾ã—ãŸã€‚ãã®ãŸã‚ã€ã“ã†ã„ã£ãŸã‚¢ãƒ¼ã‚テクãƒãƒ£ãŒã‚³ãƒ¼ãƒ‰å“質ã®ç¶æŒã‚„安定性ã®å‘上ã€å®Ÿéš›çš„ã§è¤‡é›‘ãªå•é¡Œã®è§£æ±ºã«ã‚‚é©å¿œå¯èƒ½ã§ã‚ã‚‹ã¨ã„ã†ã“ã¨ã‚’実感ã¨ã—ã¦æŒã£ã¦ã„ã¾ã™ã€‚ è¿‘å¹´ã€ãã†ã„ã£ãŸè¦ç´ ãŒæ§˜ã€…ãªãƒ„ール
1
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
Not Only Streams for Akademia JLabs
Reactive integrations with Akka Streams
Reactive Webアプリケーション - ãã—ã¦Spring 5㸠#jjug_ccc #ccc_ef3
Reactive ã¨ã¯ä½•ã‹ï¼Ÿ #reactive_shinjuku
Reactive Streamsを使ã£ã¦ã¿ã‚ˆã†
Reactive Streams 入門 #jjug
Reactive Streams for Apache Kafka
{{#tags}}- {{label}}
{{/tags}}