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、可选 -
存储器用于存储接收到的对象