org.apache.spark.streaming.rdd

Class WriteAheadLogBackedBlockRDDPartition

Object

org.apache.spark.streaming.rdd.WriteAheadLogBackedBlockRDDPartition

All Implemented Interfaces:

java.io.Serializable, Partition

public class WriteAheadLogBackedBlockRDDPartition
extends Object
implements Partition

Partition class for WriteAheadLogBackedBlockRDD. It contains information about the id of the blocks having this partition's data and the segment of the write ahead log that backs the partition.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WriteAheadLogBackedBlockRDDPartition(int index, BlockId blockId, WriteAheadLogFileSegment segment)

Method Summary

Methods

Modifier and Type	Method and Description
BlockId	blockId()
int	index() Get the split's index within its parent RDD
WriteAheadLogFileSegment	segment()

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.Partition

hashCode

Constructor Detail

WriteAheadLogBackedBlockRDDPartition

public WriteAheadLogBackedBlockRDDPartition(int index,
                                    BlockId blockId,
                                    WriteAheadLogFileSegment segment)

Method Detail

index

public int index()

Description copied from interface: Partition

Get the split's index within its parent RDD

Specified by:

index in interface Partition

blockId

public BlockId blockId()

segment

public WriteAheadLogFileSegment segment()