org.apache.spark.storage

Class PutResult

Object

org.apache.spark.storage.PutResult

All Implemented Interfaces:

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

public class PutResult
extends Object
implements scala.Product, scala.Serializable

Result of adding a block into a BlockStore. This case class contains a few things: (1) The estimated size of the put, (2) The values put if the caller asked for them to be returned (e.g. for chaining replication), and (3) A list of blocks dropped as a result of this put. This is always empty for DiskStore.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PutResult(long size, scala.util.Either<scala.collection.Iterator<Object>,java.nio.ByteBuffer> data, scala.collection.Seq<scala.Tuple2<BlockId,BlockStatus>> droppedBlocks)

Method Summary

Methods

Modifier and Type	Method and Description
scala.util.Either<scala.collection.Iterator<Object>,java.nio.ByteBuffer>	data()
scala.collection.Seq<scala.Tuple2<BlockId,BlockStatus>>	droppedBlocks()
long	size()

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

PutResult

public PutResult(long size,
         scala.util.Either<scala.collection.Iterator<Object>,java.nio.ByteBuffer> data,
         scala.collection.Seq<scala.Tuple2<BlockId,BlockStatus>> droppedBlocks)

Method Detail

size

public long size()

data

public scala.util.Either<scala.collection.Iterator<Object>,java.nio.ByteBuffer> data()

droppedBlocks

public scala.collection.Seq<scala.Tuple2<BlockId,BlockStatus>> droppedBlocks()