Class OplogReader


  • public class OplogReader
    extends java.lang.Object
    • Constructor Detail

      • OplogReader

        public OplogReader​(com.mongodb.MongoClient mongoClient,
                           java.lang.Integer dataMaxSize)
    • Method Detail

      • readDocumentsFromOplogByShardAndCollections

        public java.util.Map<java.lang.String,​org.bson.Document> readDocumentsFromOplogByShardAndCollections​(java.util.List<java.lang.String> collectionsToReadOplog,
                                                                                                                   org.bson.BsonTimestamp maxTimeStamp)