Package org.apache.spark.storage

Interface LogBlockIdGenerator

public interface LogBlockIdGenerator
LogBlockIdGenerator is responsible for generating unique LogBlockIds for log blocks.

  • Method Details

    • genUniqueBlockId

      LogBlockId genUniqueBlockId(long lastLogTime, String executorId)

    • logBlockType

      scala.Enumeration.Value logBlockType()

    • nextBlockId

      LogBlockId nextBlockId(long lastLogTime, String executorId)
      Generates a new LogBlockId based on the last log time and executor ID. Make sure that the generated LogBlockId has the same log block type as this generator.

      Parameters:
      lastLogTime - The timestamp of the last log entry.
      executorId - The ID of the executor generating the log block.
      Returns:
      (undocumented)