BaseConsumer(persistor: P, dataQueue: BlockingQueue<MutableList<T>>, controlQueue: ArrayBlockingQueue<DedupeReport>, deleteIfExists: Boolean)
Base definition of a runnable Consumer. Consumers are responsible for persisting data to disk
T -
T
P -
P