classBlockGenerator extends Serializable with Logging
Batches objects created by a org.apache.spark.streaming.dstream.NetworkReceiver and puts them into
appropriately named blocks at regular intervals. This class starts two threads,
one to periodically start a new batch and prepare the previous batch of as a block,
the other to push the blocks into the block manager.
Batches objects created by a org.apache.spark.streaming.dstream.NetworkReceiver and puts them into appropriately named blocks at regular intervals. This class starts two threads, one to periodically start a new batch and prepare the previous batch of as a block, the other to push the blocks into the block manager.