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、可選

存儲器用於存儲接收到的對象