pyspark.streaming.StreamingContext.socketTextStream¶
-
StreamingContext。socketTextStream( 主機名:str,港口:int,storageLevel:pyspark.storagelevel.StorageLevel=StorageLevel(真的,真的,假的,假的,2) )→pyspark.streaming.dstream.DStream(str] ¶ -
創建一個輸入從源主機名:TCP端口。使用TCP套接字接收數據和接收字節被解釋為UTF8編碼
\ n分隔線。- 參數
-
- 主機名 str
-
主機連接到接收數據
- 港口 int
-
端口連接到接收數據
-
storageLevel
pyspark.StorageLevel、可選 -
存儲器用於存儲接收到的對象