BaseConsumer |
Base definition of a runnable Consumer. Consumers are responsible for persisting data to disk abstract class BaseConsumer<T, P : WritePersistor<T>> : Runnable |
DeduperDataConsumer |
Consumer for processing and persisting target data, IE "deduped" data class DeduperDataConsumer : BaseConsumer<Map<String, Any>, TargetPersistor> |
DeduperDupeConsumer |
Consumer for processing and persisting duplicate data class DeduperDupeConsumer : BaseConsumer<Pair<String, Pair<MutableList<Long>, Dupe>>, DupePersistor> |
DeduperHashConsumer |
Consumer for processing and persisting MD-5 hashes data class DeduperHashConsumer : BaseConsumer<HashRow, HashPersistor> |