MongoBulkWriter.java 文件源码

public MongoBulkWriter(String URI, String namespace)
{
    logger = LoggerFactory.getLogger(MongoBulkWriter.class);
    logger.info("Connecting to " + URI );
    mongoClient = new MongoClient(new MongoClientURI(URI));
    String[] parts = namespace.split("\\.");
    db = mongoClient.getDatabase(parts[0]);
    collection = db.getCollection(parts[1]);

    ops = new ArrayList<WriteModel<Document>>();
}