Queue<E> persistQueue
com.fasterxml.jackson.databind.ObjectMapper mapper
AtomicLong lastWrite
ExecutorService executor
MongoConfiguration config
MongoPersistReader.MongoPersistReaderTask readerTask
com.mongodb.DB client
com.mongodb.DBCollection collection
com.mongodb.DBCursor cursor
List<E> insertBatch
ReadWriteLock lock
Queue<E> persistQueue
com.fasterxml.jackson.databind.ObjectMapper mapper
AtomicLong lastWrite
ScheduledExecutorService backgroundFlushTask
MongoConfiguration config
com.mongodb.DB client
com.mongodb.DBAddress dbaddress
com.mongodb.DBCollection collection
List<E> insertBatch
ReadWriteLock lock
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.