LogLoader¶

Creating Instance¶

LogLoader takes the following to be created:

• Directory
• TopicPartition
• LogConfig
• Scheduler
• Time
• LogDirFailureChannel
• hadCleanShutdown flag
• LogSegments
• logStartOffsetCheckpoint
• recoveryPointCheckpoint
• LeaderEpochFileCache
• ProducerStateManager
• numRemainingSegments
• isRemoteLogEnabled flag (default: false)

LogLoader is created when:

• UnifiedLog is requested to create a UnifiedLog

Loading¶

load(): LoadedLogOffsets

load...FIXME

load is used when:

• UnifiedLog is requested to create a UnifiedLog