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 delimited lines:

def socketTextStream(hostname: String, port: Int,
      storageLevel: StorageLevel = StorageLevel.MEMORY_AND_DISK_SER_2):
    ReceiverInputDStream[String]