org.apache.spark.streaming.receiver

Class WriteAheadLogBasedStoreResult

Object

org.apache.spark.streaming.receiver.WriteAheadLogBasedStoreResult

All Implemented Interfaces:

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

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

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WriteAheadLogBasedStoreResult(StreamBlockId blockId, WriteAheadLogFileSegment segment)

Method Summary

Methods

Modifier and Type	Method and Description
StreamBlockId	blockId()
WriteAheadLogFileSegment	segment()

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

WriteAheadLogBasedStoreResult

public WriteAheadLogBasedStoreResult(StreamBlockId blockId,
                             WriteAheadLogFileSegment segment)

Method Detail

blockId

public StreamBlockId blockId()

Specified by:

blockId in interface ReceivedBlockStoreResult

segment

public WriteAheadLogFileSegment segment()