DeduperDataConsumer(targetPersistor: TargetPersistor, dataQueue: BlockingQueue<MutableList<Map<String, Any>>>, controlQueue: ArrayBlockingQueue<DedupeReport>, deleteIfExists: Boolean, sourceDataSource: DataSource, sqlStatement: String)
Consumer for processing and persisting target data, IE "deduped" data