public class ReceiverTracker extends Object implements Logging
Modifier and Type | Class and Description |
---|---|
class |
ReceiverTracker.ReceiverLauncher
This thread class runs all the receivers on the cluster.
|
Constructor and Description |
---|
ReceiverTracker(StreamingContext ssc,
boolean skipReceiverLaunch) |
Modifier and Type | Method and Description |
---|---|
void |
allocateBlocksToBatch(Time batchTime)
Allocate all unallocated blocks to the given batch.
|
void |
cleanupOldBlocksAndBatches(Time cleanupThreshTime)
Clean up the data and metadata of blocks and batches that are strictly
older than the threshold time.
|
scala.collection.immutable.Map<Object,scala.collection.Seq<ReceivedBlockInfo>> |
getBlocksOfBatch(Time batchTime)
Get the blocks for the given batch and all input streams.
|
scala.collection.Seq<ReceivedBlockInfo> |
getBlocksOfBatchAndStream(Time batchTime,
int streamId)
Get the blocks allocated to the given batch and stream.
|
boolean |
hasUnallocatedBlocks()
Check if any blocks are left to be processed
|
void |
start()
Start the actor and receiver execution thread.
|
void |
stop(boolean graceful)
Stop the receiver execution thread.
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public ReceiverTracker(StreamingContext ssc, boolean skipReceiverLaunch)
public void start()
public void stop(boolean graceful)
public void allocateBlocksToBatch(Time batchTime)
public scala.collection.immutable.Map<Object,scala.collection.Seq<ReceivedBlockInfo>> getBlocksOfBatch(Time batchTime)
public scala.collection.Seq<ReceivedBlockInfo> getBlocksOfBatchAndStream(Time batchTime, int streamId)
public void cleanupOldBlocksAndBatches(Time cleanupThreshTime)
public boolean hasUnallocatedBlocks()