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.AbstractInputRecordProcessor<INPUT_KEY,
- com.linkedin.venice.hadoop.task.datawriter.AbstractPartitionWriter.ChildWriterProducerCallback (implements com.linkedin.venice.pubsub.api.PubSubProducerCallback)
- 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.writer.AbstractVeniceWriter<K,
V, U> (implements java.io.Closeable) - com.linkedin.venice.hadoop.task.datawriter.ComplexVeniceWriterAdapter<K,
V, U> - com.linkedin.venice.hadoop.task.datawriter.CompositeVeniceWriter<K,
V, U>
- com.linkedin.venice.hadoop.task.datawriter.ComplexVeniceWriterAdapter<K,
- com.linkedin.venice.hadoop.task.datawriter.AbstractDataWriterTask
Interface Hierarchy
- com.linkedin.venice.hadoop.task.TaskTracker
- com.linkedin.venice.hadoop.task.datawriter.DataWriterTaskTracker