org.apache.spark.streaming.receiver

Interface ActorHelper

All Superinterfaces:

Logging

public interface ActorHelper
extends Logging

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

Methods

Modifier and Type	Method and Description
void	store(java.nio.ByteBuffer bytes) Store the bytes of received data as a data block into Spark's memory.
<T> void	store(scala.collection.Iterator<T> iter) Store an iterator of received data as a data block into Spark's memory.
<T> void	store(T item) Store a single item of received data to Spark's memory.

Methods inherited from interface org.apache.spark.Logging

initialized, initializeIfNecessary, initializeLogging, initLock, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Method Detail

store

<T> void store(scala.collection.Iterator<T> iter)

Store an iterator of received data as a data block into Spark's memory.

store

void store(java.nio.ByteBuffer bytes)

Store the bytes of received data as a data block into Spark's memory. Note that the data in the ByteBuffer must be serialized using the same serializer that Spark is configured to use.

store

<T> void store(T item)

Store a single item of received data to Spark's memory. These single items will be aggregated together into data blocks before being pushed into Spark's memory.