org.apache.spark.streaming.scheduler

Class ReceivedBlockInfo

Object

org.apache.spark.streaming.scheduler.ReceivedBlockInfo

All Implemented Interfaces:

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

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

Information about blocks received by the receiver

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ReceivedBlockInfo(int streamId, long numRecords, ReceivedBlockStoreResult blockStoreResult)

Method Summary

Methods

Modifier and Type	Method and Description
ReceivedBlockStoreResult	blockStoreResult()
long	numRecords()
int	streamId()

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

ReceivedBlockInfo

public ReceivedBlockInfo(int streamId,
                 long numRecords,
                 ReceivedBlockStoreResult blockStoreResult)

Method Detail

streamId

public int streamId()

numRecords

public long numRecords()

blockStoreResult

public ReceivedBlockStoreResult blockStoreResult()