Partition Log

Log is a partition log that…​FIXME

Log is created when…​FIXME

Creating Log Instance

Log takes the following when created:

  • Directory

  • LogConfig

  • logStartOffset

  • recoveryPoint

  • Scheduler

  • BrokerTopicStats

  • Time

  • maxProducerIdExpirationMs

  • producerIdExpirationCheckIntervalMs

  • TopicPartition

  • ProducerStateManager

  • LogDirFailureChannel

Log initializes the internal registries and counters.

While being created, Log…​FIXME

Creating Log Instance — apply Factory Method

apply(
  dir: File,
  config: LogConfig,
  logStartOffset: Long,
  recoveryPoint: Long,
  scheduler: Scheduler,
  brokerTopicStats: BrokerTopicStats,
  time: Time = Time.SYSTEM,
  maxProducerIdExpirationMs: Int,
  producerIdExpirationCheckIntervalMs: Int,
  logDirFailureChannel: LogDirFailureChannel): Log

apply…​FIXME

Note
apply is used when LogManager is requested to loadLog and getOrCreateLog.

roll Method

roll(expectedNextOffset: Long = 0): LogSegment

roll…​FIXME

Note
roll is used when…​FIXME

asyncDeleteSegment Method

asyncDeleteSegment(segment: LogSegment): Unit

asyncDeleteSegment…​FIXME

Note
asyncDeleteSegment is used when…​FIXME

flush Method

flush(offset: Long): Unit

flush…​FIXME

Note
flush is used when…​FIXME

deleteSeg Internal Method

deleteSeg(): Unit

deleteSeg…​FIXME

Note
deleteSeg is used when…​FIXME

results matching ""

    No results matching ""