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.VeniceRecordWithMetadata
- 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.CompositeVeniceWriter<K,
V, U> - com.linkedin.venice.hadoop.task.datawriter.DualWriteVeniceWriter
- com.linkedin.venice.hadoop.task.datawriter.CompositeVeniceWriter<K,
- com.linkedin.venice.hadoop.task.datawriter.ExternalStorageRecord
- com.linkedin.venice.hadoop.task.datawriter.AbstractDataWriterTask
Interface Hierarchy
- java.lang.AutoCloseable
- java.io.Closeable
- com.linkedin.venice.hadoop.task.datawriter.ExternalStorageWriter
- java.io.Closeable
- com.linkedin.venice.hadoop.task.TaskTracker
- com.linkedin.venice.hadoop.task.datawriter.DataWriterTaskTracker