deduper / org.bradfordmiller.deduper / DeduperProducer

DeduperProducer

class DeduperProducer : Runnable

Constructors

<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)

Properties

commitSize	`val commitSize: Long`
config	`val config: Config`
controlQueues	`val controlQueues: Map<ControlQueue, ArrayBlockingQueue<DedupeReport>>`
dataQueue	`val dataQueue: BlockingQueue<MutableList<Map<String, Any>>>?`
dupeQueue	`val dupeQueue: BlockingQueue<MutableList<Pair<String, Pair<MutableList<Long>, Dupe>>>>?`
hashQueue	`val hashQueue: BlockingQueue<MutableList<HashRow>>?`
outputReportCommitSize	`val outputReportCommitSize: Long`
persistors	`val persistors: Persistors`
sourceDataSource	`val sourceDataSource: DataSource`
sqlStatement	`val sqlStatement: String`

Functions

run	`fun run(): Unit`

Companion Object Properties

logger

val logger: Logger!