**流是什么?：** * 數據流 * 數據的流入 * 數據的處理 * 數據的流出 * 隨處可見的數據流 * 電商網站、日志服務器、社交網絡和交通監控產生的大量實時數據 * 流處理 * 是一種允許用戶在接收到的數據后的短時間內快速查詢連續數據流和檢測條件的技術 **為什么需要流處理：** * 它能夠更快地提供洞察力，通常在毫秒到秒之間 * 大部分數據的產生過程都是一個永無止境的事件流 * 要進行批處理，需要存儲它，在某個時間停止數據收集，并處理數據 * 流處理自然適合時間序列數據和檢測模式隨時間推移 **流處理應用場景：** * 股市監控 * 交通監控 * 計算機系統與網絡監控 * 監控生產線 * 供應鏈優化 * 入侵、監視和欺詐檢測 * 大多數智能設備應用 * 上下文感知促銷和廣告 * …… **如何進行流處理：** * 常用流處理框架 * Apache Spark Streaming（Spark Streaming和Flink國內用的比較多） * Apache Flink * Confluent（國外市場用的比較多） * Apache Storm（基本被Flink和Spark Streaming替代）