July 2017
Intermediate to advanced
796 pages
18h 55m
English
This creates an input stream from TCP source hostname:port. Data is received using a TCP socket and the received bytes are interpreted as UTF8 encoded \n delimited lines:
def socketTextStream(hostname: String, port: Int, storageLevel: StorageLevel = StorageLevel.MEMORY_AND_DISK_SER_2): ReceiverInputDStream[String]
Read now
Unlock full access