|Constructor and Description|
|Modifier and Type||Method and Description|
This methods translates the data from an inputstream (say, from a socket) to '\n' delimited strings and returns an iterator to access the strings.
This method is called by the system when the receiver is started.
This method is called by the system when the receiver is stopped.
Create a socket connection and receive data until receiver is stopped
attachExecutor, executor_, isStarted, isStopped, preferredLocation, reportError, restart, restart, restart, setReceiverId, stop, stop, storageLevel, store, store, store, store, store, store, store, store, store, streamId
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public static scala.collection.Iterator<String> bytesToLines(java.io.InputStream inputStream)
public void onStart()
If there are errors in threads started here, then following options can be done
reportError(...) can be called to report the error to the driver.
The receiving of data will continue uninterrupted.
stop(...) can be called to stop receiving data. This will call
clear up all resources allocated (threads, buffers, etc.) during
restart(...) can be called to restart the receiver. This will call
immediately, and then
onStart() after a delay.
public void onStop()
onStart()must be cleaned up in this method.
public void receive()