class DeduperHashConsumer : BaseConsumer<HashRow, HashPersistor>
Consumer for processing and persisting MD-5 hashes data
<init> |
Consumer for processing and persisting MD-5 hashes data DeduperHashConsumer(hashPersistor: HashPersistor, hashQueue: BlockingQueue<MutableList<HashRow>>, controlQueue: ArrayBlockingQueue<DedupeReport>, deleteIfExists: Boolean) |
createTarget |
create/prep MD-5 hash persistence - can be database table or flat file fun createTarget(deleteIfExists: Boolean, persistor: HashPersistor): Unit |
getDeduperReportCount |
gets the MD-5 hash count from dedupeReport fun getDeduperReportCount(dedupeReport: DedupeReport): Long |