class DeduperDupeConsumer : BaseConsumer<Pair<String, Pair<MutableList<Long>, Dupe>>, DupePersistor>
Consumer for processing and persisting duplicate data
<init> |
Consumer for processing and persisting duplicate data DeduperDupeConsumer(dupePersistor: DupePersistor, dupeQueue: BlockingQueue<MutableList<Pair<String, Pair<MutableList<Long>, Dupe>>>>, controlQueue: ArrayBlockingQueue<DedupeReport>, deleteDupeIfExists: Boolean) |
createTarget |
create/prep duplicate persistence - can be database table or flat file fun createTarget(deleteIfExists: Boolean, persistor: DupePersistor): Unit |
getDeduperReportCount |
gets the duplicate count from dedupeReport fun getDeduperReportCount(dedupeReport: DedupeReport): Long |