deduper / org.bradfordmiller.deduper / DeduperProducer / <init>

<init>

DeduperProducer(dataQueue: BlockingQueue<MutableList<Map<String, Any>>>?, dupeQueue: BlockingQueue<MutableList<Pair<String, Pair<MutableList<Long>, Dupe>>>>?, hashQueue: BlockingQueue<MutableList<HashRow>>?, controlQueues: Map<ControlQueue, ArrayBlockingQueue<DedupeReport>>, commitSize: Long = 500, outputReportCommitSize: Long = 1000000, config: Config, persistors: Persistors, sourceDataSource: DataSource, sqlStatement: String)