org.apache.spark.storage

Class BlockInfo

Object

org.apache.spark.storage.BlockInfo

public class BlockInfo
extends Object

Constructor Summary

Constructors

Constructor and Description
BlockInfo(StorageLevel level, boolean tellMaster)

Method Summary

Methods

Modifier and Type	Method and Description
StorageLevel	level()
void	markFailure() Mark this BlockInfo as ready but failed
void	markReady(long sizeInBytes) Mark this BlockInfo as ready (i.e.
long	size()
boolean	tellMaster()
boolean	waitForReady() Wait for this BlockInfo to be marked as ready (i.e.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BlockInfo

public BlockInfo(StorageLevel level,
         boolean tellMaster)

Method Detail

level

public StorageLevel level()

tellMaster

public boolean tellMaster()

size

public long size()

waitForReady

public boolean waitForReady()

Wait for this BlockInfo to be marked as ready (i.e. block is finished writing). Return true if the block is available, false otherwise.

markReady

public void markReady(long sizeInBytes)

Mark this BlockInfo as ready (i.e. block is finished writing)

markFailure

public void markFailure()

Mark this BlockInfo as ready but failed