Page History

class RemoteLogManager extends Configurable {
     val RemoteStorageManager
     // configure
     def configure(Map<String, ?> configs)

     // CopiesAsk LogSegmentsRLM yetto tomonitor bethe copiedgiven toTopicPartitions, remoteand storagecopy forinactive theLog
 given set of TopicPartitions.
 // Segments to remote //storage. ItRLM updates local index RemoteLogSegmentIndexfiles once a LogSegment
     // Log Segment in a TopicPartition is copied to Remote Storage.
     def addPartitions(topicPartitions: Set[TopicPartition]): boolean

     // Stops copy of LogSegment if TopicPartition ownership is moved from a broker.
     def removePartitions(topicPartitions: Set[TopicPartition]): boolean
   
     
     // Read topic partition data from remote
     def read(fetchMaxByes: Int, hardMaxBytesLimit:Boolean, readPartitionInfo: Seq[(TopicPartition, PartitionData)]): LogReadResult

     // Stops all the threads and closes the instance.
     def shutdown(): Unit   
}