pyspark.streaming.StreamingContext.socketTextStream

StreamingContext.socketTextStream(hostname, port, storageLevel=StorageLevel(True, True, False, False, 2))

Create an input from TCP source hostname:port. Data is received using a TCP socket and receive byte is interpreted as UTF8 encoded \n delimited lines.

Parameters:

hostnamestr

Hostname to connect to for receiving data

portint

Port to connect to for receiving data

storageLevelpyspark.StorageLevel, optional

Storage level to use for storing the received objects

pyspark.streaming.StreamingContext.queueStream pyspark.streaming.StreamingContext.textFileStream