org.apache.spark.streaming.receiver

Class BlockManagerBasedStoreResult

Object

org.apache.spark.streaming.receiver.BlockManagerBasedStoreResult

All Implemented Interfaces:

java.io.Serializable, ReceivedBlockStoreResult, scala.Equals, scala.Product

public class BlockManagerBasedStoreResult
extends Object
implements ReceivedBlockStoreResult, scala.Product, scala.Serializable

Implementation of ReceivedBlockStoreResult that stores the metadata related to storage of blocks using BlockManagerBasedBlockHandler

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BlockManagerBasedStoreResult(StreamBlockId blockId)

Method Summary

Methods

Modifier and Type	Method and Description
StreamBlockId	blockId()

Methods inherited from class Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

BlockManagerBasedStoreResult

public BlockManagerBasedStoreResult(StreamBlockId blockId)

Method Detail

blockId

public StreamBlockId blockId()

Specified by:

blockId in interface ReceivedBlockStoreResult