一、source 1. kafka source 常用參數(shù)： auto.offset.reset叫搁，只有當使用新的groupid時逸嘀，earlies...

kafka-python文檔 一隧膘、consumer 1. 常用api 二争涌、producer 三嘉冒、其他 3.1 json處理

一削葱、常用shell命令 1. 列出所有topic 2. 查看kafka版本 3. 查看offset

確保安裝juypter和spark.bashrc增加環(huán)境變量 使用：在指定目錄cmd下執(zhí)行pyspark啟動juypter才睹，進入開發(fā)環(huán)境

一徘跪、函數(shù)傳參 二、如果每個函數(shù)都需要同一個功能 三砂竖、裝飾器實現(xiàn) 四真椿、被裝飾函數(shù)有參數(shù)情況 五、帶參數(shù)的裝飾器 六乎澄、類裝飾器 主要通過call函數(shù)...

一突硝、概念 python2默認ascii碼，可以在文件頭顯式指定編碼（utf-8置济，此時所有str的編碼都是utf-8)python2底層兩種編碼：...

創(chuàng)建 val df=spark.createDataset(Seq(("aaa",1,2),("bbb",3,4))).toDF("key1",...

一解恰、graph基本概念 tensor.graph tf.get_default_graph() with g.as_default() 二、gr...