Class Hierarchy
- java.lang.Object
- com.linkedin.venice.hadoop.task.datawriter.AbstractDataWriterTask
- com.linkedin.venice.hadoop.task.datawriter.AbstractInputRecordProcessor<INPUT_KEY,INPUT_VALUE> (implements java.io.Closeable)
- com.linkedin.venice.hadoop.task.datawriter.AbstractPartitionWriter (implements java.io.Closeable)
- com.linkedin.venice.hadoop.task.datawriter.AbstractPartitionWriter.DuplicateKeyPrinter (implements java.lang.AutoCloseable, java.io.Closeable)
- com.linkedin.venice.hadoop.task.datawriter.AbstractPartitionWriter.PartitionWriterProducerCallback (implements com.linkedin.venice.pubsub.api.PubSubProducerCallback)
- com.linkedin.venice.hadoop.task.datawriter.AbstractPartitionWriter.VeniceWriterMessage
- com.linkedin.venice.hadoop.task.datawriter.AbstractDataWriterTask
Interface Hierarchy
- com.linkedin.venice.hadoop.task.TaskTracker
- com.linkedin.venice.hadoop.task.datawriter.DataWriterTaskTracker