|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ActorHelper
:: DeveloperApi :: A receiver trait to be mixed in with your Actor to gain access to the API for pushing received data into Spark Streaming for being processed.
Find more details at: http://spark.apache.org/docs/latest/streaming-custom-receivers.html
Method Summary | ||
---|---|---|
void |
store(java.nio.ByteBuffer bytes)
Store the bytes of received data as a data block into Spark's memory. |
|
|
store(scala.collection.Iterator<T> iter)
Store an iterator of received data as a data block into Spark's memory. |
|
|
store(T item)
Store a single item of received data to Spark's memory. |
Methods inherited from interface org.apache.spark.Logging |
---|
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning |
Method Detail |
---|
<T> void store(scala.collection.Iterator<T> iter)
void store(java.nio.ByteBuffer bytes)
bytes
- (undocumented)<T> void store(T item)
item
- (undocumented)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |