Package org.apache.spark.storage

Class LogBlockId

Object

org.apache.spark.storage.BlockId

org.apache.spark.storage.LogBlockId

Direct Known Subclasses:

TestLogBlockId

public abstract class LogBlockId
extends BlockId

Identifies a block of log data.

param: lastLogTime the timestamp of the last log entry in this block, used for filtering and log management. param: executorId the ID of the executor that produced this log block.

Constructor Summary

Constructors

Constructor	Description
LogBlockId(long lastLogTime, String executorId)

Method Summary

Modifier and Type	Method	Description
static LogBlockId	empty(scala.Enumeration.Value logBlockType)
String	executorId()
long	lastLogTime()
abstract scala.Enumeration.Value	logBlockType()

Methods inherited from class org.apache.spark.storage.BlockId

apply, asRDDId, BROADCAST, isBroadcast, isRDD, isShuffle, isShuffleChunk, name, PYTHON_STREAM, RDD, SHUFFLE, SHUFFLE_BATCH, SHUFFLE_CHUNK, SHUFFLE_DATA, SHUFFLE_INDEX, SHUFFLE_MERGED, SHUFFLE_MERGED_DATA, SHUFFLE_MERGED_INDEX, SHUFFLE_MERGED_META, SHUFFLE_PUSH, STREAM, TASKRESULT, TEMP_LOCAL, TEMP_SHUFFLE, TEST, TEST_LOG_BLOCK, toString

Methods inherited from class java.lang.Object

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

Constructor Details

LogBlockId

public LogBlockId(long lastLogTime,
 String executorId)

Method Details

empty

public static LogBlockId empty(scala.Enumeration.Value logBlockType)

lastLogTime

public long lastLogTime()

executorId

public String executorId()

logBlockType

public abstract scala.Enumeration.Value logBlockType()