1.兩種方式
由streamingcontext可以提供的api
上面做的wordcount中的方式就算是第一種方式。
3.advanced source
使用資料接收器
執行緒負責轉換接受資料，資料產生方主動將資料傳送給sparkstreaming應用程式
receiver接收到資料後，就儲存下來
所以會有乙個一直執行的job存在
資料傳輸方式：push方式。
通過第三方的jar檔案讀取資料，資料不會在集群中形成block塊
就不需要啟動乙個專門的jpb執行receiver的工作
資料的傳輸方式：poll方式
劍指Offer 063資料流中的中位數
063資料流中的中位數 題目 如何得到乙個資料流中的中位數？如果從資料流中讀出奇數個數值，那麼中位數就是所有數值排序之後位於中間的數值。如果從資料流中讀出偶數個數值，那麼中位數就是所有數值排序之後中間兩個數的平均值。我們使用insert 方法讀取資料流，使用getmedian 方法獲取當前讀取資料的...
JDBC ODBC橋接資料庫
當使用最高許可權登入連線的時候，提示要以sysdba的身份登入 結果，發現使用了sysdba之後吐了一斤老血 直接拒絕登入，沒道理。使用者名稱和密碼檢查了，連線字串也沒毛病，都沒有問題，到底 出了問題？發現去命令列和plsql developer開發工具登入也沒有問題，試著去regedit裡面改了o...
橋接協議資料單元（BPDU）
橋接協議資料單元 bpdu 生成樹協議 stp 在交換機互相通訊時進行操作，資料報文以橋協議資料單元 bpdu 的形式進行交換。每隔2秒，bpdu報文便向所有的交換機埠傳送一次，以便交換機 或網橋 能交換當前最新的拓撲資訊，並迅速識別和檢測其中的環路。bpdu報文交換的目的是，選定乙個合適的參考點作...