Hierarchy For All Packages

Package Hierarchies:

• com.linkedin.alpini.base.concurrency,
• com.linkedin.alpini.base.concurrency.impl,
• com.linkedin.alpini.base.hash,
• com.linkedin.alpini.base.misc,
• com.linkedin.alpini.base.monitoring,
• com.linkedin.alpini.base.pool,
• com.linkedin.alpini.base.pool.impl,
• com.linkedin.alpini.base.queuing,
• com.linkedin.alpini.base.registry,
• com.linkedin.alpini.base.registry.impl,
• com.linkedin.alpini.base.safealloc,
• com.linkedin.alpini.base.ssl,
• com.linkedin.alpini.base.statistics,
• com.linkedin.alpini.base.test,
• com.linkedin.alpini.cli,
• com.linkedin.alpini.consts,
• com.linkedin.alpini.consts.config,
• com.linkedin.alpini.io,
• com.linkedin.alpini.io.ssl,
• com.linkedin.alpini.jna,
• com.linkedin.alpini.log,
• com.linkedin.alpini.netty4.compression,
• com.linkedin.alpini.netty4.handlers,
• com.linkedin.alpini.netty4.http2,
• com.linkedin.alpini.netty4.misc,
• com.linkedin.alpini.netty4.pool,
• com.linkedin.alpini.netty4.ssl,
• com.linkedin.alpini.router,
• com.linkedin.alpini.router.api,
• com.linkedin.alpini.router.impl,
• com.linkedin.alpini.router.impl.netty4,
• com.linkedin.alpini.router.monitoring,
• com.linkedin.avro.fastserde,
• com.linkedin.davinci,
• com.linkedin.davinci.blobtransfer,
• com.linkedin.davinci.blobtransfer.client,
• com.linkedin.davinci.blobtransfer.server,
• com.linkedin.davinci.callback,
• com.linkedin.davinci.client,
• com.linkedin.davinci.client.factory,
• com.linkedin.davinci.compression,
• com.linkedin.davinci.config,
• com.linkedin.davinci.consumer,
• com.linkedin.davinci.consumer.stats,
• com.linkedin.davinci.helix,
• com.linkedin.davinci.ingestion,
• com.linkedin.davinci.ingestion.consumption,
• com.linkedin.davinci.ingestion.isolated,
• com.linkedin.davinci.ingestion.main,
• com.linkedin.davinci.ingestion.utils,
• com.linkedin.davinci.kafka.consumer,
• com.linkedin.davinci.listener.response,
• com.linkedin.davinci.notifier,
• com.linkedin.davinci.replication,
• com.linkedin.davinci.replication.merge,
• com.linkedin.davinci.repository,
• com.linkedin.davinci.schema,
• com.linkedin.davinci.schema.merge,
• com.linkedin.davinci.schema.writecompute,
• com.linkedin.davinci.serializer.avro,
• com.linkedin.davinci.serializer.avro.fast,
• com.linkedin.davinci.stats,
• com.linkedin.davinci.stats.ingestion.heartbeat,
• com.linkedin.davinci.storage,
• com.linkedin.davinci.storage.chunking,
• com.linkedin.davinci.store,
• com.linkedin.davinci.store.blackhole,
• com.linkedin.davinci.store.cache,
• com.linkedin.davinci.store.cache.backend,
• com.linkedin.davinci.store.cache.caffeine,
• com.linkedin.davinci.store.memory,
• com.linkedin.davinci.store.record,
• com.linkedin.davinci.store.rocksdb,
• com.linkedin.davinci.store.view,
• com.linkedin.davinci.utils,
• com.linkedin.davinci.validation,
• com.linkedin.venice,
• com.linkedin.venice.acl,
• com.linkedin.venice.acl.handler,
• com.linkedin.venice.admin,
• com.linkedin.venice.admin.protocol.response,
• com.linkedin.venice.annotation,
• com.linkedin.venice.authorization,
• com.linkedin.venice.blobtransfer,
• com.linkedin.venice.chunking,
• com.linkedin.venice.cleaner,
• com.linkedin.venice.client,
• com.linkedin.venice.client.change.capture.protocol,
• com.linkedin.venice.client.exceptions,
• com.linkedin.venice.client.factory,
• com.linkedin.venice.client.schema,
• com.linkedin.venice.client.stats,
• com.linkedin.venice.client.store,
• com.linkedin.venice.client.store.deserialization,
• com.linkedin.venice.client.store.predicate,
• com.linkedin.venice.client.store.schemas,
• com.linkedin.venice.client.store.streaming,
• com.linkedin.venice.client.store.transport,
• com.linkedin.venice.client.utils,
• com.linkedin.venice.common,
• com.linkedin.venice.compression,
• com.linkedin.venice.compression.protocol,
• com.linkedin.venice.compute,
• com.linkedin.venice.compute.protocol.request,
• com.linkedin.venice.compute.protocol.request.enums,
• com.linkedin.venice.compute.protocol.request.router,
• com.linkedin.venice.compute.protocol.response,
• com.linkedin.venice.controller,
• com.linkedin.venice.controller.authorization,
• com.linkedin.venice.controller.datarecovery,
• com.linkedin.venice.controller.exception,
• com.linkedin.venice.controller.helix,
• com.linkedin.venice.controller.init,
• com.linkedin.venice.controller.kafka,
• com.linkedin.venice.controller.kafka.consumer,
• com.linkedin.venice.controller.kafka.protocol.admin,
• com.linkedin.venice.controller.kafka.protocol.enums,
• com.linkedin.venice.controller.kafka.protocol.serializer,
• com.linkedin.venice.controller.lingeringjob,
• com.linkedin.venice.controller.migration,
• com.linkedin.venice.controller.server,
• com.linkedin.venice.controller.spark,
• com.linkedin.venice.controller.stats,
• com.linkedin.venice.controller.supersetschema,
• com.linkedin.venice.controller.systemstore,
• com.linkedin.venice.controller.util,
• com.linkedin.venice.controllerapi,
• com.linkedin.venice.controllerapi.routes,
• com.linkedin.venice.d2,
• com.linkedin.venice.D2,
• com.linkedin.venice.datarecovery,
• com.linkedin.venice.datarecovery.meta,
• com.linkedin.venice.etl,
• com.linkedin.venice.exceptions,
• com.linkedin.venice.exceptions.validation,
• com.linkedin.venice.fastclient,
• com.linkedin.venice.fastclient.factory,
• com.linkedin.venice.fastclient.meta,
• com.linkedin.venice.fastclient.stats,
• com.linkedin.venice.fastclient.transport,
• com.linkedin.venice.fastclient.utils,
• com.linkedin.venice.grpc,
• com.linkedin.venice.guid,
• com.linkedin.venice.hadoop,
• com.linkedin.venice.hadoop.engine,
• com.linkedin.venice.hadoop.exceptions,
• com.linkedin.venice.hadoop.input.kafka,
• com.linkedin.venice.hadoop.input.kafka.avro,
• com.linkedin.venice.hadoop.input.kafka.chunk,
• com.linkedin.venice.hadoop.input.kafka.ttl,
• com.linkedin.venice.hadoop.input.recordreader,
• com.linkedin.venice.hadoop.input.recordreader.avro,
• com.linkedin.venice.hadoop.input.recordreader.vson,
• com.linkedin.venice.hadoop.mapreduce.common,
• com.linkedin.venice.hadoop.mapreduce.counter,
• com.linkedin.venice.hadoop.mapreduce.datawriter.jobs,
• com.linkedin.venice.hadoop.mapreduce.datawriter.map,
• com.linkedin.venice.hadoop.mapreduce.datawriter.partition,
• com.linkedin.venice.hadoop.mapreduce.datawriter.reduce,
• com.linkedin.venice.hadoop.mapreduce.datawriter.task,
• com.linkedin.venice.hadoop.mapreduce.engine,
• com.linkedin.venice.hadoop.output.avro,
• com.linkedin.venice.hadoop.schema,
• com.linkedin.venice.hadoop.ssl,
• com.linkedin.venice.hadoop.task,
• com.linkedin.venice.hadoop.task.datawriter,
• com.linkedin.venice.hadoop.utils,
• com.linkedin.venice.hadoop.validation,
• com.linkedin.venice.heartbeat,
• com.linkedin.venice.helix,
• com.linkedin.venice.hooks,
• com.linkedin.venice.httpclient,
• com.linkedin.venice.httpclient5,
• com.linkedin.venice.ingestion.control,
• com.linkedin.venice.ingestion.protocol,
• com.linkedin.venice.ingestion.protocol.enums,
• com.linkedin.venice.io,
• com.linkedin.venice.jobs,
• com.linkedin.venice.kafka.protocol,
• com.linkedin.venice.kafka.protocol.enums,
• com.linkedin.venice.kafka.protocol.state,
• com.linkedin.venice.kafka.validation,
• com.linkedin.venice.kafka.validation.checksum,
• com.linkedin.venice.listener,
• com.linkedin.venice.listener.grpc,
• com.linkedin.venice.listener.grpc.handlers,
• com.linkedin.venice.listener.request,
• com.linkedin.venice.listener.response,
• com.linkedin.venice.listener.response.stats,
• com.linkedin.venice.memory,
• com.linkedin.venice.message,
• com.linkedin.venice.meta,
• com.linkedin.venice.meta.systemstore.schemas,
• com.linkedin.venice.metadata.response,
• com.linkedin.venice.migration,
• com.linkedin.venice.offsets,
• com.linkedin.venice.participant.protocol,
• com.linkedin.venice.participant.protocol.enums,
• com.linkedin.venice.partitioner,
• com.linkedin.venice.persona,
• com.linkedin.venice.producer,
• com.linkedin.venice.producer.online,
• com.linkedin.venice.protocols,
• com.linkedin.venice.pubsub,
• com.linkedin.venice.pubsub.adapter,
• com.linkedin.venice.pubsub.adapter.kafka,
• com.linkedin.venice.pubsub.adapter.kafka.admin,
• com.linkedin.venice.pubsub.adapter.kafka.consumer,
• com.linkedin.venice.pubsub.adapter.kafka.producer,
• com.linkedin.venice.pubsub.api,
• com.linkedin.venice.pubsub.api.exceptions,
• com.linkedin.venice.pubsub.manager,
• com.linkedin.venice.pulsar.sink,
• com.linkedin.venice.pushmonitor,
• com.linkedin.venice.pushstatus,
• com.linkedin.venice.pushstatushelper,
• com.linkedin.venice.read,
• com.linkedin.venice.read.protocol.request.router,
• com.linkedin.venice.read.protocol.response,
• com.linkedin.venice.read.protocol.response.streaming,
• com.linkedin.venice.request,
• com.linkedin.venice.response,
• com.linkedin.venice.router,
• com.linkedin.venice.router.acl,
• com.linkedin.venice.router.api,
• com.linkedin.venice.router.api.path,
• com.linkedin.venice.router.api.routing.helix,
• com.linkedin.venice.router.exception,
• com.linkedin.venice.router.httpclient,
• com.linkedin.venice.router.stats,
• com.linkedin.venice.router.streaming,
• com.linkedin.venice.router.throttle,
• com.linkedin.venice.router.utils,
• com.linkedin.venice.routerapi,
• com.linkedin.venice.samza,
• com.linkedin.venice.schema,
• com.linkedin.venice.schema.avro,
• com.linkedin.venice.schema.rmd,
• com.linkedin.venice.schema.rmd.v1,
• com.linkedin.venice.schema.vson,
• com.linkedin.venice.schema.writecompute,
• com.linkedin.venice.security,
• com.linkedin.venice.serialization,
• com.linkedin.venice.serialization.avro,
• com.linkedin.venice.serializer,
• com.linkedin.venice.server,
• com.linkedin.venice.service,
• com.linkedin.venice.servicediscovery,
• com.linkedin.venice.spark,
• com.linkedin.venice.spark.datawriter.jobs,
• com.linkedin.venice.spark.datawriter.partition,
• com.linkedin.venice.spark.datawriter.recordprocessor,
• com.linkedin.venice.spark.datawriter.task,
• com.linkedin.venice.spark.datawriter.writer,
• com.linkedin.venice.spark.engine,
• com.linkedin.venice.spark.input,
• com.linkedin.venice.spark.input.hdfs,
• com.linkedin.venice.spark.utils,
• com.linkedin.venice.standalone,
• com.linkedin.venice.stats,
• com.linkedin.venice.status,
• com.linkedin.venice.status.protocol,
• com.linkedin.venice.status.protocol.enums,
• com.linkedin.venice.storage.protocol,
• com.linkedin.venice.store,
• com.linkedin.venice.store.exception,
• com.linkedin.venice.store.rocksdb,
• com.linkedin.venice.streaming,
• com.linkedin.venice.system.store,
• com.linkedin.venice.systemstore.schemas,
• com.linkedin.venice.tehuti,
• com.linkedin.venice.testng,
• com.linkedin.venice.throttle,
• com.linkedin.venice.unit.kafka,
• com.linkedin.venice.unit.kafka.consumer,
• com.linkedin.venice.unit.kafka.consumer.poll,
• com.linkedin.venice.unit.kafka.producer,
• com.linkedin.venice.unit.matchers,
• com.linkedin.venice.utils,
• com.linkedin.venice.utils.collections,
• com.linkedin.venice.utils.concurrent,
• com.linkedin.venice.utils.consistency,
• com.linkedin.venice.utils.lazy,
• com.linkedin.venice.utils.locks,
• com.linkedin.venice.utils.metrics,
• com.linkedin.venice.utils.pools,
• com.linkedin.venice.views,
• com.linkedin.venice.vpj,
• com.linkedin.venice.writer,
• com.linkedin.venice.writer.update,
• com.linkedin.venice.zk,
• io.netty.bootstrap,
• io.netty.channel,
• io.netty.handler.codec,
• io.netty.handler.codec.http,
• io.netty.handler.codec.http2,
• io.netty.handler.timeout,
• org.apache.avro.generic,
• org.apache.avro.io,
• org.apache.avro.specific

Class Hierarchy

• java.lang.Object
  • com.linkedin.alpini.base.concurrency.impl.AbstractAsyncFuture<T> (implements com.linkedin.alpini.base.concurrency.AsyncFuture<T>)
    • com.linkedin.alpini.base.concurrency.impl.FailedAsyncFuture<T> (implements com.linkedin.alpini.base.concurrency.AsyncPromise<T>)
      • com.linkedin.alpini.base.concurrency.impl.CancelledAsyncFuture<T>
    • com.linkedin.alpini.base.concurrency.impl.SuccessAsyncFuture<T> (implements com.linkedin.alpini.base.concurrency.AsyncPromise<T>)
  • com.linkedin.davinci.storage.chunking.AbstractAvroChunkingAdapter<T> (implements com.linkedin.davinci.storage.chunking.ChunkingAdapter<CHUNKS_CONTAINER,VALUE>)
    • com.linkedin.davinci.storage.chunking.GenericChunkingAdapter<V>
      • com.linkedin.davinci.storage.chunking.GenericRecordChunkingAdapter
    • com.linkedin.davinci.storage.chunking.RawBytesChunkingAdapter
    • com.linkedin.davinci.storage.chunking.SpecificRecordChunkingAdapter<V>
  • com.linkedin.venice.client.store.AbstractAvroComputeRequestBuilder<K> (implements com.linkedin.venice.client.store.ComputeRequestBuilder<K>)
    • com.linkedin.venice.client.store.AvroComputeRequestBuilderV3<K>
      • com.linkedin.venice.client.store.AvroComputeRequestBuilderV4<K>
  • io.netty.bootstrap.AbstractBootstrap<B,C> (implements java.lang.Cloneable)
    • io.netty.bootstrap.Bootstrap
      • io.netty.bootstrap.InstrumentedBootstrap
        • io.netty.bootstrap.ResolveAllBootstrap
  • io.netty.buffer.AbstractByteBufAllocator (implements io.netty.buffer.ByteBufAllocator)
    • com.linkedin.alpini.base.safealloc.SafeAllocator (implements io.netty.buffer.ByteBufAllocatorMetricProvider)
  • com.linkedin.venice.fastclient.meta.AbstractClientRoutingStrategy (implements com.linkedin.venice.fastclient.meta.ClientRoutingStrategy)
    • com.linkedin.venice.fastclient.meta.HelixScatterGatherRoutingStrategy
    • com.linkedin.venice.fastclient.meta.LeastLoadedClientRoutingStrategy
  • io.netty.channel.AbstractCoalescingBufferQueue10294
  • java.util.AbstractCollection<E> (implements java.util.Collection<E>)
    • java.util.AbstractList<E> (implements java.util.List<E>)
      • java.util.AbstractSequentialList<E>
        • com.linkedin.alpini.base.misc.DoublyLinkedList<E> (implements java.util.Deque<E>)
      • java.util.ArrayList<E> (implements java.lang.Cloneable, java.util.List<E>, java.util.RandomAccess, java.io.Serializable)
        • com.linkedin.venice.schema.vson.VsonAvroDatumReader.DeepEqualsArrayList
    • java.util.AbstractQueue<E> (implements java.util.Queue<E>)
      • com.linkedin.alpini.base.concurrency.ConcurrentLinkedBlockingQueue<E> (implements java.util.concurrent.BlockingQueue<E>)
    • java.util.AbstractSet<E> (implements java.util.Set<E>)
      • com.linkedin.alpini.base.concurrency.ArraySortedSet<E> (implements java.lang.Cloneable, java.util.SortedSet<E>)
      • io.netty.channel.group.DefaultChannelGroup (implements io.netty.channel.group.ChannelGroup)
        • com.linkedin.alpini.netty4.pool.FastFixedChannelPool.PoolChannelGroup
          • com.linkedin.alpini.netty4.pool.FixedFastChannelPoolImpl.FixedPoolChannelGroup
        • com.linkedin.alpini.netty4.handlers.ShutdownableChannelGroup (implements com.linkedin.alpini.base.registry.ShutdownableResource)
  • 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.mapreduce.datawriter.map.AbstractVeniceMapper<INPUT_KEY,INPUT_VALUE> (implements org.apache.hadoop.mapred.Mapper<K1,V1,K2,V2>)
        • com.linkedin.venice.hadoop.mapreduce.datawriter.map.VeniceAvroMapper
        • com.linkedin.venice.hadoop.input.kafka.VeniceKafkaInputMapper
        • com.linkedin.venice.hadoop.mapreduce.datawriter.map.VeniceVsonMapper
      • com.linkedin.venice.spark.datawriter.recordprocessor.SparkInputRecordProcessor
    • com.linkedin.venice.hadoop.task.datawriter.AbstractPartitionWriter (implements java.io.Closeable)
      • com.linkedin.venice.spark.datawriter.writer.SparkPartitionWriter
      • com.linkedin.venice.hadoop.mapreduce.datawriter.reduce.VeniceReducer (implements org.apache.hadoop.mapred.Reducer<K2,V2,K3,V3>)
        • com.linkedin.venice.hadoop.input.kafka.VeniceKafkaInputReducer
    • com.linkedin.venice.hadoop.input.kafka.KafkaInputFormatCombiner (implements org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Reducer<K2,V2,K3,V3>)
    • com.linkedin.venice.hadoop.ValidateSchemaAndBuildDictMapper (implements org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Mapper<K1,V1,K2,V2>)
  • io.netty.util.concurrent.AbstractEventExecutorGroup (implements io.netty.util.concurrent.EventExecutorGroup)
    • com.linkedin.alpini.netty4.misc.InstrumentibleEventExecutor
    • io.netty.util.concurrent.MultithreadEventExecutorGroup
      • io.netty.channel.MultithreadEventLoopGroup (implements io.netty.channel.EventLoopGroup)
        • com.linkedin.alpini.netty4.misc.LocalThreadEventLoopGroup<E> (implements com.linkedin.alpini.netty4.misc.SingleThreadEventLoopGroupSupplier)
        • io.netty.channel.nio.NioEventLoopGroup
          • com.linkedin.alpini.netty4.misc.ShutdownableNioEventLoopGroup (implements com.linkedin.alpini.base.registry.Shutdownable)
        • com.linkedin.alpini.netty4.misc.SingleThreadEventLoopGroup
  • java.util.concurrent.AbstractExecutorService (implements java.util.concurrent.ExecutorService)
    • com.linkedin.alpini.base.registry.impl.ShutdownableExecutorServiceImpl<E> (implements com.linkedin.alpini.base.registry.ShutdownableExecutorService)
      • com.linkedin.alpini.base.registry.impl.ShutdownableScheduledExecutorServiceImpl<E> (implements com.linkedin.alpini.base.registry.ShutdownableScheduledExecutorService)
    • java.util.concurrent.ThreadPoolExecutor
      • com.linkedin.alpini.base.misc.ThreadPoolExecutor (implements com.linkedin.alpini.base.concurrency.ExecutorService)
        • com.linkedin.alpini.base.misc.TimeScheduledThreadPoolExecutor (implements com.linkedin.alpini.base.concurrency.ScheduledExecutorService)
  • org.apache.logging.log4j.core.filter.AbstractFilterable.Builder<B>
    • org.apache.logging.log4j.core.appender.AbstractAppender.Builder<B>
      • com.linkedin.venice.utils.InMemoryLogAppender.Builder (implements org.apache.logging.log4j.core.util.Builder<T>)
  • io.netty.util.concurrent.AbstractFuture<V> (implements io.netty.util.concurrent.Future<V>)
    • io.netty.util.concurrent.DefaultPromise<V> (implements io.netty.util.concurrent.Promise<V>)
      • io.netty.bootstrap.PendingConnectFuturePromise (implements io.netty.channel.ChannelPromise)
      • io.netty.bootstrap.PendingConnectPromise (implements io.netty.channel.ChannelPromise)
  • io.netty.handler.codec.http2.AbstractHttp2ConnectionHandlerBuilder<T,B>
    • io.netty.handler.codec.http2.Http2FrameCodecBuilder
      • io.netty.handler.codec.http2.EspressoHttp2FrameCodecBuilder
  • org.apache.logging.log4j.core.AbstractLifeCycle (implements org.apache.logging.log4j.core.LifeCycle2)
    • org.apache.logging.log4j.core.filter.AbstractFilterable (implements org.apache.logging.log4j.core.filter.Filterable)
      • org.apache.logging.log4j.core.appender.AbstractAppender (implements org.apache.logging.log4j.core.Appender, org.apache.logging.log4j.core.impl.LocationAware)
        • com.linkedin.venice.utils.InMemoryLogAppender
  • java.util.AbstractMap<K,V> (implements java.util.Map<K,V>)
    • com.linkedin.alpini.base.misc.ArrayMap<K,V>
    • java.util.concurrent.ConcurrentHashMap<K,V> (implements java.util.concurrent.ConcurrentMap<K,V>, java.io.Serializable)
      • com.linkedin.venice.utils.concurrent.VeniceConcurrentHashMap<K,V>
    • java.util.HashMap<K,V> (implements java.lang.Cloneable, java.util.Map<K,V>, java.io.Serializable)
      • java.util.LinkedHashMap<K,V> (implements java.util.Map<K,V>)
        • com.linkedin.venice.utils.BoundedHashMap<K,V>
        • com.linkedin.venice.utils.collections.MeasurableLinkedHashMap<K,V> (implements com.linkedin.venice.memory.Measurable)
      • com.linkedin.venice.client.store.streaming.VeniceResponseMapImpl<K,V> (implements com.linkedin.venice.client.store.streaming.VeniceResponseMap<K,V>)
      • com.linkedin.venice.schema.vson.VsonAvroDatumReader.DeepEqualsHashMap
    • com.linkedin.davinci.utils.IndexedHashMap<K,V> (implements com.linkedin.davinci.utils.IndexedMap<K,V>)
  • com.google.protobuf.AbstractMessageLite<MessageType,BuilderType> (implements com.google.protobuf.MessageLite)
    • com.google.protobuf.AbstractMessage (implements com.google.protobuf.Message)
      • com.google.protobuf.GeneratedMessageV3 (implements java.io.Serializable)
        • com.linkedin.venice.protocols.VeniceClientRequest (implements com.linkedin.venice.protocols.VeniceClientRequestOrBuilder)
        • com.linkedin.venice.protocols.VeniceServerResponse (implements com.linkedin.venice.protocols.VeniceServerResponseOrBuilder)
  • com.google.protobuf.AbstractMessageLite.Builder<MessageType,BuilderType> (implements com.google.protobuf.MessageLite.Builder)
    • com.google.protobuf.AbstractMessage.Builder<BuilderType> (implements com.google.protobuf.Message.Builder)
      • com.google.protobuf.GeneratedMessageV3.Builder<BuilderType>
        • com.linkedin.venice.protocols.VeniceClientRequest.Builder (implements com.linkedin.venice.protocols.VeniceClientRequestOrBuilder)
        • com.linkedin.venice.protocols.VeniceServerResponse.Builder (implements com.linkedin.venice.protocols.VeniceServerResponseOrBuilder)
  • 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.unit.kafka.consumer.poll.AbstractPollStrategy (implements com.linkedin.venice.unit.kafka.consumer.poll.PollStrategy)
    • com.linkedin.venice.unit.kafka.consumer.poll.ArbitraryOrderingPollStrategy
    • com.linkedin.venice.unit.kafka.consumer.poll.BlockingObserverPollStrategy
    • com.linkedin.venice.unit.kafka.consumer.poll.CompositePollStrategy
    • com.linkedin.venice.unit.kafka.consumer.poll.DuplicatingPollStrategy
    • com.linkedin.venice.unit.kafka.consumer.poll.FilteringPollStrategy
    • com.linkedin.venice.unit.kafka.consumer.poll.RandomPollStrategy
  • com.linkedin.venice.pushmonitor.AbstractPushMonitor (implements com.linkedin.venice.pushmonitor.PartitionStatusListener, com.linkedin.venice.pushmonitor.PushMonitor, com.linkedin.venice.meta.RoutingDataRepository.RoutingDataChangedListener)
    • com.linkedin.venice.pushmonitor.PartitionStatusBasedPushMonitor
  • com.linkedin.alpini.base.queuing.AbstractQOS
    • com.linkedin.alpini.base.queuing.AbstractQOSBasedQueue<T> (implements com.linkedin.alpini.base.queuing.SimpleQueue<T>)
      • com.linkedin.alpini.base.queuing.QOSBasedMultiQueue<T>
      • com.linkedin.alpini.base.queuing.QOSBasedQueue<T>
  • com.linkedin.alpini.base.statistics.AbstractQuantileEstimation<SAMPLE>
    • com.linkedin.alpini.base.statistics.DoubleQuantileEstimation (implements java.util.function.DoubleConsumer)
    • com.linkedin.alpini.base.statistics.GenericQuantileEstimation<T> (implements java.util.function.Consumer<T>)
    • com.linkedin.alpini.base.statistics.LongQuantileEstimation (implements java.util.function.LongConsumer)
      • com.linkedin.alpini.base.statistics.LongQuantileArrayEstimation
      • com.linkedin.alpini.base.statistics.LongStatsAggregator
        • com.linkedin.alpini.base.statistics.LongStatsAggregatorLowQuantile
        • com.linkedin.alpini.base.statistics.LongStatsArrayAggregator
  • com.linkedin.alpini.base.statistics.AbstractQuantileEstimation.AbstractSample<SAMPLE> (implements java.lang.Cloneable)
    • com.linkedin.alpini.base.statistics.DoubleQuantileEstimation.Sample
    • com.linkedin.alpini.base.statistics.GenericQuantileEstimation.Sample<T>
    • com.linkedin.alpini.base.statistics.LongQuantileEstimation.Sample
  • com.linkedin.alpini.base.statistics.AbstractQuantileEstimation.Data
    • com.linkedin.alpini.base.statistics.LongStatsAggregator.LongData
  • com.linkedin.alpini.base.statistics.AbstractQuantileEstimation.Quantile (implements org.apache.logging.log4j.util.StringBuilderFormattable)
  • com.linkedin.alpini.base.statistics.AbstractQuantileEstimation.Quantiles
  • com.linkedin.venice.listener.response.AbstractReadResponse (implements com.linkedin.davinci.listener.response.ReadResponse)
    • com.linkedin.venice.listener.response.MultiKeyResponseWrapper<K>
      • com.linkedin.venice.listener.response.ComputeResponseWrapper
      • com.linkedin.venice.listener.response.MultiGetResponseWrapper
    • com.linkedin.venice.listener.response.ParallelMultiKeyResponseWrapper<T>
    • com.linkedin.venice.listener.response.SingleGetResponseWrapper
  • com.linkedin.venice.listener.response.stats.AbstractReadResponseStats (implements com.linkedin.davinci.listener.response.ReadResponseStats, com.linkedin.venice.listener.response.stats.ReadResponseStatsRecorder)
    • com.linkedin.venice.listener.response.stats.MultiKeyResponseStats
      • com.linkedin.venice.listener.response.stats.ComputeResponseStats
        • com.linkedin.venice.listener.response.stats.ComputeResponseStatsWithSizeProfiling
      • com.linkedin.venice.listener.response.stats.MultiGetResponseStatsWithSizeProfiling
    • com.linkedin.venice.listener.response.stats.SingleGetResponseStats
  • com.linkedin.venice.client.store.streaming.AbstractRecordStreamDecoder<ENVELOPE,K,V> (implements com.linkedin.venice.client.store.streaming.RecordStreamDecoder)
    • com.linkedin.venice.client.store.streaming.ComputeRecordStreamDecoder<K,V>
    • com.linkedin.venice.client.store.streaming.MultiGetRecordStreamDecoder<K,V>
  • com.linkedin.venice.controller.server.AbstractRoute
    • com.linkedin.venice.controller.server.AdminCommandExecutionRoutes
    • com.linkedin.venice.controller.server.AdminTopicMetadataRoutes
    • com.linkedin.venice.controller.server.ClusterRoutes
    • com.linkedin.venice.controller.server.ControllerRoutes
    • com.linkedin.venice.controller.server.CreateStore
    • com.linkedin.venice.controller.server.CreateVersion
    • com.linkedin.venice.controller.server.DataRecoveryRoutes
    • com.linkedin.venice.controller.server.JobRoutes
    • com.linkedin.venice.controller.server.MigrationRoutes
    • com.linkedin.venice.controller.server.NewClusterBuildOutRoutes
    • com.linkedin.venice.controller.server.NodesAndReplicas
    • com.linkedin.venice.controller.server.RoutersClusterConfigRoutes
    • com.linkedin.venice.controller.server.SchemaRoutes
    • com.linkedin.venice.controller.server.SkipAdminRoute
    • com.linkedin.venice.controller.server.StoragePersonaRoutes
    • com.linkedin.venice.controller.server.StoresRoutes
    • com.linkedin.venice.controller.server.VersionRoute
  • com.linkedin.venice.helix.AbstractSchemaEntrySerializer<T> (implements com.linkedin.venice.meta.VeniceSerializer<T>)
    • com.linkedin.venice.helix.DerivedSchemaEntrySerializer
    • com.linkedin.venice.helix.ReplicationMetadataSchemaEntrySerializer
  • com.linkedin.alpini.base.registry.AbstractShutdownableResource<R> (implements com.linkedin.alpini.base.registry.ShutdownableResource)
    • com.linkedin.alpini.base.registry.SyncShutdownableAdapter (implements com.linkedin.alpini.base.registry.ResourceRegistry.Sync)
  • com.linkedin.davinci.store.AbstractStorageEngine<Partition> (implements java.io.Closeable)
    • com.linkedin.davinci.store.blackhole.BlackHoleStorageEngine
    • com.linkedin.davinci.store.memory.InMemoryStorageEngine
    • com.linkedin.davinci.store.rocksdb.RocksDBStorageEngine
    • com.linkedin.davinci.store.cache.VeniceStoreCacheStorageEngine
  • com.linkedin.davinci.store.AbstractStorageIterator
    • com.linkedin.davinci.store.rocksdb.RocksDBStorageIterator
  • com.linkedin.davinci.store.AbstractStoragePartition
    • com.linkedin.davinci.store.blackhole.BlackHoleStorageEnginePartition
    • com.linkedin.davinci.store.memory.InMemoryStoragePartition
    • com.linkedin.davinci.store.rocksdb.RocksDBStoragePartition
      • com.linkedin.davinci.store.rocksdb.ReplicationMetadataRocksDBStoragePartition
    • com.linkedin.davinci.store.cache.VeniceStoreCacheStoragePartition
  • com.linkedin.venice.meta.AbstractStore (implements com.linkedin.venice.meta.Store)
    • com.linkedin.venice.meta.SystemStore
    • com.linkedin.venice.meta.ZKStore (implements com.linkedin.venice.meta.DataModelBackedStructure<T>)
  • com.linkedin.venice.fastclient.meta.AbstractStoreMetadata (implements com.linkedin.venice.fastclient.meta.StoreMetadata)
    • com.linkedin.venice.fastclient.meta.RequestBasedMetadata
  • io.grpc.stub.AbstractStub<S>
    • io.grpc.stub.AbstractAsyncStub<S>
      • com.linkedin.venice.protocols.VeniceReadServiceGrpc.VeniceReadServiceStub
    • io.grpc.stub.AbstractBlockingStub<S>
      • com.linkedin.venice.protocols.VeniceReadServiceGrpc.VeniceReadServiceBlockingStub
    • io.grpc.stub.AbstractFutureStub<S>
      • com.linkedin.venice.protocols.VeniceReadServiceGrpc.VeniceReadServiceFutureStub
  • com.linkedin.venice.stats.AbstractVeniceAggStats<T>
    • com.linkedin.venice.stats.AbstractVeniceAggStoreStats<T> (implements com.linkedin.venice.meta.StoreDataChangedListener)
      • com.linkedin.davinci.stats.AggHostLevelIngestionStats
      • com.linkedin.davinci.stats.AggKafkaConsumerServiceStats
      • com.linkedin.venice.pushmonitor.AggPushHealthStats
      • com.linkedin.venice.pushmonitor.AggPushStatusCleanUpStats
      • com.linkedin.venice.router.stats.AggRouterHttpRequestStats
      • com.linkedin.venice.stats.AggServerHttpRequestStats
    • com.linkedin.venice.router.stats.AggHostHealthStats
    • com.linkedin.venice.controller.stats.AggPartitionHealthStats (implements com.linkedin.venice.meta.RoutingDataRepository.RoutingDataChangedListener)
    • com.linkedin.venice.stats.AggRocksDBStats
    • com.linkedin.venice.stats.AggServerQuotaUsageStats
  • com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats<STATS,STATS_REPORTER> (implements com.linkedin.venice.meta.StoreDataChangedListener)
    • com.linkedin.davinci.stats.AggVersionedDIVStats
    • com.linkedin.davinci.stats.AggVersionedIngestionStats
    • com.linkedin.davinci.stats.AggVersionedStorageEngineStats
    • com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatVersionedStats
  • com.linkedin.venice.hadoop.AbstractVeniceFilter<INPUT_VALUE> (implements java.io.Closeable)
    • com.linkedin.venice.hadoop.input.kafka.ttl.VeniceRmdTTLFilter<INPUT_VALUE>
      • com.linkedin.venice.hadoop.input.kafka.ttl.VeniceChunkedPayloadTTLFilter
      • com.linkedin.venice.hadoop.input.kafka.ttl.VeniceKafkaInputTTLFilter
  • com.linkedin.venice.producer.AbstractVeniceProducer<K,V> (implements com.linkedin.venice.producer.VeniceProducer<K,V>)
    • com.linkedin.venice.producer.online.OnlineVeniceProducer<K,V>
  • com.linkedin.venice.hadoop.input.recordreader.AbstractVeniceRecordReader<INPUT_KEY,INPUT_VALUE>
    • com.linkedin.venice.hadoop.input.recordreader.avro.AbstractAvroRecordReader<INPUT_KEY,INPUT_VALUE>
      • com.linkedin.venice.hadoop.input.recordreader.avro.VeniceAvroRecordReader
    • com.linkedin.venice.hadoop.input.recordreader.avro.IdentityVeniceRecordReader
    • com.linkedin.venice.hadoop.input.recordreader.vson.VeniceVsonRecordReader
  • com.linkedin.venice.service.AbstractVeniceService (implements java.io.Closeable)
    • com.linkedin.davinci.kafka.consumer.AbstractKafkaConsumerService
      • com.linkedin.davinci.kafka.consumer.KafkaConsumerService
        • com.linkedin.davinci.kafka.consumer.PartitionWiseKafkaConsumerService
          • com.linkedin.davinci.kafka.consumer.StoreAwarePartitionWiseKafkaConsumerService
        • com.linkedin.davinci.kafka.consumer.TopicWiseKafkaConsumerService
      • com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator
    • com.linkedin.davinci.kafka.consumer.AbstractStoreBufferService
      • com.linkedin.davinci.kafka.consumer.SeparatedStoreBufferService
      • com.linkedin.davinci.kafka.consumer.StoreBufferService
    • com.linkedin.venice.controller.kafka.consumer.AdminConsumerService
    • com.linkedin.venice.controller.server.AdminSparkServer
    • com.linkedin.davinci.kafka.consumer.AggKafkaConsumerService
    • com.linkedin.venice.cleaner.BackupVersionOptimizationService (implements com.linkedin.venice.cleaner.ResourceReadUsageTracker)
    • com.linkedin.venice.router.api.DictionaryRetrievalService
    • com.linkedin.venice.controller.DisabledPartitionEnablerService
    • com.linkedin.davinci.storage.DiskHealthCheckService
    • com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService
    • com.linkedin.davinci.helix.HelixParticipationService (implements com.linkedin.venice.status.StatusMessageHandler<T>)
    • com.linkedin.davinci.ingestion.isolated.IsolatedIngestionServer
    • com.linkedin.davinci.kafka.consumer.KafkaStoreIngestionService (implements com.linkedin.davinci.kafka.consumer.StoreIngestionService)
    • com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService
    • com.linkedin.venice.cleaner.LeakedResourceCleaner
    • com.linkedin.venice.listener.ListenerService
    • com.linkedin.davinci.ingestion.main.MainIngestionMonitorService
    • com.linkedin.davinci.ingestion.main.MainIngestionStorageMetadataService (implements com.linkedin.davinci.storage.StorageMetadataService)
    • com.linkedin.davinci.blobtransfer.server.P2PBlobTransferService
    • com.linkedin.davinci.kafka.consumer.RemoteIngestionRepairService
    • com.linkedin.venice.router.api.RouterHeartbeat
    • com.linkedin.venice.router.RouterServer
    • com.linkedin.davinci.storage.StorageEngineMetadataService (implements com.linkedin.davinci.storage.StorageMetadataService)
    • com.linkedin.davinci.storage.StorageService
    • com.linkedin.venice.controller.StoreBackupVersionCleanupService
    • com.linkedin.venice.controller.StoreGraveyardCleanupService
    • com.linkedin.venice.listener.StoreValueSchemasCacheService (implements com.linkedin.venice.meta.ReadOnlySchemaRepository)
    • com.linkedin.venice.controller.systemstore.SystemStoreRepairService
    • com.linkedin.venice.controller.kafka.TopicCleanupService
      • com.linkedin.venice.controller.kafka.TopicCleanupServiceForParentController
    • com.linkedin.venice.controller.UnusedValueSchemaCleanupService
    • com.linkedin.venice.controller.VeniceControllerService
  • com.linkedin.venice.stats.AbstractVeniceStats
    • com.linkedin.venice.stats.AbstractVeniceHttpStats
      • com.linkedin.venice.client.stats.BasicClientStats
        • com.linkedin.venice.client.stats.ClientStats
          • com.linkedin.venice.fastclient.stats.FastClientStats
      • com.linkedin.venice.fastclient.stats.ClusterRouteStats.RouteStats
      • com.linkedin.venice.router.stats.RouterHttpRequestStats
      • com.linkedin.venice.stats.ServerHttpRequestStats
    • com.linkedin.davinci.stats.AbstractVeniceStatsReporter<STATS>
      • com.linkedin.davinci.stats.DIVStatsReporter
      • com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatStatReporter
      • com.linkedin.davinci.stats.IngestionStatsReporter
    • com.linkedin.venice.controller.stats.AdminConsumptionStats
    • com.linkedin.venice.router.stats.AdminOperationsStats
    • com.linkedin.venice.stats.BackupVersionOptimizationServiceStats
    • com.linkedin.davinci.consumer.stats.BasicConsumerStats
    • com.linkedin.venice.fastclient.stats.ClusterStats
    • com.linkedin.venice.controller.stats.DisabledPartitionStats
    • com.linkedin.venice.stats.DiskHealthStats
    • com.linkedin.venice.stats.DnsLookupStats
    • com.linkedin.venice.controller.stats.ErrorPartitionStats
    • com.linkedin.venice.router.stats.HealthCheckStats
    • com.linkedin.venice.controller.lingeringjob.HeartbeatBasedCheckerStats
    • com.linkedin.venice.router.stats.HelixGroupStats
    • com.linkedin.venice.stats.HelixMessageChannelStats
    • com.linkedin.venice.router.stats.HostHealthStats
    • com.linkedin.davinci.stats.HostLevelIngestionStats
    • com.linkedin.venice.stats.HttpConnectionPoolStats
    • com.linkedin.davinci.stats.IsolatedIngestionProcessHeartbeatStats
    • com.linkedin.davinci.stats.IsolatedIngestionProcessStats
    • com.linkedin.davinci.stats.KafkaConsumerServiceStats
    • com.linkedin.venice.stats.LeakedResourceCleanerStats
    • com.linkedin.davinci.stats.MetadataUpdateStats
    • com.linkedin.davinci.stats.NativeMetadataRepositoryStats
    • com.linkedin.davinci.stats.ParticipantStoreConsumptionStats
    • com.linkedin.venice.controller.stats.PartitionHealthStats
    • com.linkedin.venice.pushmonitor.PushHealthStats
    • com.linkedin.venice.controller.stats.PushJobStatusStats
    • com.linkedin.venice.pushmonitor.PushStatusCleanUpStats
    • com.linkedin.venice.stats.RetryManagerStats
    • com.linkedin.davinci.stats.RocksDBMemoryStats
    • com.linkedin.venice.stats.RocksDBStats
    • com.linkedin.venice.router.stats.RouterCurrentVersionStats
    • com.linkedin.venice.router.stats.RouterThrottleStats
    • com.linkedin.venice.router.stats.SecurityStats
    • com.linkedin.venice.stats.ServerConnectionStats
    • com.linkedin.davinci.stats.ServerMetadataServiceStats
    • com.linkedin.venice.stats.ServerReadQuotaUsageStats
    • com.linkedin.venice.controller.stats.SparkServerStats
    • com.linkedin.venice.router.stats.StaleVersionStats
    • com.linkedin.davinci.StoreBackendStats
    • com.linkedin.venice.controller.stats.StoreBackupVersionCleanupServiceStats
    • com.linkedin.davinci.stats.StoreBufferServiceStats
    • com.linkedin.davinci.store.cache.backend.StoreCacheStats
    • com.linkedin.venice.controller.stats.StoreStats
    • com.linkedin.davinci.stats.StuckConsumerRepairStats
    • com.linkedin.venice.controller.stats.SystemStoreHealthCheckStats
    • com.linkedin.venice.stats.ThreadPoolStats
      • com.linkedin.davinci.stats.ParticipantStateTransitionStats
    • com.linkedin.venice.controller.stats.TopicCleanupServiceStats
    • com.linkedin.venice.controller.stats.VeniceAdminStats
    • com.linkedin.venice.stats.VeniceJVMStats
    • com.linkedin.venice.stats.VeniceLockStats
    • com.linkedin.venice.producer.VeniceProducerMetrics
    • com.linkedin.davinci.stats.VeniceVersionedStatsReporter<STATS,STATS_REPORTER>
    • com.linkedin.venice.stats.VeniceWriterStats
    • com.linkedin.venice.stats.ZkClientStatusStats (implements org.apache.helix.zookeeper.zkclient.IZkStateListener)
  • com.linkedin.venice.writer.AbstractVeniceWriter<K,V,U> (implements java.io.Closeable)
    • com.linkedin.venice.writer.VeniceWriter<K,V,U>
  • com.linkedin.venice.schema.vson.AbstractVsonSchemaAdapter<T>
    • com.linkedin.venice.schema.vson.VsonAvroSchemaAdapter
    • com.linkedin.venice.schema.vson.VsonSchemaAdapter
  • com.linkedin.venice.authorization.AceEntry
  • com.linkedin.venice.authorization.AclBinding
  • com.linkedin.venice.acl.AclCreationDeletionListener (implements com.linkedin.venice.meta.StoreDataChangedListener)
  • com.linkedin.venice.controller.Admin.OfflinePushStatusInfo
  • com.linkedin.venice.controllerapi.AdminCommandExecution
  • com.linkedin.venice.controller.AdminCommandExecutionTracker
  • com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask (implements java.io.Closeable, java.lang.Runnable)
  • com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask (implements java.util.concurrent.Callable<V>)
  • com.linkedin.venice.controller.kafka.protocol.serializer.AdminOperationSerializer
  • com.linkedin.venice.controller.kafka.consumer.AdminOperationWrapper
  • com.linkedin.venice.listener.request.AdminRequest
  • com.linkedin.davinci.listener.response.AdminResponse
  • com.linkedin.venice.AdminTool
  • com.linkedin.venice.controller.AdminTopicMetadataAccessor
    • com.linkedin.venice.admin.InMemoryAdminTopicMetadataAccessor
    • com.linkedin.venice.controller.ZkAdminTopicMetadataAccessor
  • com.linkedin.venice.controller.kafka.AdminTopicUtils
  • com.linkedin.venice.controllerapi.AggregatedHealthStatusRequest
  • com.linkedin.venice.controller.stats.AggStoreStats
  • com.linkedin.venice.client.store.predicate.AndPredicate (implements com.linkedin.venice.client.store.predicate.Predicate)
  • com.linkedin.venice.router.httpclient.ApacheHttpAsyncStorageNodeClient (implements com.linkedin.venice.router.httpclient.StorageNodeClient)
  • com.linkedin.venice.pubsub.adapter.kafka.admin.ApacheKafkaAdminAdapter (implements com.linkedin.venice.pubsub.api.PubSubAdminAdapter)
  • com.linkedin.venice.pubsub.adapter.kafka.admin.ApacheKafkaAdminAdapterFactory (implements com.linkedin.venice.pubsub.PubSubAdminAdapterFactory<ADAPTER>)
  • com.linkedin.venice.pubsub.adapter.kafka.admin.ApacheKafkaAdminConfig
  • com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerAdapter (implements com.linkedin.venice.pubsub.api.PubSubConsumerAdapter)
  • com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerAdapterFactory (implements com.linkedin.venice.pubsub.PubSubConsumerAdapterFactory<ADAPTER>)
  • com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerConfig
  • com.linkedin.venice.pubsub.adapter.kafka.ApacheKafkaOffsetPosition (implements com.linkedin.venice.pubsub.api.PubSubPosition)
  • com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerAdapter (implements com.linkedin.venice.pubsub.api.PubSubProducerAdapter)
  • com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerAdapterFactory (implements com.linkedin.venice.pubsub.PubSubProducerAdapterFactory<ADAPTER>)
  • com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerCallback (implements org.apache.kafka.clients.producer.Callback)
  • com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerConfig
  • com.linkedin.venice.pubsub.adapter.kafka.ApacheKafkaUtils
  • com.linkedin.venice.utils.collections.ArrayBackedNullSkippingIterator<E>
  • com.linkedin.venice.utils.collections.ArrayCollection<E> (implements java.util.Collection<E>)
  • com.linkedin.venice.utils.ArrayUtils
  • io.tehuti.metrics.stats.AsyncGauge (implements io.tehuti.metrics.NamedMeasurableStat)
    • com.linkedin.davinci.stats.DIVStatsReporter.DIVStatsGauge
    • com.linkedin.davinci.stats.IngestionStatsReporter.IngestionStatsGauge
    • com.linkedin.venice.stats.LambdaStat
      • com.linkedin.venice.stats.TehutiUtils.RatioStat
      • com.linkedin.venice.stats.TehutiUtils.SimpleRatioStat
  • com.linkedin.alpini.base.pool.impl.AsyncPoolImpl<T> (implements com.linkedin.alpini.base.pool.AsyncPool<T>, com.linkedin.alpini.base.registry.ShutdownableResource)
    • com.linkedin.alpini.base.pool.impl.AsyncQOSPoolImpl<T> (implements com.linkedin.alpini.base.pool.AsyncQOSPool<T>)
  • com.linkedin.venice.servicediscovery.AsyncRetryingServiceDiscoveryAnnouncer (implements com.linkedin.venice.servicediscovery.ServiceDiscoveryAnnouncer)
  • com.linkedin.venice.controller.AuditInfo
  • com.linkedin.venice.utils.locks.AutoCloseableLock (implements java.lang.AutoCloseable)
    • com.linkedin.venice.utils.locks.AutoCloseableMultiLock
    • com.linkedin.venice.utils.locks.AutoCloseableSingleLock
  • com.linkedin.davinci.schema.merge.AvroCollectionElementComparator
  • com.linkedin.venice.utils.AvroCompatibilityUtils
  • com.linkedin.davinci.client.AvroGenericDaVinciClient<K,V> (implements com.linkedin.venice.client.store.AvroGenericReadComputeStoreClient<K,V>, com.linkedin.davinci.client.DaVinciClient<K,V>)
    • com.linkedin.davinci.client.AvroSpecificDaVinciClient<K,V>
  • com.linkedin.venice.serializer.AvroGenericDeserializer<V> (implements com.linkedin.venice.serializer.RecordDeserializer<T>)
    • com.linkedin.venice.serializer.AvroSpecificDeserializer<T>
      • com.linkedin.venice.serializer.FastAvroSpecificDeserializer<T>
    • com.linkedin.venice.serializer.FastAvroGenericDeserializer<V>
    • com.linkedin.davinci.serializer.avro.MapOrderPreservingDeserializer
    • com.linkedin.davinci.serializer.avro.fast.MapOrderPreservingFastDeserializer
    • com.linkedin.venice.serializer.VsonAvroGenericDeserializer<K>
  • com.linkedin.venice.utils.AvroRecordUtils
  • com.linkedin.venice.schema.AvroSchemaParseUtils
  • com.linkedin.venice.utils.AvroSchemaUtils
  • com.linkedin.venice.serializer.AvroSerializer<K> (implements com.linkedin.venice.serializer.RecordSerializer<T>)
    • com.linkedin.venice.serializer.FastAvroSerializer<K>
    • com.linkedin.davinci.serializer.avro.fast.MapOrderPreservingFastSerializer<K>
    • com.linkedin.davinci.serializer.avro.MapOrderPreservingSerializer<K>
    • com.linkedin.venice.serializer.VsonAvroGenericSerializer<K>
  • com.linkedin.venice.serialization.avro.AvroSpecificStoreDeserializerCache<V> (implements com.linkedin.venice.serialization.StoreDeserializerCache<T>)
  • com.linkedin.venice.serialization.AvroStoreDeserializerCache<T> (implements com.linkedin.venice.serialization.StoreDeserializerCache<T>)
  • com.linkedin.venice.utils.AvroSupersetSchemaUtils
  • com.linkedin.alpini.netty4.pool.BasicDnsResolver (implements com.linkedin.alpini.netty4.pool.ChannelPoolResolver)
  • com.linkedin.alpini.netty4.misc.BasicHeaders (implements com.linkedin.alpini.base.misc.Headers)
  • com.linkedin.venice.client.store.deserialization.BatchDeserializer<E,K,V>
    • com.linkedin.venice.client.store.deserialization.BlackHoleDeserializer<E,K,V>
    • com.linkedin.venice.client.store.deserialization.BlockingDeserializer<E,K,V>
  • com.linkedin.davinci.storage.chunking.BatchGetChunkingAdapter (implements com.linkedin.davinci.storage.chunking.ChunkingAdapter<CHUNKS_CONTAINER,VALUE>)
  • com.linkedin.venice.status.BatchJobHeartbeatConfigs
  • com.linkedin.venice.utils.collections.BiIntKeyCache<E>
  • com.linkedin.venice.listener.response.BinaryResponse
  • com.linkedin.venice.blobtransfer.BlobPeersDiscoveryResponse
  • com.linkedin.davinci.blobtransfer.BlobSnapshotManager
  • com.linkedin.davinci.blobtransfer.BlobTransferPartitionMetadata
  • com.linkedin.davinci.blobtransfer.BlobTransferPayload
  • com.linkedin.davinci.blobtransfer.BlobTransferUtil
  • com.linkedin.davinci.blobtransfer.BlobTransferUtils
  • com.linkedin.alpini.base.concurrency.BlockingLatch
  • com.linkedin.venice.utils.ByteArray (implements java.io.Serializable)
  • com.linkedin.davinci.utils.ByteArrayKey (implements java.lang.Comparable<T>)
  • io.netty.buffer.ByteBuf (implements java.lang.Comparable<T>, io.netty.util.ReferenceCounted)
    • io.netty.buffer.AbstractByteBuf
      • com.linkedin.alpini.base.safealloc.DerivedMutableByteBuf
      • com.linkedin.alpini.base.safealloc.DerivedReadOnlyByteBuf
  • com.linkedin.alpini.base.misc.ByteBufAsciiString (implements java.lang.CharSequence, java.lang.Comparable<T>, io.netty.util.ReferenceCounted)
  • com.linkedin.davinci.store.record.ByteBufferValueRecord<T>
  • com.linkedin.davinci.callback.BytesStreamingCallback
  • com.linkedin.venice.utils.ByteUtils
  • com.linkedin.venice.httpclient.CachedDnsResolver (implements java.io.Closeable, org.apache.http.conn.DnsResolver)
  • com.linkedin.venice.helix.CachedReadOnlyStoreRepository (implements com.linkedin.venice.meta.ReadOnlyStoreRepository)
    • com.linkedin.venice.helix.HelixReadOnlyStoreRepository
      • com.linkedin.venice.helix.HelixReadOnlyZKSharedSystemStoreRepository
        • com.linkedin.venice.controller.helix.SharedHelixReadOnlyZKSharedSystemStoreRepository (implements java.io.Closeable)
      • com.linkedin.venice.helix.SubscriptionBasedStoreRepository (implements com.linkedin.venice.meta.SubscriptionBasedReadOnlyStoreRepository)
    • com.linkedin.venice.helix.HelixReadWriteStoreRepository (implements com.linkedin.venice.meta.ReadWriteStoreRepository)
  • com.linkedin.venice.helix.CachedResourceZkStateListener (implements org.apache.helix.zookeeper.zkclient.IZkStateListener)
  • com.linkedin.davinci.client.factory.CachingDaVinciClientFactory (implements java.io.Closeable, com.linkedin.davinci.client.factory.DaVinciClientFactory)
  • com.linkedin.venice.client.factory.CachingVeniceStoreClientFactory (implements com.linkedin.venice.client.factory.VeniceStoreClientFactory)
  • com.linkedin.davinci.store.cache.caffeine.CaffeineVeniceStoreCache (implements com.linkedin.davinci.store.cache.VeniceStoreCache)
  • com.linkedin.alpini.base.monitoring.CallTrackerImpl (implements com.linkedin.alpini.base.monitoring.CallTracker)
  • com.linkedin.venice.utils.concurrent.ChainedCompletableFuture<I,O>
  • com.linkedin.davinci.consumer.ChangeEvent<T>
  • com.linkedin.davinci.consumer.ChangelogClientConfig<T>
  • io.netty.channel.ChannelHandlerAdapter (implements io.netty.channel.ChannelHandler)
    • io.netty.channel.ChannelInboundHandlerAdapter (implements io.netty.channel.ChannelInboundHandler)
      • io.netty.handler.codec.http2.ActiveStreamsCountHandler
      • io.netty.handler.ssl.ApplicationProtocolNegotiationHandler
        • com.linkedin.alpini.netty4.http2.Http2PipelineInitializer
      • io.netty.handler.codec.ByteToMessageDecoder
        • io.netty.handler.codec.http2.Http2ConnectionHandler (implements io.netty.channel.ChannelOutboundHandler, io.netty.handler.codec.http2.Http2LifecycleManager)
          • io.netty.handler.codec.http2.Http2FrameCodec
            • io.netty.handler.codec.http2.EspressoHttp2FrameCodec
        • io.netty.handler.codec.http.HttpObjectDecoder
          • com.linkedin.alpini.netty4.misc.BasicHttpObjectDecoder
            • com.linkedin.alpini.netty4.handlers.HttpContentMultiPartDecode
          • com.linkedin.alpini.netty4.misc.BasicHttpRequestDecoder
            • com.linkedin.alpini.netty4.handlers.BasicHttpServerCodec.Decoder
          • com.linkedin.alpini.netty4.handlers.BasicHttpResponseDecoder
        • com.linkedin.alpini.netty4.compression.SnappyDecoder
        • io.netty.handler.ssl.SslHandler (implements io.netty.channel.ChannelOutboundHandler)
          • com.linkedin.alpini.netty4.ssl.FusedSslHandler
      • io.netty.channel.ChannelDuplexHandler (implements io.netty.channel.ChannelOutboundHandler)
        • io.netty.channel.CombinedChannelDuplexHandler<I,O>
          • com.linkedin.alpini.netty4.handlers.BasicHttpClientCodec (implements io.netty.handler.codec.http.HttpClientUpgradeHandler.SourceCodec)
          • com.linkedin.alpini.netty4.handlers.BasicHttpServerCodec (implements io.netty.handler.codec.http.HttpServerUpgradeHandler.SourceCodec)
        • com.linkedin.alpini.netty4.http2.CompactHeaderHandler
        • com.linkedin.alpini.netty4.handlers.ElideDuplicateHeadersHandler
        • io.netty.handler.codec.http2.Http2ChannelDuplexHandler
          • io.netty.handler.codec.http2.EspressoHttp2MultiplexHandler
        • com.linkedin.alpini.netty4.handlers.Http2PingSendHandler
        • com.linkedin.alpini.netty4.handlers.HttpServerConcurrencyObserver
        • io.netty.handler.logging.LoggingHandler
          • com.linkedin.alpini.netty4.handlers.Log4J2LoggingHandler
        • io.netty.handler.codec.MessageToMessageCodec<INBOUND_IN,OUTBOUND_IN>
          • com.linkedin.alpini.netty4.http2.AbstractHttp2StreamFrameCodec
            • com.linkedin.alpini.netty4.http2.Http2StreamFrameClientCodec
            • com.linkedin.alpini.netty4.http2.Http2StreamFrameServerCodec
          • com.linkedin.alpini.netty4.handlers.BasicHttpContentEncoder
        • com.linkedin.venice.router.streaming.NettyChunkedWriteHandler
          • com.linkedin.venice.router.streaming.VeniceChunkedWriteHandler
        • com.linkedin.alpini.netty4.handlers.ReverseHandler
          • com.linkedin.alpini.netty4.compression.SnappyEncoder
        • com.linkedin.alpini.netty4.handlers.StaleConnectionHandler
        • com.linkedin.venice.listener.StatsHandler
      • com.linkedin.alpini.netty4.handlers.ChannelInitializer<C>
        • com.linkedin.alpini.netty4.handlers.AsyncFullHttpRequestHandler
        • com.linkedin.alpini.netty4.handlers.BackgroundChannelHandler
        • com.linkedin.alpini.netty4.handlers.BasicServerChannelInitializer<C,FACTORY>
          • com.linkedin.alpini.router.impl.netty4.Router4PipelineFactory<C> (implements com.linkedin.alpini.router.impl.RouterPipelineFactory<CHANNEL_HANDLER>)
        • com.linkedin.alpini.netty4.handlers.ChunkedResponseHandler
        • com.linkedin.alpini.netty4.handlers.SimpleChannelInitializer<C>
          • com.linkedin.alpini.netty4.handlers.HttpMultiPartContentCodec
          • com.linkedin.alpini.netty4.handlers.HttpMultiPartContentDecoder
          • com.linkedin.alpini.netty4.handlers.HttpServerStatisticsHandler
        • com.linkedin.alpini.netty4.ssl.SslClientInitializer
        • com.linkedin.alpini.netty4.ssl.SslInitializer
        • com.linkedin.alpini.netty4.handlers.VIPRequestHandler
      • io.netty.channel.ChannelInitializer<C>
        • com.linkedin.davinci.blobtransfer.server.BlobTransferNettyChannelInitializer
        • com.linkedin.venice.listener.HttpChannelInitializer
        • com.linkedin.davinci.ingestion.isolated.IsolatedIngestionServerChannelInitializer
        • com.linkedin.davinci.ingestion.main.MainIngestionReportChannelInitializer
      • com.linkedin.alpini.netty4.handlers.ConnectionLimitHandler
        • com.linkedin.alpini.netty4.handlers.ConnectionControlHandler
      • com.linkedin.venice.listener.ErrorCatchingHandler
      • io.netty.handler.codec.EspressoMessageToMessageDecoder<I>
        • io.netty.handler.codec.EspressoMessageAggregator<I,S,C,O>
          • io.netty.handler.codec.http.EspressoHttpObjectAggregator
      • com.linkedin.alpini.netty4.handlers.Http2ExceptionHandler
      • com.linkedin.alpini.netty4.handlers.HttpObjectToBasicHttpObjectAdapter
      • com.linkedin.alpini.netty4.handlers.HttpVersionFilter
      • com.linkedin.alpini.netty4.handlers.InboundContentDebugHandler
      • com.linkedin.alpini.netty4.handlers.InboundContentDebugHandler.HttpDecodeResult
      • com.linkedin.alpini.netty4.handlers.LogSslCipherSuiteHandler
      • io.netty.handler.codec.MessageToMessageDecoder<I>
        • io.netty.handler.codec.http.HttpContentDecoder
          • io.netty.handler.codec.http.HttpContentDecompressor
            • com.linkedin.alpini.netty4.compression.ContentDecompressor
        • com.linkedin.alpini.netty4.handlers.HttpContentMultiPartAggregator
        • com.linkedin.alpini.netty4.handlers.HttpContentUnwrap
        • io.netty.handler.codec.MessageAggregator<I,S,C,O>
          • com.linkedin.alpini.netty4.handlers.HttpMultiPartContentAggregator
          • io.netty.handler.codec.http.HttpObjectAggregator
            • com.linkedin.alpini.netty4.handlers.BasicHttpObjectAggregator
              • com.linkedin.alpini.netty4.handlers.BasicHttpNonMultiPartAggregator
            • com.linkedin.davinci.blobtransfer.client.MetadataAggregator
      • com.linkedin.alpini.netty4.ssl.SecureClientHandler
      • com.linkedin.venice.listener.ServerConnectionStatsHandler
      • io.netty.channel.SimpleChannelInboundHandler<I>
        • com.linkedin.venice.acl.handler.AbstractStoreAclHandler<REQUEST_TYPE>
          • com.linkedin.venice.router.acl.RouterStoreAclHandler
          • com.linkedin.venice.listener.ServerStoreAclHandler (implements io.grpc.ServerInterceptor)
        • com.linkedin.venice.router.AdminOperationsHandler
        • com.linkedin.venice.router.HealthCheckHandler
        • com.linkedin.alpini.netty4.handlers.Http2PingResponseHandler
        • com.linkedin.davinci.ingestion.isolated.IsolatedIngestionServerAclHandler
        • com.linkedin.davinci.ingestion.isolated.IsolatedIngestionServerHandler
        • com.linkedin.davinci.ingestion.main.MainIngestionReportHandler
        • com.linkedin.venice.router.MetaDataHandler
        • com.linkedin.davinci.blobtransfer.client.P2PFileTransferClientHandler
        • com.linkedin.davinci.blobtransfer.server.P2PFileTransferServerHandler
        • com.linkedin.davinci.blobtransfer.client.P2PMetadataTransferHandler
        • com.linkedin.venice.listener.ReadQuotaEnforcementHandler (implements com.linkedin.venice.meta.RoutingDataRepository.RoutingDataChangedListener, com.linkedin.venice.meta.StoreDataChangedListener)
        • com.linkedin.venice.listener.RouterRequestHttpHandler
        • com.linkedin.venice.router.RouterSslVerificationHandler
        • com.linkedin.venice.router.RouterThrottleHandler
        • com.linkedin.venice.listener.ServerAclHandler (implements io.grpc.ServerInterceptor)
        • com.linkedin.venice.listener.VerifySslHandler (implements io.grpc.ServerInterceptor)
      • com.linkedin.venice.listener.StorageReadRequestHandler
    • io.netty.channel.ChannelOutboundHandlerAdapter (implements io.netty.channel.ChannelOutboundHandler)
      • io.netty.handler.codec.EspressoMessageToMessageEncoder<I>
        • io.netty.handler.codec.http.EspressoHttpObjectEncoder<H>
      • com.linkedin.alpini.netty4.handlers.HeaderStamp
      • io.netty.handler.codec.MessageToMessageEncoder<I>
        • com.linkedin.alpini.netty4.handlers.HttpByteBufContentChunker
        • io.netty.handler.codec.http.HttpObjectEncoder<H>
          • com.linkedin.alpini.netty4.handlers.HttpMultiPartContentEncoder
          • io.netty.handler.codec.http.HttpResponseEncoder
            • com.linkedin.alpini.netty4.handlers.BasicHttpServerCodec.Encoder
      • com.linkedin.alpini.netty4.handlers.OutboundByteBufAggregator
      • com.linkedin.venice.listener.OutboundHttpWrapperHandler
      • com.linkedin.alpini.netty4.handlers.RateLimitConnectHandler
      • io.netty.handler.timeout.WriteTimeoutHandler
        • io.netty.handler.timeout.ForceCloseOnWriteTimeoutHandler
    • io.netty.handler.codec.http2.Http2FrameLogger
      • com.linkedin.alpini.netty4.handlers.Http2SettingsFrameLogger
      • com.linkedin.alpini.netty4.handlers.Log4J2FrameLogger
  • com.linkedin.alpini.netty4.pool.ChannelPoolManagerImpl (implements com.linkedin.alpini.netty4.pool.ChannelPoolManager)
  • com.linkedin.alpini.netty4.misc.ChannelTaskSerializer
  • com.linkedin.venice.kafka.validation.checksum.CheckSum
    • com.linkedin.venice.kafka.validation.checksum.AdHash
    • com.linkedin.venice.kafka.validation.checksum.Adler32CheckSum
    • com.linkedin.venice.kafka.validation.checksum.CRC32CheckSum
    • com.linkedin.venice.kafka.validation.checksum.MD5CheckSum
  • com.linkedin.davinci.utils.ChunkAssembler
  • com.linkedin.venice.hadoop.input.kafka.chunk.ChunkAssembler
  • com.linkedin.venice.hadoop.input.kafka.chunk.ChunkAssembler.ValueBytesAndSchemaId
  • com.linkedin.venice.writer.ChunkedPayloadAndManifest
  • com.linkedin.davinci.storage.chunking.ChunkedValueManifestContainer
  • com.linkedin.venice.utils.ChunkingTestUtils
  • com.linkedin.davinci.storage.chunking.ChunkingUtils
  • com.linkedin.venice.chunking.ChunkKeyValueTransformerImpl (implements com.linkedin.venice.chunking.ChunkKeyValueTransformer)
  • com.linkedin.venice.memory.ClassSizeEstimator
  • com.linkedin.alpini.base.misc.ClassUtil
  • com.linkedin.alpini.cli.CLIArgumentParser<T> (implements com.linkedin.alpini.cli.CLIParser<T>)
  • com.linkedin.venice.client.store.streaming.ClientComputeRecordStreamDecoder<K,V> (implements com.linkedin.venice.client.store.streaming.RecordStreamDecoder)
  • com.linkedin.venice.client.store.ClientConfig<T>
  • com.linkedin.venice.fastclient.ClientConfig<K,V,T>
  • com.linkedin.venice.fastclient.ClientConfig.ClientConfigBuilder<K,V,T>
  • com.linkedin.venice.client.store.ClientFactory
  • com.linkedin.venice.fastclient.factory.ClientFactory
  • com.linkedin.venice.client.store.ClientFactoryTestUtils
  • com.linkedin.venice.fastclient.utils.ClientTestUtils
  • com.linkedin.venice.utils.concurrent.CloseableThreadLocal<T> (implements java.lang.AutoCloseable)
  • com.linkedin.venice.controller.server.ClusterDiscovery
  • com.linkedin.venice.controller.init.ClusterLeaderInitializationManager (implements com.linkedin.venice.controller.init.ClusterLeaderInitializationRoutine)
  • com.linkedin.venice.utils.locks.ClusterLockManager
  • com.linkedin.venice.fastclient.stats.ClusterRouteStats
  • com.linkedin.davinci.schema.merge.CollectionFieldOperationHandler
    • com.linkedin.davinci.schema.merge.SortBasedCollectionFieldOpHandler
  • com.linkedin.venice.schema.rmd.v1.CollectionRmdTimestamp<DELETED_ELEMENT_TYPE>
  • com.linkedin.davinci.schema.merge.CollectionTimestampMergeRecordHelper
  • com.linkedin.alpini.base.misc.CollectionUtil.ListBuilder<T>
  • com.linkedin.alpini.base.misc.CollectionUtil.MapBuilder<K,V>
  • com.linkedin.alpini.base.misc.CollectionUtil.SetBuilder<T>
  • com.linkedin.venice.utils.CollectionUtils
  • com.linkedin.venice.datarecovery.Command
    • com.linkedin.venice.datarecovery.EstimateDataRecoveryTimeCommand
    • com.linkedin.venice.datarecovery.MonitorCommand
    • com.linkedin.venice.datarecovery.StoreRepushCommand
  • com.linkedin.venice.datarecovery.Command.Params
    • com.linkedin.venice.datarecovery.EstimateDataRecoveryTimeCommand.Params
    • com.linkedin.venice.datarecovery.MonitorCommand.Params
    • com.linkedin.venice.datarecovery.StoreRepushCommand.Params
  • com.linkedin.venice.datarecovery.Command.Result
    • com.linkedin.venice.datarecovery.EstimateDataRecoveryTimeCommand.Result
    • com.linkedin.venice.datarecovery.MonitorCommand.Result
    • com.linkedin.venice.datarecovery.StoreRepushCommand.Result
  • com.linkedin.venice.CommonConfigKeys
  • com.linkedin.venice.utils.ComplementSet<T>
  • java.util.concurrent.CompletableFuture<T> (implements java.util.concurrent.CompletionStage<T>, java.util.concurrent.Future<V>)
    • com.linkedin.venice.client.store.AppTimeOutTrackingCompletableFuture<T>
    • com.linkedin.alpini.base.concurrency.impl.DefaultAsyncFuture<T> (implements com.linkedin.alpini.base.concurrency.AsyncPromise<T>, com.linkedin.alpini.base.misc.Time.Awaitable)
      • com.linkedin.alpini.base.concurrency.impl.DefaultAsyncFutureTask<T> (implements java.util.concurrent.RunnableFuture<V>)
      • com.linkedin.alpini.base.concurrency.impl.DefaultCollectingAsyncFuture<V>
    • com.linkedin.davinci.utils.LockAssistedCompletableFuture<T>
    • com.linkedin.venice.client.store.streaming.VeniceResponseCompletableFuture<T>
  • com.linkedin.venice.writer.CompletableFutureCallback (implements com.linkedin.venice.memory.Measurable, com.linkedin.venice.pubsub.api.PubSubProducerCallback)
  • com.linkedin.alpini.netty4.compression.CompressionUtils
  • com.linkedin.venice.compression.CompressorFactory (implements java.lang.AutoCloseable, java.io.Closeable)
    • com.linkedin.davinci.compression.StorageEngineBackedCompressorFactory
  • com.linkedin.venice.client.store.ComputeGenericRecord (implements org.apache.avro.generic.GenericRecord)
  • com.linkedin.venice.compute.ComputeRequestWrapper
  • com.linkedin.venice.compute.ComputeUtils
  • com.linkedin.venice.utils.concurrent.ConcurrencyUtils
  • com.linkedin.alpini.base.concurrency.ConcurrentAccumulator<T,A,R> (implements java.util.function.Consumer<T>, java.util.function.Supplier<T>)
  • com.linkedin.venice.utils.ConcurrentRef<T>
  • com.linkedin.venice.ConfigConstants
  • com.linkedin.venice.ConfigKeys
  • com.linkedin.davinci.kafka.consumer.ConsumerAction (implements java.lang.Comparable<T>)
  • com.linkedin.davinci.kafka.consumer.ConsumerSubscriptionCleaner
  • com.linkedin.venice.router.api.ContentDecompressResult
  • com.linkedin.venice.controllerapi.ControllerApiConstants
  • com.linkedin.venice.controllerapi.ControllerClient (implements java.io.Closeable)
    • com.linkedin.venice.controllerapi.D2ControllerClient
  • com.linkedin.venice.system.store.ControllerClientBackedSystemSchemaInitializer (implements java.io.Closeable)
  • com.linkedin.venice.controllerapi.ControllerClientFactory
  • com.linkedin.venice.controllerapi.ControllerResponse
    • com.linkedin.venice.controllerapi.AclResponse
    • com.linkedin.venice.controllerapi.routes.AdminCommandExecutionResponse
    • com.linkedin.venice.controllerapi.AdminTopicMetadataResponse
    • com.linkedin.venice.controllerapi.ChildAwareResponse
    • com.linkedin.venice.controllerapi.ClusterStaleDataAuditResponse
    • com.linkedin.venice.controllerapi.D2ServiceDiscoveryResponse
      • com.linkedin.venice.controllerapi.D2ServiceDiscoveryResponseV2
    • com.linkedin.venice.routerapi.HybridStoreQuotaStatusResponse
    • com.linkedin.venice.controllerapi.IncrementalPushVersionsResponse
    • com.linkedin.venice.controllerapi.JobStatusQueryResponse
    • com.linkedin.venice.LastSucceedExecutionIdResponse
    • com.linkedin.venice.controllerapi.LeaderControllerResponse
    • com.linkedin.venice.controllerapi.MigrationPushStrategyResponse
    • com.linkedin.venice.controllerapi.MultiNodeResponse
    • com.linkedin.venice.controllerapi.MultiNodesStatusResponse
    • com.linkedin.venice.controllerapi.MultiReplicaResponse
    • com.linkedin.venice.controllerapi.MultiSchemaIdResponse
    • com.linkedin.venice.controllerapi.MultiSchemaResponse
    • com.linkedin.venice.controllerapi.MultiStoragePersonaResponse
    • com.linkedin.venice.controllerapi.MultiStoreInfoResponse
    • com.linkedin.venice.controllerapi.MultiStoreResponse
    • com.linkedin.venice.controllerapi.MultiStoreStatusResponse
    • com.linkedin.venice.controllerapi.MultiStoreTopicsResponse
    • com.linkedin.venice.controllerapi.MultiVersionStatusResponse
    • com.linkedin.venice.controllerapi.NewStoreResponse
    • com.linkedin.venice.controllerapi.NodeReplicasReadinessResponse
    • com.linkedin.venice.controllerapi.NodeStatusResponse
    • com.linkedin.venice.controllerapi.OwnerResponse
    • com.linkedin.venice.controllerapi.PartitionResponse
    • com.linkedin.venice.controllerapi.PubSubTopicConfigResponse
    • com.linkedin.venice.controllerapi.routes.PushJobStatusUploadResponse
    • com.linkedin.venice.routerapi.PushStatusResponse
    • com.linkedin.venice.controllerapi.ReadyForDataRecoveryResponse
    • com.linkedin.venice.controllerapi.RegionPushDetailsResponse
    • com.linkedin.venice.controllerapi.RepushInfoResponse
    • com.linkedin.venice.routerapi.ResourceStateResponse
    • com.linkedin.venice.controllerapi.RoutersClusterConfigResponse
    • com.linkedin.venice.controllerapi.SchemaResponse
    • com.linkedin.venice.controllerapi.SchemaUsageResponse
    • com.linkedin.venice.controllerapi.StoppableNodeStatusResponse
    • com.linkedin.venice.controllerapi.StorageEngineOverheadRatioResponse
    • com.linkedin.venice.controllerapi.StoragePersonaResponse
    • com.linkedin.venice.controllerapi.StoreComparisonResponse
    • com.linkedin.venice.controllerapi.StoreHealthAuditResponse
    • com.linkedin.venice.controllerapi.StoreMigrationResponse
    • com.linkedin.venice.controllerapi.StoreResponse
    • com.linkedin.venice.controllerapi.SystemStoreHeartbeatResponse
    • com.linkedin.venice.controllerapi.TrackableControllerResponse
      • com.linkedin.venice.controllerapi.MultiVersionResponse
    • com.linkedin.venice.controllerapi.VersionResponse
      • com.linkedin.venice.controllerapi.VersionCreationResponse
  • com.linkedin.venice.controllerapi.ControllerTransport (implements java.lang.AutoCloseable)
  • com.linkedin.venice.ControlMessageDumper
  • java.util.concurrent.CopyOnWriteArrayList<E> (implements java.lang.Cloneable, java.util.List<E>, java.util.RandomAccess, java.io.Serializable)
    • com.linkedin.venice.utils.SparseConcurrentList<E>
      • com.linkedin.venice.utils.SparseConcurrentListWithOffset<E>
  • com.linkedin.venice.compute.CosineSimilarityOperator (implements com.linkedin.venice.compute.ReadComputeOperator)
  • com.linkedin.venice.hadoop.mapreduce.datawriter.task.CounterBackedMapReduceDataWriterTaskTracker (implements com.linkedin.venice.hadoop.task.datawriter.DataWriterTaskTracker)
  • com.linkedin.alpini.base.misc.CounterQueue<T>
  • com.linkedin.venice.compute.CountOperator (implements com.linkedin.venice.compute.ReadComputeOperator)
  • com.linkedin.alpini.base.hash.Crc32 (implements java.util.zip.Checksum)
  • com.linkedin.alpini.base.hash.Crc32C (implements java.util.zip.Checksum)
  • com.linkedin.venice.listener.request.CurrentVersionRequest
  • com.linkedin.venice.controllerapi.CurrentVersionResponse
  • com.linkedin.venice.d2.D2ClientFactory
  • com.linkedin.venice.D2.D2ClientUtils
  • com.linkedin.venice.controllerapi.D2ControllerClientFactory
  • com.linkedin.venice.d2.D2HealthChecker
  • com.linkedin.venice.d2.D2Server (implements com.linkedin.venice.servicediscovery.ServiceDiscoveryAnnouncer)
  • com.linkedin.venice.d2.D2ServerManager
  • com.linkedin.venice.client.store.D2ServiceDiscovery
  • com.linkedin.venice.utils.DaemonThreadFactory (implements java.util.concurrent.ThreadFactory)
    • com.linkedin.venice.utils.RandomAccessDaemonThreadFactory
  • com.linkedin.venice.utils.DataProviderUtils
  • com.linkedin.venice.datarecovery.DataRecoveryClient
  • com.linkedin.venice.datarecovery.DataRecoveryClient.DataRecoveryParams
  • com.linkedin.venice.controller.datarecovery.DataRecoveryManager (implements java.io.Closeable)
  • com.linkedin.venice.datarecovery.DataRecoveryTask (implements java.lang.Runnable)
  • com.linkedin.venice.datarecovery.DataRecoveryTask.TaskParams
  • com.linkedin.venice.datarecovery.DataRecoveryTask.TaskResult
  • com.linkedin.venice.meta.DataRecoveryVersionConfigImpl (implements com.linkedin.venice.meta.DataRecoveryVersionConfig)
  • com.linkedin.venice.datarecovery.DataRecoveryWorker
    • com.linkedin.venice.datarecovery.DataRecoveryEstimator
    • com.linkedin.venice.datarecovery.DataRecoveryExecutor
    • com.linkedin.venice.datarecovery.DataRecoveryMonitor
  • com.linkedin.venice.spark.datawriter.task.DataWriterAccumulators (implements java.io.Serializable)
  • com.linkedin.venice.jobs.DataWriterComputeJob (implements com.linkedin.venice.jobs.ComputeJob)
    • com.linkedin.venice.spark.datawriter.jobs.AbstractDataWriterSparkJob
      • com.linkedin.venice.spark.datawriter.jobs.DataWriterSparkJob
    • com.linkedin.venice.hadoop.mapreduce.datawriter.jobs.DataWriterMRJob
  • com.linkedin.davinci.DaVinciBackend (implements java.io.Closeable)
  • com.linkedin.venice.blobtransfer.DaVinciBlobFinder (implements com.linkedin.venice.blobtransfer.BlobFinder)
  • com.linkedin.davinci.client.DaVinciConfig
  • com.linkedin.davinci.notifier.DaVinciPushStatusUpdateTask
  • com.linkedin.davinci.client.DaVinciRecordTransformer<K,V,O>
    • com.linkedin.davinci.client.BlockingDaVinciRecordTransformer<K,V,O>
  • com.linkedin.davinci.client.DaVinciRecordTransformerConfig
  • com.linkedin.davinci.client.DaVinciRecordTransformerResult<O>
  • com.linkedin.davinci.client.DaVinciRecordTransformerUtility<K,O>
  • org.apache.avro.io.Decoder
    • org.apache.avro.io.BinaryDecoder
      • org.apache.avro.io.ByteBufferOptimizedBinaryDecoder
      • org.apache.avro.io.OptimizedBinaryDecoder
  • com.linkedin.venice.offsets.DeepCopyOffsetManager (implements com.linkedin.venice.offsets.OffsetManager)
    • com.linkedin.venice.offsets.DeepCopyStorageMetadataService (implements com.linkedin.davinci.storage.StorageMetadataService)
  • io.netty.util.DefaultAttributeMap (implements io.netty.util.AttributeMap)
    • io.netty.handler.codec.http2.EspressoHttp2MultiplexHandler.EspressoHttp2MultiplexHandlerStreamChannel
  • org.apache.hc.client5.http.ssl.DefaultClientTlsStrategy
    • com.linkedin.venice.httpclient5.VeniceClientTlsStrategy
  • com.linkedin.venice.hadoop.mapreduce.engine.DefaultHadoopJobClientProvider (implements com.linkedin.venice.hadoop.mapreduce.engine.HadoopJobClientProvider)
  • io.netty.handler.codec.http.DefaultHttpObject (implements io.netty.handler.codec.http.HttpObject)
    • io.netty.handler.codec.http.DefaultHttpMessage (implements io.netty.handler.codec.http.HttpMessage)
      • com.linkedin.alpini.netty4.misc.BasicHttpMultiPart (implements io.netty.util.AttributeMap, com.linkedin.alpini.netty4.misc.HttpMultiPart)
        • com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart (implements com.linkedin.alpini.netty4.misc.FullHttpMultiPart, com.linkedin.alpini.netty4.misc.MultipartContent)
      • io.netty.handler.codec.http.DefaultHttpRequest (implements io.netty.handler.codec.http.HttpRequest)
        • com.linkedin.alpini.netty4.misc.BasicHttpRequest (implements io.netty.util.AttributeMap, com.linkedin.alpini.base.misc.BasicRequest, java.lang.Cloneable)
          • com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPartRequest (implements com.linkedin.alpini.netty4.misc.FullHttpMultiPartRequest)
          • com.linkedin.alpini.netty4.misc.BasicFullHttpRequest (implements io.netty.handler.codec.http.FullHttpRequest)
            • com.linkedin.alpini.netty4.http2.Http1FullRequest
          • com.linkedin.alpini.netty4.http2.Http1Request
      • io.netty.handler.codec.http.DefaultHttpResponse (implements io.netty.handler.codec.http.HttpResponse)
        • com.linkedin.alpini.netty4.misc.BasicHttpResponse (implements io.netty.util.AttributeMap)
          • com.linkedin.alpini.netty4.misc.BasicFullHttpResponse (implements io.netty.handler.codec.http.FullHttpResponse)
            • com.linkedin.alpini.netty4.http2.Http1FullResponse
          • com.linkedin.alpini.netty4.http2.Http1Response
        • com.linkedin.alpini.netty4.misc.DefaultFileChannelHttpResponse (implements com.linkedin.alpini.netty4.misc.ChunkedHttpResponse)
        • io.netty.handler.codec.http.DefaultFullHttpResponse (implements io.netty.handler.codec.http.FullHttpResponse)
          • com.linkedin.venice.router.streaming.SuccessfulStreamingResponse
          • com.linkedin.venice.router.api.VeniceFullHttpResponse
  • com.linkedin.venice.authorization.DefaultIdentityParser (implements com.linkedin.venice.authorization.IdentityParser)
  • com.linkedin.davinci.ingestion.DefaultIngestionBackend (implements com.linkedin.davinci.ingestion.IngestionBackend)
    • com.linkedin.davinci.ingestion.IsolatedIngestionBackend (implements com.linkedin.davinci.ingestion.IngestionBackend)
  • com.linkedin.venice.hadoop.DefaultInputDataInfoProvider (implements com.linkedin.venice.hadoop.InputDataInfoProvider)
  • com.linkedin.venice.hadoop.mapreduce.engine.DefaultJobClientWrapper (implements com.linkedin.venice.hadoop.JobClientWrapper)
  • com.linkedin.venice.controller.lingeringjob.DefaultLingeringStoreVersionChecker (implements com.linkedin.venice.controller.lingeringjob.LingeringStoreVersionChecker)
  • com.linkedin.venice.heartbeat.DefaultPushJobHeartbeatSenderFactory (implements com.linkedin.venice.heartbeat.PushJobHeartbeatSenderFactory)
  • com.linkedin.venice.serialization.DefaultSerializer (implements com.linkedin.venice.serialization.VeniceKafkaSerializer<T>)
  • com.linkedin.venice.security.DefaultSSLFactory (implements com.linkedin.venice.security.SSLFactory)
  • com.linkedin.venice.controller.supersetschema.DefaultSupersetSchemaGenerator (implements com.linkedin.venice.controller.supersetschema.SupersetSchemaGenerator)
  • com.linkedin.davinci.client.DelegatingAvroGenericDaVinciClient<K,V> (implements com.linkedin.venice.client.store.AvroGenericReadComputeStoreClient<K,V>, com.linkedin.davinci.client.DaVinciClient<K,V>)
    • com.linkedin.davinci.client.StatsAvroGenericDaVinciClient<K,V>
      • com.linkedin.davinci.client.StatsAvroSpecificDaVinciClient<K,V>
  • com.linkedin.venice.controller.init.DelegatingClusterLeaderInitializationRoutine (implements com.linkedin.venice.controller.init.ClusterLeaderInitializationRoutine)
  • com.linkedin.venice.client.store.streaming.DelegatingTrackingCallback<K,V> (implements com.linkedin.venice.client.store.streaming.TrackingStreamingCallback<K,V>)
    • com.linkedin.venice.client.store.streaming.ClientComputeRecordStreamDecoder.Callback<K,V>
  • com.linkedin.venice.writer.DeleteMetadata
  • com.linkedin.venice.guid.DeterministicGuidGenerator
  • com.linkedin.venice.listener.request.DictionaryFetchRequest
  • com.linkedin.venice.utils.DictionaryUtils
  • com.linkedin.venice.utils.consistency.DiffValidationUtils
  • com.linkedin.venice.utils.DiskUsage
  • com.linkedin.davinci.stats.DIVStats
  • com.linkedin.venice.compute.DotProductOperator (implements com.linkedin.venice.compute.ReadComputeOperator)
  • com.linkedin.alpini.base.misc.DoublyLinkedList.Entry<E>
    • com.linkedin.alpini.base.concurrency.TimeoutProcessor.TimeoutFuture
  • com.linkedin.venice.DumpAdminMessages
  • com.linkedin.venice.DumpAdminMessages.AdminOperationInfo
  • com.linkedin.venice.producer.DurableWrite
  • com.linkedin.venice.schema.rmd.v1.ElementTimestampAndIdx
  • org.apache.avro.io.Encoder (implements java.io.Flushable)
    • org.apache.avro.io.ParsingEncoder
      • org.apache.avro.io.JsonEncoder (implements org.apache.avro.io.parsing.Parser.ActionHandler)
        • org.apache.avro.io.ByteBufferToHexFormatJsonEncoder
  • com.linkedin.venice.utils.EncodingUtils
  • com.linkedin.venice.utils.EnumUtils
  • com.linkedin.venice.client.store.predicate.EqualsRelationalOperator (implements com.linkedin.venice.client.store.predicate.Predicate)
  • com.linkedin.venice.controller.ErrorPartitionResetTask (implements java.io.Closeable, java.lang.Runnable)
  • io.netty.handler.codec.http2.EspressoHttp2FrameCodecUtil
  • io.netty.handler.codec.http2.EspressoHttp2StreamChannelBootstrap
  • com.linkedin.alpini.netty4.pool.EspressoSimpleChannelPool (implements io.netty.channel.pool.ChannelPool)
    • com.linkedin.alpini.netty4.pool.EspressoFixedChannelPool (implements com.linkedin.alpini.netty4.pool.ChannelPoolWithStats)
      • com.linkedin.alpini.netty4.pool.FixedChannelPoolImpl (implements com.linkedin.alpini.netty4.pool.ManagedChannelPool)
  • com.linkedin.venice.datarecovery.EstimateDataRecoveryTimeCommand.Params.Builder
  • com.linkedin.venice.meta.ETLStoreConfigImpl (implements com.linkedin.venice.meta.ETLStoreConfig)
  • com.linkedin.venice.etl.ETLUtils
  • com.linkedin.venice.throttle.EventThrottler (implements com.linkedin.venice.throttle.VeniceRateLimiter)
  • com.linkedin.venice.unit.matchers.ExceptionClassAndCauseClassMatcher (implements org.mockito.ArgumentMatcher<T>)
  • com.linkedin.venice.unit.matchers.ExceptionClassMatcher (implements org.mockito.ArgumentMatcher<T>)
  • com.linkedin.venice.utils.ExceptionUtils
  • com.linkedin.venice.pushmonitor.ExecutionStatusWithDetails
  • com.linkedin.alpini.io.ExternalCommand
  • com.linkedin.avro.fastserde.FastDeserializerGeneratorAccessor
  • com.linkedin.alpini.log.FastLog (implements com.linkedin.alpini.log.FastLogMBean)
  • com.linkedin.alpini.log.FastLogContext (implements org.apache.logging.log4j.spi.LoggerContext)
  • com.linkedin.alpini.log.FastLogContextFactory (implements org.apache.logging.log4j.spi.LoggerContextFactory)
  • com.linkedin.alpini.log.FastLogger (implements org.apache.logging.log4j.spi.ExtendedLogger)
  • com.linkedin.alpini.netty4.pool.FastSimpleChannelPool (implements io.netty.channel.pool.ChannelPool)
    • com.linkedin.alpini.netty4.pool.FastFixedChannelPool (implements com.linkedin.alpini.netty4.pool.ChannelPoolWithStats)
      • com.linkedin.alpini.netty4.pool.FixedFastChannelPoolImpl (implements com.linkedin.alpini.netty4.pool.ManagedChannelPool)
  • org.apache.hadoop.mapred.FileInputFormat<K,V> (implements org.apache.hadoop.mapred.InputFormat<K,V>)
    • org.apache.hadoop.mapred.SequenceFileInputFormat<K,V>
      • com.linkedin.venice.hadoop.VsonSequenceFileInputFormat
  • org.apache.hadoop.mapred.FileOutputFormat<K,V> (implements org.apache.hadoop.mapred.OutputFormat<K,V>)
    • org.apache.avro.mapred.AvroOutputFormat<T>
      • com.linkedin.venice.hadoop.ValidateSchemaAndBuildDictOutputFormat
  • com.linkedin.venice.hadoop.FilterChain<INPUT_VALUE> (implements java.io.Closeable)
  • com.linkedin.alpini.netty4.pool.FixedChannelPoolFactory (implements io.netty.channel.pool.ChannelHealthChecker, com.linkedin.alpini.netty4.pool.ChannelPoolFactory)
  • com.linkedin.alpini.base.hash.FnvHashFunction (implements com.linkedin.alpini.base.hash.HashFunction)
  • com.linkedin.venice.utils.ForkedJavaProcess.LogInfo
  • com.linkedin.alpini.netty4.misc.Futures
  • java.util.concurrent.FutureTask<V> (implements java.util.concurrent.RunnableFuture<V>)
    • com.linkedin.alpini.base.concurrency.CompletableFutureTask<V> (implements java.util.concurrent.CompletionStage<T>)
  • io.tehuti.metrics.stats.Gauge (implements io.tehuti.metrics.MeasurableStat)
    • com.linkedin.venice.stats.LongAdderRateGauge
  • com.linkedin.venice.schema.GeneratedSchemaID
  • org.apache.avro.generic.GenericDatumReader<D> (implements org.apache.avro.io.DatumReader<D>)
    • com.linkedin.davinci.serializer.avro.MapOrderPreservingDatumReader<T>
    • org.apache.avro.specific.SpecificDatumReader<T>
      • com.linkedin.venice.serialization.avro.VeniceSpecificDatumReader<T>
    • com.linkedin.venice.schema.vson.VsonAvroDatumReader<D>
  • org.apache.avro.generic.GenericDatumWriter<D> (implements org.apache.avro.io.DatumWriter<D>)
    • org.apache.avro.generic.DeterministicMapOrderGenericDatumWriter<T> (implements org.apache.avro.generic.DeterministicMapOrderDatumWriter)
    • com.linkedin.davinci.serializer.avro.MapOrderPreservingGenericDatumWriter<T>
    • org.apache.avro.specific.SpecificDatumWriter<T>
      • org.apache.avro.specific.DeterministicMapOrderSpecificDatumWriter<T> (implements org.apache.avro.generic.DeterministicMapOrderDatumWriter)
      • com.linkedin.davinci.serializer.avro.MapOrderPreservingSpecificDatumWriter<T>
    • com.linkedin.venice.schema.vson.VsonAvroDatumWriter<K>
  • com.linkedin.venice.fastclient.GrpcClientConfig
  • com.linkedin.venice.fastclient.GrpcClientConfig.Builder
  • com.linkedin.venice.listener.grpc.GrpcRequestContext
  • com.linkedin.venice.grpc.GrpcUtils
  • com.linkedin.venice.throttle.GuavaRateLimiter (implements com.linkedin.venice.throttle.VeniceRateLimiter)
  • com.linkedin.venice.guid.GuidUtils
  • com.linkedin.venice.compute.HadamardProductOperator (implements com.linkedin.venice.compute.ReadComputeOperator)
  • com.linkedin.venice.hadoop.utils.HadoopUtils
  • com.linkedin.venice.utils.HashCodeComparator<T> (implements java.util.Comparator<T>)
  • io.netty.util.HashedWheelTimer (implements io.netty.util.Timer)
    • com.linkedin.alpini.netty4.misc.ShutdownableHashedWheelTimer (implements com.linkedin.alpini.base.registry.Shutdownable)
  • com.linkedin.venice.hadoop.input.recordreader.avro.HdfsAvroUtils
  • com.linkedin.venice.hadoop.schema.HDFSSchemaSource (implements java.lang.AutoCloseable, com.linkedin.venice.hadoop.schema.SchemaSource)
  • com.linkedin.alpini.base.misc.HeaderStringCache
  • com.linkedin.alpini.base.misc.HeaderStringCache.Cache
  • com.linkedin.venice.listener.request.HealthCheckRequest
  • com.linkedin.venice.controller.lingeringjob.HeartbeatBasedLingeringStoreVersionChecker (implements com.linkedin.venice.controller.lingeringjob.LingeringStoreVersionChecker)
  • com.linkedin.venice.guid.HeartbeatGuidV3Generator
  • com.linkedin.venice.listener.request.HeartbeatRequest
  • com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatStat
  • com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatTimeStampEntry
  • com.linkedin.venice.helix.HelixAdapterSerializer (implements org.apache.helix.manager.zk.PathBasedZkSerializer)
  • com.linkedin.venice.helix.HelixBaseRoutingRepository (implements org.apache.helix.api.listeners.ControllerChangeListener, com.linkedin.venice.meta.RoutingDataRepository, org.apache.helix.api.listeners.RoutingTableChangeListener)
    • com.linkedin.venice.helix.HelixCustomizedViewOfflinePushRepository
    • com.linkedin.venice.helix.HelixExternalViewRepository (implements org.apache.helix.api.listeners.IdealStateChangeListener)
  • com.linkedin.venice.helix.HelixCustomizedViewOfflinePushRepository.StoreChangeListener (implements com.linkedin.venice.meta.StoreDataChangedListener)
  • com.linkedin.venice.pushmonitor.HelixCVBasedPushMonitor
  • com.linkedin.venice.fastclient.meta.HelixGroupInfo
  • com.linkedin.venice.router.api.routing.helix.HelixGroupLeastLoadedStrategy (implements com.linkedin.venice.router.api.routing.helix.HelixGroupSelectionStrategy)
  • com.linkedin.venice.router.api.routing.helix.HelixGroupRoundRobinStrategy (implements com.linkedin.venice.router.api.routing.helix.HelixGroupSelectionStrategy)
  • com.linkedin.venice.router.api.routing.helix.HelixGroupSelector (implements com.linkedin.venice.router.api.routing.helix.HelixGroupSelectionStrategy)
  • com.linkedin.venice.helix.HelixHybridStoreQuotaRepository (implements org.apache.helix.api.listeners.RoutingTableChangeListener)
  • com.linkedin.venice.helix.HelixInstanceConfigRepository (implements org.apache.helix.api.listeners.InstanceConfigChangeListener, com.linkedin.venice.VeniceResource)
  • com.linkedin.venice.helix.HelixInstanceConverter
  • com.linkedin.venice.helix.HelixLiveInstanceMonitor (implements org.apache.helix.zookeeper.zkclient.IZkChildListener, com.linkedin.venice.meta.LiveInstanceMonitor, com.linkedin.venice.VeniceResource)
  • com.linkedin.venice.helix.HelixPartitionStateAccessor
    • com.linkedin.venice.helix.HelixPartitionStatusAccessor
  • com.linkedin.venice.helix.HelixReadOnlyLiveClusterConfigRepository (implements com.linkedin.venice.meta.ReadOnlyLiveClusterConfigRepository)
    • com.linkedin.venice.helix.HelixReadWriteLiveClusterConfigRepository (implements com.linkedin.venice.meta.ReadWriteLiveClusterConfigRepository)
  • com.linkedin.venice.helix.HelixReadOnlySchemaRepository (implements com.linkedin.venice.meta.ReadOnlySchemaRepository, com.linkedin.venice.meta.StoreDataChangedListener)
    • com.linkedin.venice.helix.HelixReadOnlyZKSharedSchemaRepository
      • com.linkedin.venice.controller.helix.SharedHelixReadOnlyZKSharedSchemaRepository (implements java.io.Closeable)
  • com.linkedin.venice.helix.HelixReadOnlySchemaRepositoryAdapter (implements com.linkedin.venice.meta.ReadOnlySchemaRepository)
  • com.linkedin.venice.helix.HelixReadOnlyStoreConfigRepository (implements com.linkedin.venice.meta.ReadOnlyStoreConfigRepository, com.linkedin.venice.VeniceResource)
  • com.linkedin.venice.helix.HelixReadOnlyStoreConfigRepository.StoreConfigAddedOrDeletedChangedListener (implements org.apache.helix.zookeeper.zkclient.IZkChildListener)
  • com.linkedin.venice.helix.HelixReadOnlyStoreConfigRepository.StoreConfigChangedListener (implements org.apache.helix.zookeeper.zkclient.IZkDataListener)
  • com.linkedin.venice.helix.HelixReadOnlyStoreRepositoryAdapter (implements com.linkedin.venice.meta.ReadOnlyStoreRepository)
    • com.linkedin.venice.helix.HelixReadWriteStoreRepositoryAdapter (implements com.linkedin.venice.meta.ReadWriteStoreRepository)
  • com.linkedin.venice.helix.HelixReadOnlyStoreRepositoryAdapter.VeniceStoreDataChangedListener (implements com.linkedin.venice.meta.StoreDataChangedListener)
  • com.linkedin.venice.helix.HelixReadWriteSchemaRepository (implements com.linkedin.venice.meta.ReadWriteSchemaRepository)
  • com.linkedin.venice.helix.HelixReadWriteSchemaRepositoryAdapter (implements com.linkedin.venice.meta.ReadWriteSchemaRepository)
  • com.linkedin.venice.helix.HelixSchemaAccessor
  • com.linkedin.venice.helix.HelixStatusMessageChannel (implements com.linkedin.venice.status.StatusMessageChannel)
  • com.linkedin.venice.helix.HelixStoreGraveyard (implements com.linkedin.venice.meta.StoreGraveyard)
  • com.linkedin.venice.utils.HelixUtils
  • com.linkedin.venice.controller.HelixVeniceClusterResources (implements com.linkedin.venice.VeniceResource)
  • com.linkedin.alpini.netty4.pool.Http2AwareChannelPool (implements com.linkedin.alpini.netty4.pool.ManagedChannelPool)
  • com.linkedin.alpini.netty4.pool.Http2PingHelper (implements com.linkedin.alpini.netty4.pool.Http2PingCallListener)
  • com.linkedin.alpini.netty4.http2.Http2PipelineInitializer.Builder<T>
  • com.linkedin.alpini.netty4.misc.Http2Utils
  • com.linkedin.venice.fastclient.transport.HttpClient5BasedR2Client
  • com.linkedin.venice.router.httpclient.HttpClient5StorageNodeClient (implements com.linkedin.venice.router.httpclient.StorageNodeClient)
  • com.linkedin.venice.httpclient5.HttpClient5Utils
  • com.linkedin.venice.httpclient5.HttpClient5Utils.HttpClient5Builder
  • com.linkedin.davinci.ingestion.HttpClientTransport (implements java.lang.AutoCloseable)
  • com.linkedin.venice.httpclient.HttpClientUtils
  • com.linkedin.venice.httpclient.HttpClientUtils.ClosableHttpAsyncClientWithConnManager
  • com.linkedin.venice.HttpConstants
  • io.netty.handler.codec.http.HttpHeaders (implements java.lang.Iterable<T>)
    • com.linkedin.alpini.netty4.http2.Http1Headers
  • com.linkedin.alpini.netty4.handlers.HttpServerStatisticsHandler.Stats
  • com.linkedin.venice.listener.response.HttpShortcutResponse
  • com.linkedin.alpini.netty4.misc.HttpToStringUtils
  • com.linkedin.venice.meta.HybridStoreConfigImpl (implements com.linkedin.venice.meta.HybridStoreConfig)
  • com.linkedin.venice.serialization.IdentityRecordDeserializer (implements com.linkedin.venice.serializer.RecordDeserializer<T>)
  • com.linkedin.davinci.consumer.ImmutableChangeCapturePubSubMessage<K,V> (implements com.linkedin.venice.pubsub.api.PubSubMessage<K,V,OFFSET>)
  • com.linkedin.venice.pubsub.ImmutablePubSubMessage<K,V> (implements com.linkedin.venice.pubsub.api.PubSubMessage<K,V,OFFSET>)
  • com.linkedin.davinci.kafka.consumer.IngestionBatchProcessor
  • com.linkedin.davinci.storage.IngestionMetadataRetrieverDelegator (implements com.linkedin.davinci.storage.IngestionMetadataRetriever)
  • com.linkedin.davinci.stats.IngestionStats
  • com.linkedin.davinci.kafka.consumer.IngestionThrottler (implements java.io.Closeable)
  • com.linkedin.venice.admin.InMemoryExecutionIdAccessor (implements com.linkedin.venice.controller.ExecutionIdAccessor)
  • com.linkedin.venice.unit.kafka.InMemoryKafkaBroker
  • com.linkedin.venice.unit.kafka.InMemoryKafkaMessage
  • com.linkedin.venice.offsets.InMemoryOffsetManager (implements com.linkedin.venice.offsets.OffsetManager)
    • com.linkedin.venice.offsets.InMemoryStorageMetadataService (implements com.linkedin.davinci.storage.StorageMetadataService)
  • com.linkedin.venice.hadoop.InputDataInfoProvider.InputDataInfo
  • com.linkedin.venice.hadoop.InputStorageQuotaTracker
  • java.io.InputStream (implements java.io.Closeable)
    • com.linkedin.davinci.storage.chunking.ChunkedValueInputStream
    • com.linkedin.alpini.io.ZeroInputStream
  • com.linkedin.venice.meta.Instance
  • com.linkedin.venice.fastclient.meta.InstanceHealthMonitor (implements java.io.Closeable)
  • com.linkedin.venice.controller.InstanceRemovableStatuses
  • com.linkedin.venice.memory.InstanceSizeEstimator
  • com.linkedin.venice.controller.InstanceStatusDecider
  • com.linkedin.alpini.netty4.misc.InstrumentibleEventExecutor.Completion
  • com.linkedin.venice.serialization.avro.InternalAvroSpecificSerializer<SPECIFIC_RECORD> (implements com.linkedin.venice.serialization.VeniceKafkaSerializer<T>)
    • com.linkedin.venice.serialization.avro.ChunkedKeySuffixSerializer
    • com.linkedin.venice.serialization.avro.ChunkedValueManifestSerializer
    • com.linkedin.venice.serialization.avro.KafkaValueSerializer
      • com.linkedin.venice.serialization.avro.OptimizedKafkaValueSerializer
  • com.linkedin.venice.client.store.InternalAvroStoreClient<K,V> (implements com.linkedin.venice.client.store.AvroGenericReadComputeStoreClient<K,V>)
    • com.linkedin.venice.client.store.AbstractAvroStoreClient<K,V>
      • com.linkedin.venice.client.store.AvroGenericStoreClientImpl<K,V>
        • com.linkedin.venice.client.store.AvroBlackHoleResponseStoreClientImpl<K,V>
        • com.linkedin.venice.client.store.VsonGenericStoreClientImpl<K,V>
      • com.linkedin.venice.client.store.AvroSpecificStoreClientImpl<K,V> (implements com.linkedin.venice.client.store.AvroSpecificStoreClient<K,V>)
    • com.linkedin.venice.client.store.DelegatingStoreClient<K,V>
      • com.linkedin.venice.client.store.RetriableStoreClient<K,V>
        • com.linkedin.venice.client.store.SpecificRetriableStoreClient<K,V> (implements com.linkedin.venice.client.store.AvroSpecificStoreClient<K,V>)
      • com.linkedin.venice.client.store.StatTrackingStoreClient<K,V>
        • com.linkedin.venice.client.store.SpecificStatTrackingStoreClient<K,V> (implements com.linkedin.venice.client.store.AvroSpecificStoreClient<K,V>)
  • com.linkedin.venice.fastclient.InternalAvroStoreClient<K,V> (implements com.linkedin.venice.client.store.AvroGenericReadComputeStoreClient<K,V>)
    • com.linkedin.venice.fastclient.DelegatingAvroStoreClient<K,V>
      • com.linkedin.venice.fastclient.DualReadAvroGenericStoreClient<K,V>
        • com.linkedin.venice.fastclient.DualReadAvroSpecificStoreClient<K,V> (implements com.linkedin.venice.client.store.AvroSpecificStoreClient<K,V>)
      • com.linkedin.venice.fastclient.RetriableAvroGenericStoreClient<K,V>
        • com.linkedin.venice.fastclient.RetriableAvroSpecificStoreClient<K,V> (implements com.linkedin.venice.client.store.AvroSpecificStoreClient<K,V>)
      • com.linkedin.venice.fastclient.StatsAvroGenericStoreClient<K,V>
        • com.linkedin.venice.fastclient.StatsAvroSpecificStoreClient<K,V> (implements com.linkedin.venice.client.store.AvroSpecificStoreClient<K,V>)
    • com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient<K,V>
      • com.linkedin.venice.fastclient.DispatchingAvroSpecificStoreClient<K,V> (implements com.linkedin.venice.client.store.AvroSpecificStoreClient<K,V>)
      • com.linkedin.venice.fastclient.DispatchingVsonStoreClient<K,V>
  • com.linkedin.davinci.ingestion.isolated.IsolatedIngestionNotifier (implements com.linkedin.davinci.notifier.VeniceNotifier)
  • com.linkedin.davinci.ingestion.isolated.IsolatedIngestionRequestClient (implements java.io.Closeable)
  • com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils
  • com.linkedin.alpini.base.misc.IteratorUtil
  • com.linkedin.venice.utils.IteratorUtils
  • com.linkedin.venice.guid.JavaUtilGuidV4Generator
  • com.linkedin.alpini.base.hash.JenkinsHashFunction (implements com.linkedin.alpini.base.hash.HashFunction)
  • com.linkedin.venice.hadoop.mapreduce.common.JobUtils
  • com.linkedin.alpini.base.misc.Joiner
  • com.linkedin.davinci.kafka.consumer.KafkaClusterBasedRecordThrottler
  • com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.ConsumerPoolStrategy
    • com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.CurrentVersionConsumerPoolStrategy
    • com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.DefaultConsumerPoolStrategy
      • com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.AAOrWCLeaderConsumerPoolStrategy
  • com.linkedin.davinci.validation.KafkaDataIntegrityValidator
  • com.linkedin.venice.hadoop.KafkaInputDataInfoProvider (implements com.linkedin.venice.hadoop.InputDataInfoProvider)
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputDictTrainer
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputDictTrainer.Param
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputDictTrainer.ParamBuilder
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputFormat (implements org.apache.hadoop.mapred.InputFormat<K,V>)
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputKeyComparator (implements org.apache.hadoop.io.RawComparator<T>, java.io.Serializable)
    • com.linkedin.venice.hadoop.input.kafka.KafkaInputValueGroupingComparator
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputRecordReader (implements java.lang.AutoCloseable, org.apache.hadoop.mapred.RecordReader<K,V>)
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputSplit (implements org.apache.hadoop.mapred.InputSplit)
  • com.linkedin.venice.hadoop.input.kafka.KafkaInputUtils
  • com.linkedin.venice.message.KafkaKey (implements com.linkedin.venice.memory.Measurable)
  • com.linkedin.venice.serialization.KafkaKeySerializer (implements com.linkedin.venice.serialization.VeniceKafkaSerializer<T>)
  • com.linkedin.venice.utils.KafkaSSLUtils
  • com.linkedin.venice.KafkaTopicDumper (implements java.lang.AutoCloseable)
  • com.linkedin.venice.utils.KeyAndValueSchemas
  • com.linkedin.davinci.kafka.consumer.KeyLevelLocksManager
  • com.linkedin.venice.serialization.KeyWithChunkingSuffixSerializer
  • com.linkedin.venice.utils.pools.LandFillObjectPool<O>
  • com.linkedin.venice.utils.LatencyUtils
  • com.linkedin.alpini.base.concurrency.Lazy<T> (implements java.util.function.Supplier<T>)
  • com.linkedin.venice.utils.lazy.LazyImpl<T> (implements com.linkedin.venice.utils.lazy.Lazy<T>)
  • com.linkedin.venice.utils.lazy.LazyResettableImpl<C> (implements com.linkedin.venice.utils.lazy.LazyResettable<C>)
    • com.linkedin.venice.utils.lazy.LazyResettableWithTearDown<C>
  • com.linkedin.davinci.helix.LeaderFollowerPartitionStateModel.LeaderSessionIdChecker
  • com.linkedin.venice.writer.LeaderMetadataWrapper
  • com.linkedin.davinci.kafka.consumer.LeaderProducedRecordContext (implements com.linkedin.venice.memory.Measurable)
  • com.linkedin.davinci.kafka.consumer.LeaderProducerCallback (implements com.linkedin.venice.writer.ChunkAwareCallback)
    • com.linkedin.davinci.kafka.consumer.ActiveActiveProducerCallback
  • com.linkedin.alpini.base.misc.LeakDetect
  • com.linkedin.alpini.consts.Level
  • com.linkedin.alpini.base.pool.impl.LifeCycleFilter<T> (implements com.linkedin.alpini.base.pool.AsyncPool.LifeCycle<T>)
    • com.linkedin.alpini.base.pool.impl.LifeCycleStatsCollector<T>
    • com.linkedin.alpini.base.pool.impl.RateLimitedCreateLifeCycle<T>
  • com.linkedin.venice.listener.ListenerManager<T>
  • com.linkedin.venice.meta.LiveClusterConfig
  • com.linkedin.venice.LogConfigurator
  • com.linkedin.venice.LogMessages
  • com.linkedin.davinci.notifier.LogNotifier (implements com.linkedin.davinci.notifier.VeniceNotifier)
    • com.linkedin.venice.utils.ExceptionCaptorNotifier
  • com.linkedin.venice.unit.matchers.LongEqualOrGreaterThanMatcher (implements org.mockito.ArgumentMatcher<T>)
  • com.linkedin.alpini.base.statistics.LongStatsLowQuantileImpl (implements com.linkedin.alpini.base.statistics.LongStatsLowQuantile, org.apache.logging.log4j.util.StringBuilderFormattable)
  • com.linkedin.venice.router.stats.LongTailRetryStatsProvider (implements java.util.function.Function<T,R>)
  • com.linkedin.alpini.base.misc.LowerCaseAsciiCharSequence (implements java.lang.CharSequence, java.lang.Comparable<T>, org.apache.logging.log4j.util.StringBuilderFormattable)
  • com.linkedin.davinci.ingestion.main.MainIngestionRequestClient (implements java.io.Closeable)
  • com.linkedin.davinci.ingestion.main.MainTopicIngestionStatus
  • com.linkedin.davinci.serializer.avro.fast.MapOrderPreservingFastSerDeFactory
  • com.linkedin.venice.hadoop.mapreduce.engine.MapReduceEngineTaskConfigProvider (implements com.linkedin.venice.hadoop.engine.EngineTaskConfigProvider)
  • com.linkedin.venice.utils.collections.MemoryBoundBlockingQueue<T> (implements java.util.concurrent.BlockingQueue<E>)
  • com.linkedin.davinci.replication.merge.MergeByteBuffer
  • com.linkedin.davinci.replication.merge.MergeConflictResolver
  • com.linkedin.davinci.replication.merge.MergeConflictResolverFactory
  • com.linkedin.davinci.replication.merge.MergeConflictResult
  • com.linkedin.davinci.kafka.consumer.MergeConflictResultWrapper
  • com.linkedin.davinci.replication.merge.MergeGenericRecord
  • com.linkedin.davinci.replication.merge.MergeResultValueSchemaResolverImpl
  • com.linkedin.davinci.replication.merge.MergeUtils
  • com.linkedin.venice.kafka.protocol.enums.MessageType.Constants
  • com.linkedin.venice.listener.request.MetadataFetchRequest
  • com.linkedin.davinci.kafka.consumer.MetadataRepoBasedTopicExistingCheckerImpl (implements com.linkedin.davinci.kafka.consumer.TopicExistenceChecker)
  • com.linkedin.davinci.listener.response.MetadataResponse
  • com.linkedin.venice.system.store.MetaStoreReader (implements java.io.Closeable)
  • com.linkedin.venice.router.api.MetaStoreShadowReader
  • com.linkedin.venice.system.store.MetaStoreWriter (implements java.io.Closeable)
  • com.linkedin.alpini.base.misc.Metrics
  • com.linkedin.venice.utils.metrics.MetricsRepositoryUtils
  • com.linkedin.venice.tehuti.MetricsUtils
  • com.linkedin.venice.controller.migration.MigrationPushStrategyZKAccessor
  • com.linkedin.venice.utils.MockCircularTime (implements com.linkedin.venice.utils.Time)
  • com.linkedin.venice.unit.kafka.MockInMemoryAdminAdapter (implements com.linkedin.venice.pubsub.api.PubSubAdminAdapter)
  • com.linkedin.venice.unit.kafka.consumer.MockInMemoryConsumer (implements com.linkedin.venice.pubsub.api.PubSubConsumerAdapter)
  • com.linkedin.venice.unit.kafka.producer.MockInMemoryProducerAdapter (implements com.linkedin.venice.pubsub.api.PubSubProducerAdapter)
  • com.linkedin.venice.tehuti.MockTehutiReporter (implements io.tehuti.metrics.MetricsReporter)
  • com.linkedin.venice.controller.MockVeniceAuthorizer (implements com.linkedin.venice.authorization.AuthorizerService)
  • com.linkedin.venice.datarecovery.MonitorCommand.Params.Builder
  • com.linkedin.venice.hadoop.mapreduce.counter.MRJobCounterHelper
  • com.linkedin.venice.hadoop.mapreduce.counter.MRJobCounterHelper.GroupAndCounterNames
  • com.linkedin.alpini.base.misc.Msg (implements org.apache.logging.log4j.util.StringBuilderFormattable, java.util.function.Supplier<T>)
  • com.linkedin.venice.fastclient.MultiKeyRequestContext.KeyInfo<K>
  • com.linkedin.venice.controllerapi.MultiSchemaResponse.Schema
  • com.linkedin.alpini.base.concurrency.NamedThreadFactory (implements java.util.concurrent.ThreadFactory)
  • com.linkedin.venice.utils.NamedThreadFactory (implements java.util.concurrent.ThreadFactory)
  • com.linkedin.davinci.repository.NativeMetadataRepository (implements com.linkedin.venice.meta.ClusterInfoProvider, com.linkedin.venice.meta.ReadOnlySchemaRepository, com.linkedin.venice.meta.SubscriptionBasedReadOnlyStoreRepository)
    • com.linkedin.davinci.repository.ThinClientMetaStoreBasedRepository
  • com.linkedin.alpini.base.misc.Netty4ThrowException (implements com.linkedin.alpini.base.misc.ExceptionUtil.ExceptionThrower)
  • com.linkedin.davinci.blobtransfer.client.NettyFileTransferClient
  • com.linkedin.davinci.blobtransfer.NettyP2PBlobTransferManager (implements com.linkedin.davinci.blobtransfer.P2PBlobTransferManager<T>)
  • com.linkedin.alpini.netty4.misc.NettyUtils
  • com.linkedin.venice.utils.NettyUtils
  • com.linkedin.venice.controller.NodeRemovableResult
  • com.linkedin.venice.unit.matchers.NonEmptyStringMatcher (implements org.mockito.ArgumentMatcher<T>)
  • com.linkedin.venice.heartbeat.NoOpPushJobHeartbeatSender (implements com.linkedin.venice.heartbeat.PushJobHeartbeatSender)
  • com.linkedin.venice.heartbeat.NoOpPushJobHeartbeatSenderFactory (implements com.linkedin.venice.heartbeat.PushJobHeartbeatSenderFactory)
  • com.linkedin.davinci.listener.response.NoOpReadResponseStats (implements com.linkedin.davinci.listener.response.ReadResponseStats)
  • com.linkedin.venice.hadoop.NoOpSentPushJobDetailsTracker (implements com.linkedin.venice.hadoop.SentPushJobDetailsTracker)
  • com.linkedin.venice.hadoop.validation.NoOpValidator (implements com.linkedin.venice.hadoop.validation.Validator)
  • com.linkedin.venice.controller.server.NotImplemented
  • com.linkedin.alpini.base.monitoring.NullCallTracker (implements com.linkedin.alpini.base.monitoring.CallTracker)
  • com.linkedin.venice.utils.collections.NullSkippingIteratorWrapper<E>
  • com.linkedin.alpini.base.pool.impl.NullStats (implements com.linkedin.alpini.base.monitoring.CallTracker.CallStats)
  • com.linkedin.davinci.store.cache.backend.ObjectCacheBackend
  • com.linkedin.davinci.store.cache.backend.ObjectCacheConfig
  • com.linkedin.venice.utils.ObjectMapperFactory
  • com.linkedin.venice.pushmonitor.OfflinePushStatus
  • com.linkedin.venice.helix.OfflinePushStatusJSONSerializer.OfflinePushStatusSerializerMixin
  • com.linkedin.venice.helix.OfflinePushStatusJSONSerializer.StatusSnapshotSerializerMixin
  • com.linkedin.venice.offsets.OffsetRecord
  • com.linkedin.venice.producer.online.OnlineProducerFactory
  • org.apache.avro.io.OptimizedBinaryDecoderFactory
  • java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
    • java.io.ByteArrayOutputStream
      • com.linkedin.venice.io.ZeroCopyByteArrayOutputStream
    • java.io.FilterOutputStream
      • com.linkedin.alpini.io.CompressOutputStream
      • java.util.zip.DeflaterOutputStream
        • com.linkedin.venice.compression.ReusableGzipOutputStream
      • com.linkedin.alpini.io.MeteredOutputStream
      • com.linkedin.alpini.io.PigzOutputStream
    • com.linkedin.alpini.io.NullOutputStream
  • com.linkedin.alpini.base.misc.Pair<F,S>
    • com.linkedin.alpini.base.misc.ImmutableMapEntry<K,V> (implements java.util.Map.Entry<K,V>)
  • com.linkedin.venice.utils.Pair<F,S> (implements java.io.Serializable)
  • com.linkedin.venice.controller.util.ParentControllerConfigUpdateUtils
  • com.linkedin.venice.helix.ParentHelixOfflinePushAccessor
  • com.linkedin.venice.controller.ParticipantStoreClientsManager (implements java.io.Closeable)
  • com.linkedin.davinci.kafka.consumer.ParticipantStoreConsumptionTask (implements java.io.Closeable, java.lang.Runnable)
  • com.linkedin.venice.meta.Partition
  • com.linkedin.venice.meta.PartitionAssignment
  • com.linkedin.davinci.kafka.consumer.PartitionConsumptionState
  • com.linkedin.davinci.kafka.consumer.PartitionConsumptionState.TransientRecord
  • com.linkedin.venice.meta.PartitionDetail
  • org.apache.spark.Partitioner (implements scala.Serializable)
    • com.linkedin.venice.spark.datawriter.partition.VeniceSparkPartitioner
  • com.linkedin.venice.meta.PartitionerConfigImpl (implements com.linkedin.venice.meta.PartitionerConfig)
  • com.linkedin.davinci.kafka.consumer.PartitionReplicaIngestionContext
  • com.linkedin.venice.spark.datawriter.partition.PartitionSorter (implements java.util.Comparator<T>, java.io.Serializable)
  • com.linkedin.venice.pushmonitor.PartitionStatus (implements java.lang.Comparable<T>)
    • com.linkedin.venice.pushmonitor.ReadOnlyPartitionStatus
  • com.linkedin.venice.helix.PartitionStatusJSONSerializer.PartitionStatusSerializerMixin
  • com.linkedin.venice.helix.PartitionStatusJSONSerializer.ReplicaStatusSerializerMixin
  • com.linkedin.davinci.validation.PartitionTracker
  • com.linkedin.davinci.validation.PartitionTracker.TopicType
  • com.linkedin.venice.utils.PartitionUtils
  • com.linkedin.venice.router.throttle.PendingRequestThrottler
  • com.linkedin.venice.controller.init.PerClusterInternalRTStoreInitializationRoutine (implements com.linkedin.venice.controller.init.ClusterLeaderInitializationRoutine)
  • com.linkedin.venice.persona.Persona
    • com.linkedin.venice.persona.ReadPersona
    • com.linkedin.venice.persona.StoragePersona
  • com.linkedin.alpini.io.PigzOutputStream.Compressor (implements java.lang.Runnable)
    • com.linkedin.alpini.io.PigzDeflateCompressor
  • com.linkedin.venice.client.store.predicate.PredicateBuilder
  • com.linkedin.venice.authorization.Principal
  • java.lang.Process
    • com.linkedin.venice.utils.ForkedJavaProcess
  • com.linkedin.venice.producer.online.ProducerTool
  • com.linkedin.alpini.base.misc.PromiseDelegate<V> (implements io.netty.util.concurrent.Promise<V>)
  • com.linkedin.venice.utils.PropertyBuilder
  • com.linkedin.venice.pubsub.PubSubClientsFactory
  • com.linkedin.venice.pubsub.PubSubConstants
  • com.linkedin.venice.pubsub.PubSubConstantsOverrider
  • com.linkedin.venice.utils.PubSubHelper
  • com.linkedin.venice.utils.PubSubHelper.MutablePubSubMessage (implements com.linkedin.venice.pubsub.api.PubSubMessage<K,V,OFFSET>)
  • com.linkedin.venice.pubsub.api.PubSubMessageDeserializer
  • com.linkedin.venice.pubsub.api.PubSubMessageHeader (implements com.linkedin.venice.memory.Measurable)
  • com.linkedin.venice.pubsub.api.PubSubMessageHeaders (implements java.lang.Iterable<T>, com.linkedin.venice.memory.Measurable)
    • com.linkedin.venice.pubsub.api.EmptyPubSubMessageHeaders
  • com.linkedin.davinci.kafka.consumer.PubSubMessageProcessedResult
  • com.linkedin.davinci.kafka.consumer.PubSubMessageProcessedResultWrapper<K,V,OFFSET>
  • com.linkedin.venice.pubsub.PubSubPositionFactory
  • com.linkedin.venice.pubsub.PubSubPositionType
  • com.linkedin.venice.pubsub.api.PubSubProducerAdapterConcurrentDelegator (implements com.linkedin.venice.pubsub.api.PubSubProducerAdapter)
  • com.linkedin.venice.pubsub.api.PubSubProducerAdapterConcurrentDelegator.ProducerQueueDrainer (implements java.lang.Runnable)
  • com.linkedin.venice.pubsub.api.PubSubProducerAdapterConcurrentDelegator.ProducerQueueNode (implements com.linkedin.venice.memory.Measurable)
  • com.linkedin.venice.pubsub.api.PubSubProducerAdapterDelegator (implements com.linkedin.venice.pubsub.api.PubSubProducerAdapter)
  • com.linkedin.venice.pubsub.adapter.PubSubProducerCallbackSimpleImpl (implements com.linkedin.venice.pubsub.api.PubSubProducerCallback)
  • com.linkedin.venice.pubsub.PubSubTopicConfiguration
  • com.linkedin.venice.pubsub.PubSubTopicImpl (implements com.linkedin.venice.pubsub.api.PubSubTopic)
  • com.linkedin.venice.pubsub.PubSubTopicPartitionImpl (implements com.linkedin.venice.pubsub.api.PubSubTopicPartition)
  • com.linkedin.venice.pubsub.PubSubTopicPartitionInfo
  • com.linkedin.venice.unit.kafka.consumer.poll.PubSubTopicPartitionOffset
  • com.linkedin.venice.pubsub.PubSubTopicRepository
  • com.linkedin.venice.utils.PushInputSchemaBuilder
  • com.linkedin.venice.hadoop.PushJobSetting (implements java.io.Serializable)
  • com.linkedin.venice.hadoop.PushJobZstdConfig
  • com.linkedin.venice.pushmonitor.PushMonitorDelegator (implements com.linkedin.venice.pushmonitor.PushMonitor)
  • com.linkedin.venice.pushmonitor.PushMonitorUtils
  • com.linkedin.venice.pushmonitor.PushStatusCollector
  • com.linkedin.venice.pushmonitor.PushStatusDecider
    • com.linkedin.venice.pushmonitor.WaitAllPushStatusDecider
    • com.linkedin.venice.pushmonitor.WaitNMinusOnePushStatusDecider
  • com.linkedin.davinci.notifier.PushStatusNotifier (implements com.linkedin.davinci.notifier.VeniceNotifier)
  • com.linkedin.venice.pushstatushelper.PushStatusStoreReader (implements java.io.Closeable)
  • com.linkedin.venice.common.PushStatusStoreUtils
  • com.linkedin.venice.pushstatushelper.PushStatusStoreVeniceWriterCache (implements java.lang.AutoCloseable)
  • com.linkedin.venice.pushstatushelper.PushStatusStoreWriter (implements java.lang.AutoCloseable)
  • com.linkedin.venice.writer.PutMetadata
  • com.linkedin.alpini.base.queuing.QOSBasedRequestRunnable
  • com.linkedin.alpini.base.queuing.QOSFCFSQueue<T> (implements com.linkedin.alpini.base.queuing.SimpleQueue<T>)
  • com.linkedin.alpini.base.queuing.QOSPolicy.Config (implements com.linkedin.alpini.consts.config.ConfigBuilder<C>)
  • com.linkedin.alpini.base.queuing.QOSPolicy.StaticConfig
  • com.linkedin.venice.controllerapi.QueryParams
    • com.linkedin.venice.controllerapi.UpdateClusterConfigQueryParams
    • com.linkedin.venice.controllerapi.UpdateStoragePersonaQueryParams
    • com.linkedin.venice.controllerapi.UpdateStoreQueryParams
  • com.linkedin.alpini.base.misc.QueryStringDecoder
  • com.linkedin.venice.client.store.QueryTool
  • com.linkedin.alpini.netty4.misc.RandomEventExecutorChooserFactory (implements io.netty.util.concurrent.EventExecutorChooserFactory)
  • com.linkedin.venice.utils.RandomGenUtils
  • com.linkedin.venice.serialization.RawBytesStoreDeserializerCache (implements com.linkedin.venice.serialization.StoreDeserializerCache<T>)
  • com.linkedin.venice.chunking.RawKeyBytesAndChunkedKeySuffix
  • com.linkedin.venice.client.store.streaming.ReadEnvelopeChunkedDeserializer<V>
    • com.linkedin.venice.client.store.streaming.ComputeResponseRecordV1ChunkedDeserializer
    • com.linkedin.venice.client.store.streaming.MultiGetResponseRecordV1ChunkedDeserializer
  • com.linkedin.venice.client.store.streaming.ReadEnvelopeChunkedDeserializer.ValueContainer<V>
  • com.linkedin.venice.meta.ReadOnlyStore (implements com.linkedin.venice.meta.Store)
  • com.linkedin.venice.meta.ReadOnlyStore.ReadOnlyVersion (implements com.linkedin.venice.meta.Version)
  • com.linkedin.venice.meta.ReadOnlyViewConfig (implements com.linkedin.venice.meta.ViewConfig)
  • com.linkedin.venice.router.throttle.ReadRequestThrottler (implements com.linkedin.venice.meta.RoutersClusterManager.RouterCountChangedListener, com.linkedin.venice.router.throttle.RouterThrottler, com.linkedin.venice.meta.StoreDataChangedListener)
  • com.linkedin.venice.ingestion.control.RealTimeTopicSwitcher
  • com.linkedin.davinci.consumer.RecordChangeEventReadOnlySchemaRepository (implements com.linkedin.venice.meta.ReadOnlySchemaRepository)
  • com.linkedin.venice.RecoverStoreMetadata
  • com.linkedin.venice.utils.RedundantExceptionFilter
  • java.util.concurrent.locks.ReentrantReadWriteLock (implements java.util.concurrent.locks.ReadWriteLock, java.io.Serializable)
    • com.linkedin.venice.utils.concurrent.VeniceReentrantReadWriteLock
  • com.linkedin.venice.utils.ReferenceCounted<T> (implements java.lang.AutoCloseable)
  • com.linkedin.venice.utils.ReflectUtils
  • com.linkedin.davinci.kafka.consumer.RegionNameUtil
  • com.linkedin.venice.meta.RegionPushDetails
  • com.linkedin.venice.utils.RegionUtils
  • com.linkedin.davinci.notifier.RelayNotifier (implements com.linkedin.davinci.notifier.VeniceNotifier)
  • com.linkedin.venice.helix.Replica
  • com.linkedin.venice.meta.ReplicaDetail
  • com.linkedin.davinci.kafka.consumer.ReplicaHeartbeatInfo
  • com.linkedin.davinci.listener.response.ReplicaIngestionResponse
  • com.linkedin.venice.routerapi.ReplicaState
  • com.linkedin.venice.pushmonitor.ReplicaStatus
  • com.linkedin.davinci.consumer.ReplicationMetadataSchemaRepository
  • com.linkedin.venice.hadoop.mapreduce.datawriter.task.ReporterBackedMapReduceDataWriterTaskTracker (implements com.linkedin.venice.hadoop.task.datawriter.DataWriterTaskTracker)
  • com.linkedin.venice.controllerapi.RepushInfo
  • com.linkedin.venice.datarecovery.meta.RepushViabilityInfo
  • com.linkedin.venice.RequestConstants
  • com.linkedin.venice.fastclient.RequestContext
    • com.linkedin.venice.fastclient.GetRequestContext
    • com.linkedin.venice.fastclient.MultiKeyRequestContext<K,V>
      • com.linkedin.venice.fastclient.BatchGetRequestContext<K,V>
      • com.linkedin.venice.fastclient.ComputeRequestContext<K,V>
  • com.linkedin.venice.read.RequestHeadersProvider
  • com.linkedin.venice.request.RequestHelper
  • com.linkedin.venice.authorization.Resource
  • com.linkedin.venice.helix.ResourceAssignment
  • com.linkedin.venice.helix.ResourceAssignment.ResourceAssignmentChanges
  • com.linkedin.venice.utils.locks.ResourceAutoClosableLockManager<T>
  • com.linkedin.alpini.base.registry.ResourceRegistry
    • com.linkedin.alpini.base.registry.SyncResourceRegistry (implements com.linkedin.alpini.base.registry.ResourceRegistry.Sync, com.linkedin.alpini.base.registry.ShutdownableResource)
  • com.linkedin.alpini.base.test.ResourceRegistryTestBase
  • com.linkedin.venice.listener.response.stats.ResponseStatsUtil
  • com.linkedin.alpini.base.misc.RetryCounter
  • com.linkedin.alpini.base.misc.RetryCountSlidingWindow
  • com.linkedin.venice.meta.RetryManager
  • com.linkedin.venice.utils.RetryUtils
  • com.linkedin.venice.schema.rmd.RmdConstants
  • com.linkedin.davinci.consumer.RmdDeserializerCache<T> (implements com.linkedin.venice.serialization.StoreDeserializerCache<T>)
  • com.linkedin.venice.schema.rmd.RmdSchemaGenerator
  • com.linkedin.venice.schema.rmd.v1.RmdSchemaGeneratorV1
  • com.linkedin.davinci.replication.merge.RmdSerDe
  • com.linkedin.venice.schema.rmd.RmdUtils
  • com.linkedin.venice.schema.rmd.RmdVersionId
  • com.linkedin.davinci.replication.RmdWithValueSchemaId
  • com.linkedin.davinci.store.rocksdb.RocksDBServerConfig
  • com.linkedin.davinci.store.rocksdb.RocksDBSstFileWriter
  • com.linkedin.davinci.store.rocksdb.RocksDBThrottler
  • com.linkedin.venice.store.rocksdb.RocksDBUtils
  • com.linkedin.venice.router.stats.RouteHttpRequestStats
  • com.linkedin.venice.router.stats.RouteHttpStats
  • com.linkedin.alpini.router.impl.netty4.Router4<C> (implements com.linkedin.alpini.router.impl.Router.Builder, com.linkedin.alpini.router.impl.Router.PipelineFactory<CHANNEL_HANDLER>)
  • com.linkedin.alpini.router.impl.netty4.Router4Impl<C> (implements com.linkedin.alpini.base.registry.ResourceRegistry.Sync, com.linkedin.alpini.router.impl.Router)
  • com.linkedin.venice.client.schema.RouterBackedSchemaReader (implements com.linkedin.venice.schema.SchemaReader)
  • com.linkedin.venice.pushmonitor.RouterBasedHybridStoreQuotaMonitor (implements java.io.Closeable)
  • com.linkedin.venice.pushmonitor.RouterBasedHybridStoreQuotaMonitor.HybridQuotaMonitorTask (implements java.io.Closeable, java.lang.Runnable)
  • com.linkedin.venice.pushmonitor.RouterBasedPushMonitor (implements java.io.Closeable)
  • com.linkedin.venice.client.schema.RouterBasedStoreSchemaFetcher (implements com.linkedin.venice.client.schema.StoreSchemaFetcher)
  • com.linkedin.venice.router.api.RouterExceptionAndTrackingUtils
  • com.linkedin.venice.router.api.RouterKey (implements java.lang.Comparable<T>)
  • com.linkedin.venice.listener.request.RouterRequest
    • com.linkedin.venice.listener.request.GetRouterRequest
    • com.linkedin.venice.listener.request.MultiKeyRouterRequestWrapper<K>
      • com.linkedin.venice.listener.request.ComputeRouterRequestWrapper
      • com.linkedin.venice.listener.request.MultiGetRouterRequestWrapper
  • com.linkedin.venice.meta.RoutersClusterConfig
  • com.linkedin.venice.router.stats.RouterStats<STAT_TYPE>
  • com.linkedin.venice.spark.utils.RowToAvroConverter
  • com.linkedin.alpini.base.concurrency.RunOnce (implements java.lang.Runnable)
  • com.linkedin.alpini.base.safealloc.SafeAllocatorMetric (implements io.netty.buffer.ByteBufAllocatorMetric)
  • com.linkedin.venice.helix.SafeHelixDataAccessor
  • com.linkedin.venice.helix.SafeHelixManager
  • com.linkedin.alpini.router.api.Scatter<H,P,K>
  • com.linkedin.alpini.router.api.ScatterGatherHelper<H,P,K,R,BASIC_HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>
  • com.linkedin.alpini.router.api.ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>
  • com.linkedin.alpini.router.api.ScatterGatherMode
    • com.linkedin.venice.router.api.VeniceDelegateMode
  • com.linkedin.alpini.router.api.ScatterGatherRequest<H,K>
    • com.linkedin.alpini.router.api.BroadcastScatterGatherRequest<H,K>
  • com.linkedin.alpini.router.ScatterGatherRequestHandler<H,P,K,R>
    • com.linkedin.alpini.router.ScatterGatherRequestHandlerImpl<H,P,K,R,CHC,BHS,HR,HRS,SCATTER_GATHER_HELPER>
      • com.linkedin.alpini.router.ScatterGatherRequestHandler4<H,P,K,R> (implements com.linkedin.alpini.netty4.handlers.AsyncFullHttpRequestHandler.RequestHandler)
  • com.linkedin.alpini.router.monitoring.ScatterGatherStats (implements com.linkedin.alpini.router.monitoring.ScatterGatherStatsMBean)
  • com.linkedin.alpini.router.monitoring.ScatterGatherStats.Delta
  • com.linkedin.venice.client.schema.SchemaAndToString
  • com.linkedin.venice.schema.avro.SchemaCompatibility
  • com.linkedin.venice.schema.avro.SchemaCompatibility.SchemaPairCompatibility
  • com.linkedin.venice.schema.SchemaData
  • com.linkedin.venice.schema.SchemaEntry
    • com.linkedin.venice.schema.GeneratedSchemaEntry
      • com.linkedin.venice.schema.writecompute.DerivedSchemaEntry
      • com.linkedin.venice.schema.rmd.RmdSchemaEntry
  • com.linkedin.venice.helix.SchemaEntrySerializer (implements com.linkedin.venice.meta.VeniceSerializer<T>)
  • com.linkedin.venice.serialization.avro.SchemaPresenceChecker
  • com.linkedin.venice.schema.SchemaRepoBackedSchemaReader (implements com.linkedin.venice.schema.SchemaReader)
  • com.linkedin.davinci.schema.SchemaUtils
  • com.linkedin.venice.kafka.validation.Segment
  • com.linkedin.venice.meta.SerializableSystemStore
  • com.linkedin.venice.serializer.SerializerDeserializerFactory
    • com.linkedin.venice.serializer.FastSerializerDeserializerFactory
    • com.linkedin.davinci.serializer.avro.MapOrderPreservingSerDeFactory
  • com.linkedin.venice.serializer.SerializerDeserializerFactory.SchemaPairAndClassContainer
  • com.linkedin.venice.blobtransfer.ServerBlobFinder (implements com.linkedin.venice.blobtransfer.BlobFinder)
  • com.linkedin.davinci.listener.response.ServerCurrentVersionResponse
  • com.linkedin.venice.listener.ServerHandlerUtils
  • com.linkedin.venice.listener.ServerReadMetadataRepository (implements com.linkedin.davinci.storage.ReadMetadataRetriever)
  • com.linkedin.venice.listener.ServerStatsContext
  • com.linkedin.venice.servicediscovery.ServiceDiscoveryAnnouncerRetryTask (implements java.lang.Runnable)
  • com.linkedin.venice.controller.init.SharedInternalRTStoreInitializationRoutine (implements com.linkedin.venice.controller.init.ClusterLeaderInitializationRoutine)
  • com.linkedin.venice.pubsub.adapter.kafka.producer.SharedKafkaProducerConfig
  • com.linkedin.venice.utils.SharedObjectFactory<T>
  • com.linkedin.alpini.netty4.misc.ShutdownableEventLoopGroup<E> (implements io.netty.channel.EventLoopGroup, com.linkedin.alpini.base.registry.Shutdownable)
  • com.linkedin.alpini.netty4.pool.SimpleChannelPoolManagerImpl (implements com.linkedin.alpini.netty4.pool.ChannelPoolManager)
  • com.linkedin.venice.pubsub.adapter.SimplePubSubProduceResultImpl (implements com.linkedin.venice.pubsub.api.PubSubProduceResult)
    • com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProduceResult
  • com.linkedin.venice.meta.SimpleStringSerializer (implements com.linkedin.venice.meta.VeniceSerializer<T>)
  • com.linkedin.davinci.storage.chunking.SingleGetChunkingAdapter (implements com.linkedin.davinci.storage.chunking.ChunkingAdapter<CHUNKS_CONTAINER,VALUE>)
  • com.linkedin.alpini.base.misc.SlowFieldAccessor<T,V> (implements com.linkedin.alpini.base.misc.TypedFieldAccessor<T,V>)
  • com.linkedin.alpini.base.misc.SoftThreadLocal<T> (implements java.util.function.Supplier<T>)
  • com.linkedin.venice.spark.SparkConstants
  • com.linkedin.venice.spark.datawriter.task.SparkDataWriterTaskTracker (implements com.linkedin.venice.hadoop.task.datawriter.DataWriterTaskTracker)
  • com.linkedin.venice.spark.engine.SparkEngineTaskConfigProvider (implements com.linkedin.venice.hadoop.engine.EngineTaskConfigProvider)
  • com.linkedin.venice.spark.datawriter.recordprocessor.SparkInputRecordProcessorFactory (implements org.apache.spark.api.java.function.FlatMapFunction<T,R>)
  • com.linkedin.venice.spark.utils.SparkPartitionUtils
  • com.linkedin.venice.spark.datawriter.writer.SparkPartitionWriterFactory (implements org.apache.spark.api.java.function.MapPartitionsFunction<T,U>)
  • com.linkedin.venice.spark.utils.SparkScalaUtils
  • org.apache.avro.specific.SpecificFixed (implements java.lang.Comparable<T>, java.io.Externalizable, org.apache.avro.generic.GenericFixed)
    • com.linkedin.venice.kafka.protocol.GUID
  • org.apache.avro.specific.SpecificRecordBase (implements java.lang.Comparable<T>, java.io.Externalizable, org.apache.avro.generic.GenericRecord, org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.AbortMigration (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.AddVersion (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.admin.protocol.response.AdminResponseRecord (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.status.protocol.BatchJobHeartbeatKey (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.status.protocol.BatchJobHeartbeatValue (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.storage.protocol.ChunkedKeySuffix (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.storage.protocol.ChunkedValueManifest (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.storage.protocol.ChunkId (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.compute.protocol.request.ComputeOperation (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.compute.protocol.request.ComputeRequest (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.compute.protocol.request.ComputeRequestV1 (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.compute.protocol.request.ComputeRequestV2 (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.compute.protocol.request.ComputeRequestV3 (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.compute.protocol.request.ComputeRequestV4 (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.compute.protocol.response.ComputeResponseRecordV1 (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.compute.protocol.request.router.ComputeRouterRequestKeyV1 (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.ConfigureActiveActiveReplicationForCluster (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.ConfigureIncrementalPushForCluster (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.ConfigureNativeReplicationForCluster (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.admin.protocol.response.ConsumptionStateSnapshot (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.ControlMessage (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.compute.protocol.request.CosineSimilarity (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.compute.protocol.request.Count (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.CreateStoragePersona (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.meta.systemstore.schemas.CurrentStoreStates (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.meta.systemstore.schemas.CurrentVersionStates (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.DataRecoveryConfig (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.Delete (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.DeleteAllVersions (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.DeleteOldVersion (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.DeleteStoragePersona (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.DeleteStore (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.DeleteUnusedValueSchemas (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.DerivedSchemaCreation (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.DisableStoreRead (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.compute.protocol.request.DotProduct (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.EnableStoreRead (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.EndOfIncrementalPush (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.EndOfPush (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.EndOfSegment (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.meta.systemstore.schemas.ETLStoreConfig (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.ETLStoreConfigRecord (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.compression.protocol.FakeCompressingSchema (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.compute.protocol.request.HadamardProduct (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.meta.systemstore.schemas.HybridStoreConfig (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.HybridStoreConfigRecord (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.state.IncrementalPush (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.ingestion.protocol.IngestionMetricsReport (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.ingestion.protocol.IngestionStorageMetadata (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.ingestion.protocol.IngestionTaskCommand (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.ingestion.protocol.IngestionTaskReport (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.hadoop.input.kafka.avro.KafkaInputMapperKey (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.hadoop.input.kafka.avro.KafkaInputMapperValue (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.KafkaMessageEnvelope (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.KillOfflinePushJob (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.participant.protocol.KillPushJob (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.LeaderMetadata (implements org.apache.avro.specific.SpecificRecord)
      • com.linkedin.venice.writer.VeniceWriter.DefaultLeaderMetadata
    • com.linkedin.venice.ingestion.protocol.LoadedStoreUserPartitionMapping (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.metadata.response.MetadataResponseRecord (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.MetadataSchemaCreation (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.MetaSystemStoreAutoCreationValidation (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.MigrateStore (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.read.protocol.response.MultiGetResponseRecordV1 (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.read.protocol.request.router.MultiGetRouterRequestKeyV1 (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.participant.protocol.ParticipantMessageKey (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.participant.protocol.ParticipantMessageValue (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.meta.systemstore.schemas.PartitionerConfig (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.PartitionerConfigRecord (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.state.PartitionState (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.PauseStore (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.ingestion.protocol.ProcessShutdownCommand (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.ProducerMetadata (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.state.ProducerPartitionState (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.pubsub.api.PubSubPositionWireFormat (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.status.protocol.PushJobDetails (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.status.protocol.PushJobDetailsStatusTuple (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.status.protocol.PushJobStatusRecordKey (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.pushstatus.PushStatusKey (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.PushStatusSystemStoreAutoCreationValidation (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.pushstatus.PushStatusValue (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.Put (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.client.change.capture.protocol.RecordChangeEvent (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.ResumeStore (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.RollbackCurrentVersion (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.RollForwardCurrentVersion (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.SchemaMeta (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.admin.protocol.response.ServerConfigSnapshot (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.SetStoreCurrentVersion (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.SetStoreOwner (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.SetStorePartitionCount (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.StartOfBufferReplay (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.StartOfIncrementalPush (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.StartOfPush (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.StartOfSegment (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.meta.systemstore.schemas.StoreAttributes (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.StoreClusterConfig (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.StoreCreation (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.StoreETLConfig (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.StoreHybridConfig (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.meta.systemstore.schemas.StoreKeySchemas (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.StoreKeySchemas (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.meta.systemstore.schemas.StoreMetadataKey (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.meta.systemstore.schemas.StoreMetadataValue (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.StoreMetaKey (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.StoreMetaValue (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.StorePartitionerConfig (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.meta.systemstore.schemas.StoreProperties (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.StoreProperties (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.StoreReplicaStatus (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.StoreValueSchema (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.meta.systemstore.schemas.StoreValueSchemas (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.StoreValueSchemas (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.StoreVersion (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.state.StoreVersionState (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.meta.systemstore.schemas.StoreVersionState (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.StoreViewConfig (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.StoreViewConfigRecord (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.read.protocol.response.streaming.StreamingFooterRecordV1 (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.SupersetSchemaCreation (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.systemstore.schemas.SystemStoreProperties (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.meta.systemstore.schemas.TargetVersionStates (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.client.store.schemas.TestKeyRecord (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.client.store.schemas.TestValueRecord (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.client.store.schemas.TestValueRecordWithMoreFields (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.TopicSwitch (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.Update (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.UpdateStoragePersona (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.hadoop.output.avro.ValidateSchemaAndBuildDictMapperOutput (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.client.change.capture.protocol.ValueBytes (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.controller.kafka.protocol.admin.ValueSchemaCreation (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.etl.VeniceKafkaDecodedRecord (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.metadata.response.VersionProperties (implements org.apache.avro.specific.SpecificRecord)
    • com.linkedin.venice.kafka.protocol.VersionSwap (implements org.apache.avro.specific.SpecificRecord)
  • com.linkedin.venice.security.SSLConfig
  • com.linkedin.venice.SSLConfig
  • com.linkedin.venice.security.SSLConfig.ConfigHelper
  • com.linkedin.alpini.io.ssl.SSLContextBuilder
  • com.linkedin.alpini.netty4.http2.SSLContextBuilder
  • com.linkedin.alpini.netty4.ssl.SSLEngineFactoryImpl (implements com.linkedin.alpini.netty4.ssl.SSLEngineFactory)
  • com.linkedin.alpini.netty4.ssl.SSLEngineFactoryImpl.Config
  • com.linkedin.venice.utils.SslUtils
  • com.linkedin.venice.utils.SslUtils.VeniceTlsConfiguration
  • com.linkedin.venice.utils.SslUtils.VeniceTlsConfiguration.Builder
  • org.apache.helix.participant.statemachine.StateModel
    • com.linkedin.davinci.helix.AbstractPartitionStateModel
      • com.linkedin.davinci.helix.LeaderFollowerPartitionStateModel
    • com.linkedin.venice.utils.MockTestStateModelFactory.OnlineOfflineStateModel
    • com.linkedin.venice.controller.VeniceControllerStateModel
  • org.apache.helix.participant.statemachine.StateModelFactory<T>
    • com.linkedin.davinci.helix.AbstractStateModelFactory
      • com.linkedin.davinci.helix.LeaderFollowerPartitionStateModelFactory
        • com.linkedin.davinci.helix.LeaderFollowerPartitionStateModelDualPoolFactory
    • com.linkedin.venice.utils.MockTestStateModelFactory
    • com.linkedin.venice.controller.VeniceDistClusterControllerStateModelFactory
  • com.linkedin.davinci.helix.StateModelIngestionProgressNotifier (implements com.linkedin.davinci.notifier.VeniceNotifier)
    • com.linkedin.davinci.helix.LeaderFollowerIngestionProgressNotifier
  • com.linkedin.venice.meta.StaticClusterInfoProvider (implements com.linkedin.venice.meta.ClusterInfoProvider)
  • com.linkedin.venice.stats.StatsUtils
  • com.linkedin.venice.status.StatusMessage
    • com.linkedin.venice.pushmonitor.KillOfflinePushMessage
    • com.linkedin.venice.status.StoreStatusMessage
  • com.linkedin.venice.pushmonitor.StatusSnapshot
  • com.linkedin.alpini.netty4.misc.StickyEventExecutorChooserFactory (implements io.netty.util.concurrent.EventExecutorChooserFactory)
  • com.linkedin.davinci.store.StorageEngineFactory
    • com.linkedin.davinci.store.blackhole.BlackHoleStorageEngineFactory
    • com.linkedin.davinci.store.memory.InMemoryStorageEngineFactory
    • com.linkedin.davinci.store.rocksdb.RocksDBStorageEngineFactory
  • com.linkedin.davinci.storage.StorageEngineRepository
  • com.linkedin.venice.controller.StorageNodeStatus
  • com.linkedin.davinci.store.StoragePartitionConfig
  • com.linkedin.davinci.utils.StoragePartitionDiskUsage
  • com.linkedin.venice.persona.StoragePersonaAccessor
  • com.linkedin.venice.persona.StoragePersonaJSONSerializer.StoragePersonaSerializerMixin
  • com.linkedin.venice.helix.StoragePersonaRepository
  • com.linkedin.venice.helix.StoragePersonaRepository.StoragePersonaStoreDataListener (implements com.linkedin.venice.meta.StoreDataChangedListener)
  • com.linkedin.davinci.kafka.consumer.StorageUtilizationManager (implements com.linkedin.venice.meta.StoreDataChangedListener)
  • com.linkedin.davinci.StoreBackend
  • com.linkedin.davinci.config.StoreBackendConfig
  • com.linkedin.venice.client.utils.StoreClientTestUtils
  • com.linkedin.venice.controllerapi.StoreComparisonInfo
  • com.linkedin.venice.meta.StoreConfig (implements com.linkedin.venice.meta.DataModelBackedStructure<T>)
  • com.linkedin.venice.helix.StoreConfigJsonSerializer.StoreConfigSerializerMixin
  • com.linkedin.venice.meta.StoreDataAudit
  • com.linkedin.venice.meta.StoreInfo
  • com.linkedin.davinci.kafka.consumer.StoreIngestionTask (implements java.io.Closeable, java.lang.Runnable)
    • com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask
      • com.linkedin.davinci.kafka.consumer.ActiveActiveStoreIngestionTask
  • com.linkedin.davinci.kafka.consumer.StoreIngestionTaskFactory
  • com.linkedin.davinci.kafka.consumer.StoreIngestionTaskFactory.Builder
  • com.linkedin.venice.helix.StoreJSONSerializer.ETLStoreConfigSerializerMixin
  • com.linkedin.venice.helix.StoreJSONSerializer.HybridStoreConfigSerializerMixin
  • com.linkedin.venice.helix.StoreJSONSerializer.PartitionerConfigSerializerMixin
  • com.linkedin.venice.helix.StoreJSONSerializer.StoreSerializerMixin
  • com.linkedin.venice.helix.StoreJSONSerializer.VersionSerializerMixin
  • com.linkedin.venice.helix.StoreJSONSerializer.ViewConfigSerializerMixin
  • com.linkedin.venice.hooks.StoreLifecycleHooks
  • com.linkedin.davinci.kafka.consumer.StorePartitionDataReceiver (implements com.linkedin.davinci.ingestion.consumption.ConsumedDataReceiver<MESSAGE>)
  • com.linkedin.venice.datarecovery.StoreRepushCommand.Params.Builder
  • com.linkedin.venice.store.StoreStateReader (implements java.io.Closeable)
  • com.linkedin.venice.controller.kafka.StoreStatusDecider
  • com.linkedin.venice.utils.StoreUtils
  • com.linkedin.venice.controller.StoreViewUtils
  • com.linkedin.davinci.kafka.consumer.StoreWriteComputeProcessor
  • com.linkedin.venice.streaming.StreamingConstants
  • com.linkedin.venice.client.store.streaming.StreamingResponseTracker
  • com.linkedin.venice.streaming.StreamingUtils
  • com.linkedin.davinci.replication.merge.StringAnnotatedStoreSchemaCache
  • com.linkedin.venice.serialization.StringSerializer (implements com.linkedin.venice.serialization.VeniceKafkaSerializer<T>)
  • com.linkedin.alpini.base.concurrency.StripedAccumulator<A>
    • com.linkedin.alpini.base.concurrency.ComplexAccumulator<T,A,R> (implements java.util.function.Consumer<T>, java.util.function.Supplier<T>)
  • com.linkedin.alpini.io.SubprocessBuilder
  • com.linkedin.venice.controller.supersetschema.SupersetSchemaGeneratorWithCustomProp (implements com.linkedin.venice.controller.supersetschema.SupersetSchemaGenerator)
  • com.linkedin.venice.controller.init.SystemSchemaInitializationRoutine (implements com.linkedin.venice.controller.init.ClusterLeaderInitializationRoutine)
  • com.linkedin.venice.controller.authorization.SystemStoreAclSynchronizationTask (implements java.io.Closeable, java.lang.Runnable)
  • com.linkedin.venice.meta.SystemStoreAttributesImpl (implements com.linkedin.venice.meta.SystemStoreAttributes)
  • com.linkedin.venice.controller.init.SystemStoreInitializationHelper
  • com.linkedin.venice.helix.SystemStoreJSONSerializer.SystemStoreSerializerMixin
  • com.linkedin.venice.controller.systemstore.SystemStoreRepairTask (implements java.lang.Runnable)
  • com.linkedin.venice.utils.SystemTime (implements com.linkedin.venice.utils.Time)
  • com.linkedin.venice.stats.TehutiUtils
  • com.linkedin.venice.hadoop.ssl.TempFileSSLConfigurator (implements com.linkedin.venice.hadoop.ssl.SSLConfigurator)
  • com.linkedin.venice.controller.TerminalStateTopicCheckerForParentController (implements java.io.Closeable, java.lang.Runnable)
  • org.testng.TestListenerAdapter (implements org.testng.internal.IResultListener2)
    • com.linkedin.venice.testng.VeniceTestListener
  • com.linkedin.venice.utils.TestMockTime (implements com.linkedin.venice.utils.Time, io.tehuti.utils.Time)
  • com.linkedin.venice.utils.TestStoragePersonaUtils
  • com.linkedin.venice.utils.TestUtils
  • com.linkedin.venice.utils.TestWriteUtils
  • java.lang.Thread (implements java.lang.Runnable)
    • com.linkedin.davinci.consumer.VeniceChangelogConsumerImpl.HeartbeatReporterThread
  • com.linkedin.alpini.base.concurrency.ThreadedAccumulator<T,A,R> (implements java.util.function.Consumer<T>, java.util.function.Supplier<T>)
  • com.linkedin.venice.utils.concurrent.ThreadPoolFactory
  • com.linkedin.alpini.jna.ThreadUtils
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • com.linkedin.venice.acl.AclException
      • com.linkedin.alpini.base.misc.ExceptionWithStatus
        • com.linkedin.alpini.netty4.misc.ExceptionWithResponseStatus
        • com.linkedin.alpini.router.api.RouterException
          • com.linkedin.alpini.router.api.Netty4RouterException
      • com.linkedin.alpini.base.misc.Http2TooManyStreamsException
      • com.linkedin.alpini.consts.config.InvalidConfigException
      • java.io.IOException
        • com.linkedin.alpini.netty4.ssl.FusedSslHandler.OverflowException
      • com.linkedin.venice.client.store.streaming.ReadEnvelopeChunkedDeserializer.NotEnoughBytesException
      • java.lang.RuntimeException
        • io.netty.handler.codec.CodecException
          • io.netty.handler.codec.EncoderException
            • com.linkedin.alpini.netty4.handlers.BasicHttpServerCodec.ResponseOutOfSequence
        • java.lang.IllegalArgumentException
          • com.linkedin.venice.security.SSLConfig.ConfigHelper.MissingConfigParameterException
        • java.lang.IllegalStateException
          • java.util.concurrent.CancellationException
            • com.linkedin.alpini.base.pool.impl.AsyncPoolImpl.ShutdownException
            • com.linkedin.alpini.base.pool.impl.AsyncPoolImpl.TooManyWaitersException
        • com.linkedin.venice.exceptions.VeniceException
          • com.linkedin.venice.exceptions.ConcurrentBatchPushException
          • com.linkedin.venice.exceptions.ConfigurationException
            • com.linkedin.venice.exceptions.UndefinedPropertyException
          • com.linkedin.venice.exceptions.DiskLimitExhaustedException
          • com.linkedin.venice.ingestion.control.DuplicateTopicException
          • com.linkedin.venice.controller.exception.HelixClusterMaintenanceModeException
          • com.linkedin.venice.store.exception.InvalidDatabaseNameException
          • com.linkedin.venice.exceptions.InvalidVeniceSchemaException
          • com.linkedin.venice.exceptions.KafkaConsumerException
            • com.linkedin.venice.exceptions.validation.DataValidationException
              • com.linkedin.venice.exceptions.validation.DuplicateDataException
              • com.linkedin.venice.exceptions.validation.FatalDataValidationException
                • com.linkedin.venice.exceptions.validation.CorruptDataException
                  • com.linkedin.venice.exceptions.validation.UnsupportedMessageTypeException
                • com.linkedin.venice.exceptions.validation.IncomingDataAfterSegmentEndedException
                • com.linkedin.venice.exceptions.validation.MissingDataException
                  • com.linkedin.venice.exceptions.validation.ImproperlyStartedSegmentException
          • com.linkedin.venice.exceptions.MemoryLimitExhaustedException
          • com.linkedin.venice.exceptions.MissingKeyInStoreMetadataException
          • com.linkedin.venice.exceptions.PartitionerSchemaMismatchException
          • com.linkedin.venice.exceptions.PersistenceFailureException
          • com.linkedin.venice.pubsub.api.exceptions.PubSubClientException
            • com.linkedin.venice.pubsub.api.exceptions.PubSubTopicAuthorizationException
            • com.linkedin.venice.pubsub.api.exceptions.PubSubTopicExistsException
            • com.linkedin.venice.pubsub.api.exceptions.PubSubUnsubscribedTopicPartitionException
          • com.linkedin.venice.exceptions.QuotaExceededException
          • com.linkedin.venice.exceptions.RecordTooLargeException
          • com.linkedin.venice.exceptions.ResourceStillExistsException
          • com.linkedin.venice.exceptions.SchemaDuplicateException
          • com.linkedin.venice.exceptions.SchemaIncompatibilityException
          • com.linkedin.davinci.store.StorageEngineInitializationException
          • com.linkedin.venice.exceptions.StorageInitializationException
          • com.linkedin.davinci.store.StoragePartitionInitializationException
          • com.linkedin.venice.exceptions.StoreDisabledException
          • com.linkedin.venice.exceptions.StoreKeySchemaExistException
          • com.linkedin.venice.exceptions.VeniceAclException
          • com.linkedin.venice.exceptions.VeniceBlobTransferFileNotFoundException
          • com.linkedin.venice.exceptions.VeniceChecksumException
          • com.linkedin.venice.client.exceptions.VeniceClientException
            • com.linkedin.davinci.client.NonLocalAccessException
            • com.linkedin.venice.client.exceptions.ServiceDiscoveryException
            • com.linkedin.venice.client.exceptions.VeniceClientHttpException
              • com.linkedin.venice.client.exceptions.VeniceClientRateExceededException
          • com.linkedin.davinci.consumer.VeniceCoordinateOutOfRangeException
          • com.linkedin.venice.exceptions.VeniceHttpException
            • com.linkedin.venice.exceptions.OperationNotAllowedException
          • com.linkedin.venice.hadoop.exceptions.VeniceInconsistentSchemaException
          • com.linkedin.venice.exceptions.VeniceInconsistentStoreMetadataException
          • com.linkedin.venice.exceptions.VeniceIngestionTaskKilledException
          • com.linkedin.venice.router.exception.VeniceKeyCountLimitException
          • com.linkedin.venice.exceptions.VeniceMessageException
          • com.linkedin.venice.exceptions.VeniceNoClusterException
          • com.linkedin.venice.exceptions.VeniceNoStoreException
            • com.linkedin.venice.exceptions.StoreVersionNotFoundException
          • com.linkedin.venice.exceptions.VenicePeersConnectionException
          • com.linkedin.venice.exceptions.VenicePeersNotFoundException
          • com.linkedin.venice.listener.VeniceRequestEarlyTerminationException
          • com.linkedin.venice.exceptions.VeniceResourceAccessException
          • com.linkedin.venice.exceptions.VeniceRetriableException
            • com.linkedin.venice.pubsub.api.exceptions.PubSubClientRetriableException
              • com.linkedin.venice.pubsub.api.exceptions.PubSubOpTimeoutException
              • com.linkedin.venice.pubsub.api.exceptions.PubSubTopicDoesNotExistException
            • com.linkedin.venice.exceptions.VeniceTimeoutException
          • com.linkedin.venice.exceptions.VeniceRouterException
            • com.linkedin.venice.exceptions.VeniceNoHelixResourceException
          • com.linkedin.venice.hadoop.exceptions.VeniceSchemaFieldNotFoundException
          • com.linkedin.venice.serializer.VeniceSerializationException
          • com.linkedin.venice.exceptions.VeniceStoreAlreadyExistsException
          • com.linkedin.venice.hadoop.exceptions.VeniceStoreCreationException
          • com.linkedin.venice.exceptions.VeniceStoreIsMigratedException
          • com.linkedin.venice.exceptions.VeniceUnsupportedOperationException
          • com.linkedin.venice.hadoop.exceptions.VeniceValidationException
          • com.linkedin.venice.serializer.VsonSerializationException
          • com.linkedin.davinci.schema.writecompute.WriteComputeSchemaValidator.InvalidWriteComputeException
          • com.linkedin.venice.exceptions.ZkDataAccessException
  • com.linkedin.alpini.base.concurrency.TimeoutProcessor (implements java.util.concurrent.Executor)
  • com.linkedin.alpini.router.impl.netty4.TimerTimeoutProcessor (implements com.linkedin.alpini.router.api.RouterTimeoutProcessor)
  • com.linkedin.alpini.base.misc.TimeValue (implements java.lang.Cloneable, java.lang.Comparable<T>)
  • com.linkedin.venice.throttle.TokenBucket (implements com.linkedin.venice.throttle.VeniceRateLimiter)
  • com.linkedin.venice.pubsub.manager.TopicManager (implements java.io.Closeable)
  • com.linkedin.venice.pubsub.manager.TopicManagerContext
  • com.linkedin.venice.pubsub.manager.TopicManagerContext.Builder
  • com.linkedin.venice.pubsub.manager.TopicManagerRepository (implements java.io.Closeable)
  • com.linkedin.venice.TopicMessageFinder
  • com.linkedin.davinci.kafka.consumer.TopicPartitionForIngestion
  • com.linkedin.venice.listener.request.TopicPartitionIngestionContextRequest
  • com.linkedin.davinci.kafka.consumer.TopicPartitionIngestionInfo
  • com.linkedin.venice.pubsub.adapter.kafka.TopicPartitionsOffsetsTracker
  • com.linkedin.davinci.kafka.consumer.TopicSwitchWrapper
  • com.linkedin.alpini.base.misc.TouchTimer (implements org.apache.logging.log4j.util.StringBuilderFormattable)
  • com.linkedin.venice.unit.kafka.producer.TransformingProducerAdapter (implements com.linkedin.venice.pubsub.api.PubSubProducerAdapter)
  • com.linkedin.venice.unit.kafka.producer.TransformingProducerAdapter.SendMessageParameters
  • com.linkedin.venice.client.store.transport.TransportClient (implements java.io.Closeable)
    • com.linkedin.venice.client.store.transport.D2TransportClient
    • com.linkedin.venice.client.store.transport.HttpTransportClient
      • com.linkedin.venice.client.store.transport.HttpsTransportClient
    • com.linkedin.venice.fastclient.transport.InternalTransportClient
      • com.linkedin.venice.fastclient.transport.GrpcTransportClient
      • com.linkedin.venice.fastclient.transport.R2TransportClient
  • com.linkedin.venice.client.store.transport.TransportClientCallback
    • com.linkedin.venice.fastclient.transport.R2TransportClient.R2TransportClientCallback (implements com.linkedin.common.callback.Callback<T>)
  • com.linkedin.venice.client.store.transport.TransportClientResponse
    • com.linkedin.venice.fastclient.transport.TransportClientResponseForRoute
  • com.linkedin.venice.utils.TrieBasedPathResourceRegistry<T> (implements com.linkedin.venice.utils.PathResourceRegistry<T>)
  • com.linkedin.alpini.base.misc.TypedFieldAccessorHelper
    • com.linkedin.alpini.base.misc.SlowFieldAccessorHelper
  • com.linkedin.venice.meta.UncompletedPartition
  • com.linkedin.venice.meta.UncompletedReplica
  • com.linkedin.venice.serializer.UnresolvedUnionUtil
  • com.linkedin.venice.writer.update.UpdateBuilderImpl (implements com.linkedin.venice.writer.update.UpdateBuilder)
  • com.linkedin.venice.hadoop.ssl.UserCredentialsFactory
  • com.linkedin.venice.controller.UserSystemStoreLifeCycleHelper
  • com.linkedin.venice.utils.Utils
  • com.linkedin.venice.utils.Utils.ConfigEntity<T>
  • com.linkedin.venice.hadoop.ValidateSchemaAndBuildDictMapperOutputReader (implements java.io.Closeable)
  • com.linkedin.venice.ValueAndDerivedSchemaData
  • com.linkedin.davinci.schema.merge.ValueAndRmd<T>
  • com.linkedin.venice.utils.ValueHolder<T>
  • com.linkedin.davinci.store.record.ValueRecord
  • com.linkedin.venice.spark.input.VeniceAbstractPartitionReader (implements org.apache.spark.sql.connector.read.PartitionReader<T>)
    • com.linkedin.venice.spark.input.hdfs.VeniceHdfsInputPartitionReader
  • com.linkedin.venice.hadoop.input.recordreader.avro.VeniceAvroFileIterator (implements com.linkedin.venice.hadoop.input.recordreader.VeniceRecordIterator)
  • com.linkedin.venice.serialization.avro.VeniceAvroKafkaSerializer (implements com.linkedin.venice.serialization.VeniceKafkaSerializer<T>)
  • com.linkedin.davinci.consumer.VeniceChangeCoordinate (implements java.io.Externalizable)
  • com.linkedin.davinci.consumer.VeniceChangelogConsumerClientFactory
  • com.linkedin.davinci.consumer.VeniceChangelogConsumerImpl<K,V> (implements com.linkedin.davinci.consumer.VeniceChangelogConsumer<K,V>)
    • com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl<K,V>
      • com.linkedin.davinci.consumer.LocalBootstrappingVeniceChangelogConsumer<K,V>
  • com.linkedin.venice.router.streaming.VeniceChunkedResponse
  • com.linkedin.venice.httpclient5.VeniceClientTlsStrategyBuilder
  • com.linkedin.davinci.config.VeniceClusterConfig
    • com.linkedin.davinci.config.VeniceServerConfig
      • com.linkedin.davinci.config.VeniceStoreVersionConfig
  • com.linkedin.venice.acl.VeniceComponent
  • com.linkedin.venice.compression.VeniceCompressor (implements java.io.Closeable)
    • com.linkedin.venice.compression.GzipCompressor
    • com.linkedin.venice.compression.NoopCompressor
    • com.linkedin.venice.compression.ZstdWithDictCompressor
  • com.linkedin.davinci.config.VeniceConfigLoader
  • com.linkedin.venice.VeniceConstants
  • com.linkedin.venice.controller.VeniceController
  • com.linkedin.venice.controller.VeniceControllerClusterConfig
  • com.linkedin.venice.controller.VeniceControllerContext
  • com.linkedin.venice.controller.VeniceControllerContext.Builder
  • com.linkedin.venice.controller.VeniceControllerMultiClusterConfig
  • com.linkedin.venice.router.api.VeniceDispatcher (implements com.linkedin.alpini.router.api.PartitionDispatchHandler4<H,P,K>)
  • com.linkedin.venice.utils.VeniceEnumValueTest<T>
  • com.linkedin.venice.hadoop.VeniceFileInputFormat (implements org.apache.hadoop.mapred.InputFormat<K,V>)
  • com.linkedin.venice.grpc.VeniceGrpcServer
  • com.linkedin.venice.grpc.VeniceGrpcServerConfig
  • com.linkedin.venice.grpc.VeniceGrpcServerConfig.Builder
  • com.linkedin.venice.spark.input.hdfs.VeniceHdfsInputPartition (implements org.apache.spark.sql.connector.read.InputPartition)
  • com.linkedin.venice.spark.input.hdfs.VeniceHdfsInputPartitionReaderFactory (implements org.apache.spark.sql.connector.read.PartitionReaderFactory)
  • com.linkedin.venice.spark.input.hdfs.VeniceHdfsInputScan (implements org.apache.spark.sql.connector.read.Batch, org.apache.spark.sql.connector.read.Scan)
  • com.linkedin.venice.spark.input.hdfs.VeniceHdfsInputScanBuilder (implements org.apache.spark.sql.connector.read.ScanBuilder)
  • com.linkedin.venice.spark.input.hdfs.VeniceHdfsInputTable (implements org.apache.spark.sql.connector.catalog.SupportsRead)
  • com.linkedin.venice.spark.input.hdfs.VeniceHdfsSource (implements org.apache.spark.sql.connector.catalog.TableProvider)
  • com.linkedin.venice.controller.VeniceHelixAdmin (implements com.linkedin.venice.controller.Admin, com.linkedin.venice.meta.StoreCleaner)
  • com.linkedin.venice.router.api.VeniceHostFinder (implements com.linkedin.alpini.router.api.HostFinder<H,R>)
  • com.linkedin.venice.router.api.VeniceHostHealth (implements com.linkedin.alpini.router.api.HostHealthMonitor<H>)
  • com.linkedin.venice.listener.VeniceHttp2PipelineInitializerBuilder
  • com.linkedin.venice.helix.VeniceJsonSerializer<T> (implements com.linkedin.venice.meta.VeniceSerializer<T>)
    • com.linkedin.venice.controller.migration.MigrationPushStrategyJSONSerializer
    • com.linkedin.venice.helix.OfflinePushStatusJSONSerializer
    • com.linkedin.venice.helix.PartitionStatusJSONSerializer
    • com.linkedin.venice.helix.RouterClusterConfigJSONSerializer
    • com.linkedin.venice.persona.StoragePersonaJSONSerializer
    • com.linkedin.venice.helix.StoreConfigJsonSerializer
    • com.linkedin.venice.helix.StoreJSONSerializer
    • com.linkedin.venice.controller.kafka.consumer.StringToLongMapJSONSerializer
    • com.linkedin.venice.helix.SystemStoreJSONSerializer
  • com.linkedin.venice.utils.VeniceLock
  • com.linkedin.davinci.repository.VeniceMetadataRepositoryBuilder
  • com.linkedin.venice.router.httpclient.VeniceMetaDataRequest
  • com.linkedin.venice.router.api.VeniceMetricsProvider (implements java.util.function.Function<T,R>)
  • com.linkedin.venice.hadoop.mapreduce.datawriter.partition.VeniceMRPartitioner (implements org.apache.hadoop.mapred.Partitioner<K2,V2>)
    • com.linkedin.venice.hadoop.input.kafka.KafkaInputMRPartitioner
  • com.linkedin.venice.samza.VeniceObjectWithTimestamp
  • com.linkedin.venice.helix.VeniceOfflinePushMonitorAccessor (implements com.linkedin.venice.pushmonitor.OfflinePushAccessor)
  • com.linkedin.venice.controller.server.VeniceParentControllerRegionStateHandler (implements spark.Route)
  • com.linkedin.venice.controller.VeniceParentHelixAdmin (implements com.linkedin.venice.controller.Admin)
  • com.linkedin.venice.partitioner.VenicePartitioner
    • com.linkedin.venice.partitioner.ConstantVenicePartitioner
    • com.linkedin.venice.partitioner.DefaultVenicePartitioner
    • com.linkedin.venice.partitioner.InvalidKeySchemaPartitioner
    • com.linkedin.venice.unit.kafka.SimplePartitioner
  • com.linkedin.venice.router.api.VenicePartitionFinder (implements com.linkedin.alpini.router.api.PartitionFinder<K>)
  • com.linkedin.venice.router.api.path.VenicePath (implements com.linkedin.alpini.router.api.ResourcePath<K>)
    • com.linkedin.venice.router.api.path.VeniceMultiKeyPath<K>
      • com.linkedin.venice.router.api.path.VeniceComputePath
      • com.linkedin.venice.router.api.path.VeniceMultiGetPath
    • com.linkedin.venice.router.api.path.VeniceSingleGetPath
  • com.linkedin.venice.router.api.VenicePathParser<HTTP_REQUEST> (implements com.linkedin.alpini.router.api.ExtendedResourcePathParser<P,K,HTTP_REQUEST>)
  • com.linkedin.venice.router.api.VenicePathParserHelper
  • com.linkedin.venice.utils.VeniceProperties (implements java.io.Serializable)
  • com.linkedin.venice.pulsar.sink.VenicePulsarSink (implements org.apache.pulsar.io.core.Sink<T>)
  • com.linkedin.venice.pulsar.sink.VenicePulsarSinkConfig (implements java.io.Serializable)
  • com.linkedin.venice.hadoop.VenicePushJob (implements java.lang.AutoCloseable)
  • com.linkedin.venice.vpj.VenicePushJobConstants
  • com.linkedin.venice.response.VeniceReadResponseStatus
  • com.linkedin.venice.protocols.VeniceReadServiceGrpc
  • com.linkedin.venice.protocols.VeniceReadServiceGrpc.VeniceReadServiceImplBase (implements io.grpc.BindableService)
    • com.linkedin.venice.listener.grpc.VeniceReadServiceImpl
  • com.linkedin.venice.protocols.VeniceReadServiceOuterClass
  • com.linkedin.venice.router.api.VeniceResponseAggregator (implements com.linkedin.alpini.router.api.ResponseAggregatorFactory<BASIC_HTTP_REQUEST,HTTP_RESPONSE>)
  • com.linkedin.venice.router.api.VeniceResponseDecompressor
  • com.linkedin.venice.router.api.VeniceRoleFinder (implements com.linkedin.alpini.router.api.RoleFinder<Role>)
  • com.linkedin.venice.controller.server.VeniceRouteHandler<T> (implements spark.Route)
  • com.linkedin.venice.router.VeniceRouterConfig
  • com.linkedin.venice.router.utils.VeniceRouterUtils
  • com.linkedin.venice.server.VeniceServer
  • com.linkedin.venice.server.VeniceServerContext
  • com.linkedin.venice.server.VeniceServerContext.Builder
  • com.linkedin.venice.listener.grpc.handlers.VeniceServerGrpcHandler
    • com.linkedin.venice.listener.grpc.handlers.GrpcOutboundResponseHandler
    • com.linkedin.venice.listener.grpc.handlers.GrpcOutboundStatsHandler
    • com.linkedin.venice.listener.grpc.handlers.GrpcReadQuotaEnforcementHandler
    • com.linkedin.venice.listener.grpc.handlers.GrpcRouterRequestHandler
    • com.linkedin.venice.listener.grpc.handlers.GrpcStatsHandler
    • com.linkedin.venice.listener.grpc.handlers.GrpcStorageReadRequestHandler
  • com.linkedin.venice.listener.grpc.handlers.VeniceServerGrpcRequestProcessor
  • com.linkedin.venice.controller.spark.VeniceSocketConnectorFactory
  • com.linkedin.venice.controller.spark.VeniceSparkEmbeddedJettyServer (implements spark.embeddedserver.EmbeddedServer)
  • com.linkedin.venice.controller.spark.VeniceSparkServerFactory (implements spark.embeddedserver.EmbeddedServerFactory)
  • com.linkedin.venice.standalone.VeniceStandalone
  • com.linkedin.venice.client.VeniceStoreClientGlobalConfig
  • com.linkedin.venice.testng.VeniceSuiteListener (implements org.testng.ISuiteListener)
  • com.linkedin.venice.samza.VeniceSystemFactory (implements java.io.Serializable, org.apache.samza.system.SystemFactory)
  • com.linkedin.venice.samza.VeniceSystemProducer (implements java.io.Closeable, org.apache.samza.system.SystemProducer)
  • com.linkedin.venice.common.VeniceSystemStoreUtils
  • com.linkedin.davinci.stats.VeniceVersionedStats<STATS,STATS_REPORTER>
  • com.linkedin.venice.router.api.VeniceVersionFinder
  • com.linkedin.venice.views.VeniceView
    • com.linkedin.venice.views.ChangeCaptureView
    • com.linkedin.venice.views.MaterializedView
    • com.linkedin.davinci.store.view.VeniceViewWriter
      • com.linkedin.davinci.store.view.ChangeCaptureViewWriter
  • com.linkedin.davinci.store.view.VeniceViewWriterFactory
  • com.linkedin.venice.hadoop.input.recordreader.vson.VeniceVsonFileIterator (implements com.linkedin.venice.hadoop.input.recordreader.VeniceRecordIterator)
  • com.linkedin.venice.writer.VeniceWriterFactory
  • com.linkedin.venice.writer.VeniceWriterOptions
  • com.linkedin.venice.writer.VeniceWriterOptions.Builder
  • com.linkedin.venice.zk.VeniceZkPaths
  • com.linkedin.davinci.VersionBackend
  • com.linkedin.venice.meta.VersionImpl (implements com.linkedin.venice.meta.Version)
  • com.linkedin.venice.meta.ViewConfigImpl (implements com.linkedin.venice.meta.ViewConfig)
  • com.linkedin.venice.views.ViewUtils
    • com.linkedin.davinci.store.view.ViewWriterUtils
  • com.linkedin.venice.hadoop.utils.VPJSSLUtils
  • com.linkedin.venice.schema.vson.VsonAvroSerializer
  • com.linkedin.venice.schema.vson.VsonReader
  • com.linkedin.venice.schema.vson.VsonSchema (implements java.io.Serializable)
  • com.linkedin.alpini.base.statistics.Welfords
    • com.linkedin.alpini.base.statistics.Welfords.DoubleWelford (implements java.util.function.DoubleConsumer)
    • com.linkedin.alpini.base.statistics.Welfords.LongWelford (implements java.util.function.LongConsumer)
  • com.linkedin.alpini.base.statistics.Welfords.Result (implements org.apache.logging.log4j.util.StringBuilderFormattable)
  • com.linkedin.venice.schema.writecompute.WriteComputeConstants
  • com.linkedin.venice.schema.writecompute.WriteComputeHandlerV1 (implements com.linkedin.venice.schema.writecompute.WriteComputeHandler)
    • com.linkedin.davinci.schema.writecompute.WriteComputeHandlerV2
  • com.linkedin.davinci.schema.writecompute.WriteComputeProcessor
  • com.linkedin.davinci.kafka.consumer.WriteComputeResultWrapper
  • com.linkedin.venice.schema.writecompute.WriteComputeSchemaConverter
  • com.linkedin.davinci.schema.writecompute.WriteComputeSchemaValidator
  • com.linkedin.davinci.stats.WritePathLatencySensor
  • com.linkedin.venice.writer.WriterChunkingHelper
  • com.linkedin.venice.helix.ZkAllowlistAccessor (implements com.linkedin.venice.helix.AllowlistAccessor)
  • com.linkedin.venice.helix.ZkClientFactory
  • com.linkedin.venice.ZkCopier
  • com.linkedin.venice.controller.ZkExecutionIdAccessor (implements com.linkedin.venice.controller.ExecutionIdAccessor)
  • com.linkedin.venice.controller.ZkHelixAdminClient (implements com.linkedin.venice.controller.HelixAdminClient)
  • com.linkedin.venice.helix.ZkRoutersClusterManager (implements org.apache.helix.zookeeper.zkclient.IZkChildListener, org.apache.helix.zookeeper.zkclient.IZkDataListener, org.apache.helix.zookeeper.zkclient.IZkStateListener, com.linkedin.venice.meta.RoutersClusterManager, com.linkedin.venice.VeniceResource)
  • com.linkedin.venice.helix.ZkStoreConfigAccessor

Interface Hierarchy

• com.linkedin.venice.meta.AbstractStore.StoreVersionSupplier
• com.linkedin.venice.acl.AccessController
  • com.linkedin.venice.acl.DynamicAccessController
  • com.linkedin.venice.acl.StaticAccessController
• com.linkedin.venice.AdminTool.PrintFunction
• com.linkedin.alpini.netty4.handlers.AsyncFullHttpRequestHandler.RequestHandler
• com.linkedin.alpini.base.concurrency.AsyncFutureListener<T>
• com.linkedin.alpini.router.api.AsyncPartitionFinder<K>
• com.linkedin.alpini.base.pool.AsyncPool<T>
  • com.linkedin.alpini.base.pool.AsyncQOSPool<T>
• com.linkedin.alpini.base.pool.AsyncPool.LifeCycle<T>
• com.linkedin.venice.authorization.AuthorizerService
• java.lang.AutoCloseable
  • com.linkedin.venice.controller.Admin (also extends java.io.Closeable)
  • com.linkedin.venice.blobtransfer.BlobFinder
  • com.linkedin.davinci.blobtransfer.BlobTransferManager<T>
    • com.linkedin.davinci.blobtransfer.P2PBlobTransferManager<T>
  • com.linkedin.alpini.base.monitoring.CallCompletion
  • java.io.Closeable
    • com.linkedin.venice.controller.Admin (also extends java.lang.AutoCloseable)
    • com.linkedin.venice.helix.AllowlistAccessor
    • com.linkedin.venice.client.store.AvroGenericStoreClient<K,V>
      • com.linkedin.venice.client.store.AvroGenericReadComputeStoreClient<K,V>
      • com.linkedin.venice.client.store.AvroSpecificStoreClient<K,V>
      • com.linkedin.davinci.client.DaVinciClient<K,V>
    • io.netty.channel.pool.ChannelPool
      • com.linkedin.alpini.netty4.pool.ChannelPoolWithStats
        • com.linkedin.alpini.netty4.pool.ManagedChannelPool
    • com.linkedin.venice.jobs.ComputeJob
    • org.apache.kafka.common.serialization.Deserializer<T>
      • com.linkedin.venice.serialization.VeniceKafkaSerializer<T> (also extends org.apache.kafka.common.serialization.Serializer<T>)
    • com.linkedin.davinci.ingestion.IngestionBackend
    • com.linkedin.venice.hadoop.InputDataInfoProvider
    • com.linkedin.venice.pubsub.api.PubSubAdminAdapter
    • com.linkedin.venice.pubsub.PubSubAdminAdapterFactory<ADAPTER>
    • com.linkedin.venice.pubsub.api.PubSubConsumerAdapter (also extends java.lang.AutoCloseable)
    • com.linkedin.venice.pubsub.PubSubConsumerAdapterFactory<ADAPTER>
    • com.linkedin.venice.pubsub.PubSubProducerAdapterFactory<ADAPTER>
    • com.linkedin.venice.schema.SchemaReader
      • com.linkedin.venice.fastclient.meta.StoreMetadata
    • org.apache.kafka.common.serialization.Serializer<T>
      • com.linkedin.venice.serialization.VeniceKafkaSerializer<T> (also extends org.apache.kafka.common.serialization.Deserializer<T>)
    • com.linkedin.venice.router.httpclient.StorageNodeClient
    • com.linkedin.venice.client.schema.StoreSchemaFetcher
    • com.linkedin.davinci.notifier.VeniceNotifier
    • com.linkedin.venice.producer.VeniceProducer<K,V>
    • com.linkedin.venice.hadoop.input.recordreader.VeniceRecordIterator
  • com.linkedin.venice.pubsub.api.PubSubConsumerAdapter (also extends java.io.Closeable)
  • com.linkedin.venice.utils.Timer
• com.linkedin.alpini.base.misc.BasicRequest
• java.util.function.BiConsumer<T,U>
  • com.linkedin.alpini.base.misc.TypedFieldAccessor<T,V> (also extends java.util.function.Function<T,R>)
• com.linkedin.venice.utils.BiIntFunction<R>
• com.linkedin.davinci.consumer.BootstrappingVeniceChangelogConsumer<K,V>
• com.linkedin.davinci.client.factory.CachingDaVinciClientFactory.DaVinciClientConstructor
• com.linkedin.alpini.base.monitoring.CallTracker
• com.linkedin.alpini.base.monitoring.CallTracker.CallStats
• com.linkedin.alpini.netty4.pool.ChannelPoolFactory
• com.linkedin.alpini.netty4.pool.ChannelPoolManager
• com.linkedin.alpini.netty4.pool.ChannelPoolResolver
• com.linkedin.davinci.storage.chunking.ChunkingAdapter<CHUNKS_CONTAINER,VALUE>
• com.linkedin.venice.chunking.ChunkKeyValueTransformer
• com.linkedin.venice.fastclient.meta.ClientRoutingStrategy
• com.linkedin.alpini.cli.CLIParser<T>
• com.linkedin.venice.meta.ClusterInfoProvider
• com.linkedin.venice.controller.init.ClusterLeaderInitializationRoutine
• java.lang.Comparable<T>
  • java.util.concurrent.Delayed
    • java.util.concurrent.ScheduledFuture<V> (also extends java.util.concurrent.Future<V>)
      • java.util.concurrent.RunnableScheduledFuture<V> (also extends java.util.concurrent.RunnableFuture<V>)
        • com.linkedin.alpini.base.misc.RunnableScheduledFuture<V> (also extends com.linkedin.alpini.base.misc.ScheduledFuture<V>)
      • com.linkedin.alpini.base.misc.ScheduledFuture<V> (also extends com.linkedin.alpini.base.concurrency.AsyncFuture<T>)
        • com.linkedin.alpini.base.misc.RunnableScheduledFuture<V> (also extends java.util.concurrent.RunnableScheduledFuture<V>)
  • com.linkedin.venice.meta.Version (also extends com.linkedin.venice.meta.DataModelBackedStructure<T>)
• java.util.concurrent.CompletionStage<T>
  • com.linkedin.alpini.base.concurrency.AsyncFuture<T> (also extends java.util.concurrent.Future<V>)
    • com.linkedin.alpini.base.concurrency.AsyncPromise<T>
    • com.linkedin.alpini.base.misc.ScheduledFuture<V> (also extends java.util.concurrent.ScheduledFuture<V>)
      • com.linkedin.alpini.base.misc.RunnableScheduledFuture<V> (also extends java.util.concurrent.RunnableScheduledFuture<V>)
• com.linkedin.venice.client.store.ComputeRequestBuilder<K>
• com.linkedin.alpini.consts.config.ConfigBuilder<C>
• com.linkedin.davinci.ingestion.consumption.ConsumedDataReceiver<MESSAGE>
• com.linkedin.venice.meta.DataModelBackedStructure<T>
  • com.linkedin.venice.meta.DataRecoveryVersionConfig
  • com.linkedin.venice.meta.ETLStoreConfig
  • com.linkedin.venice.meta.HybridStoreConfig
  • com.linkedin.venice.meta.PartitionerConfig
  • com.linkedin.venice.meta.SystemStoreAttributes
  • com.linkedin.venice.meta.Version (also extends java.lang.Comparable<T>)
  • com.linkedin.venice.meta.ViewConfig
• com.linkedin.davinci.client.factory.DaVinciClientFactory
• com.linkedin.davinci.client.DaVinciRecordTransformerFunctionalInterface
• io.netty.handler.codec.DecoderResultProvider
  • io.netty.handler.codec.http.HttpObject
    • io.netty.handler.codec.http.HttpContent (also extends io.netty.buffer.ByteBufHolder)
      • com.linkedin.alpini.netty4.misc.FullHttpMultiPart (also extends com.linkedin.alpini.netty4.misc.HttpMultiPart)
      • io.netty.handler.codec.http.LastHttpContent
        • io.netty.handler.codec.http.FullHttpMessage (also extends io.netty.handler.codec.http.HttpMessage)
          • io.netty.handler.codec.http.FullHttpRequest (also extends io.netty.handler.codec.http.HttpRequest)
            • com.linkedin.alpini.netty4.misc.FullHttpMultiPartRequest (also extends java.lang.Iterable<T>)
          • io.netty.handler.codec.http.FullHttpResponse (also extends io.netty.handler.codec.http.HttpResponse)
            • com.linkedin.alpini.netty4.misc.ChunkedHttpResponse
              • com.linkedin.alpini.netty4.misc.MultipartHttpResponse
      • com.linkedin.alpini.netty4.misc.MultipartContent
    • io.netty.handler.codec.http.HttpMessage
      • io.netty.handler.codec.http.FullHttpMessage (also extends io.netty.handler.codec.http.LastHttpContent)
        • io.netty.handler.codec.http.FullHttpRequest (also extends io.netty.handler.codec.http.HttpRequest)
          • com.linkedin.alpini.netty4.misc.FullHttpMultiPartRequest (also extends java.lang.Iterable<T>)
        • io.netty.handler.codec.http.FullHttpResponse (also extends io.netty.handler.codec.http.HttpResponse)
          • com.linkedin.alpini.netty4.misc.ChunkedHttpResponse
            • com.linkedin.alpini.netty4.misc.MultipartHttpResponse
      • com.linkedin.alpini.netty4.misc.HttpMultiPart
        • com.linkedin.alpini.netty4.misc.FullHttpMultiPart (also extends io.netty.handler.codec.http.HttpContent)
      • io.netty.handler.codec.http.HttpRequest
        • com.linkedin.alpini.netty4.misc.BadHttpRequest
        • io.netty.handler.codec.http.FullHttpRequest (also extends io.netty.handler.codec.http.FullHttpMessage)
          • com.linkedin.alpini.netty4.misc.FullHttpMultiPartRequest (also extends java.lang.Iterable<T>)
      • io.netty.handler.codec.http.HttpResponse
        • io.netty.handler.codec.http.FullHttpResponse (also extends io.netty.handler.codec.http.FullHttpMessage)
          • com.linkedin.alpini.netty4.misc.ChunkedHttpResponse
            • com.linkedin.alpini.netty4.misc.MultipartHttpResponse
• org.apache.avro.generic.DeterministicMapOrderDatumWriter
• com.linkedin.venice.pushmonitor.DisableReplicaCallback
• com.linkedin.venice.utils.DoubleAndBooleanConsumer
• com.linkedin.venice.hadoop.engine.EngineTaskConfigProvider
• com.linkedin.alpini.netty4.misc.EventGroupLoopSupplier
• com.linkedin.venice.throttle.EventThrottlingStrategy
• com.linkedin.alpini.base.misc.ExceptionUtil.ExceptionThrower
• com.linkedin.venice.controller.ExecutionIdAccessor
• java.util.concurrent.Executor
  • java.util.concurrent.ExecutorService
    • com.linkedin.alpini.base.concurrency.ExecutorService
      • com.linkedin.alpini.base.concurrency.ScheduledExecutorService (also extends java.util.concurrent.ScheduledExecutorService)
        • com.linkedin.alpini.base.registry.ShutdownableScheduledExecutorService (also extends com.linkedin.alpini.base.registry.ShutdownableExecutorService)
      • com.linkedin.alpini.base.registry.ShutdownableExecutorService (also extends com.linkedin.alpini.base.registry.ShutdownableResource)
        • com.linkedin.alpini.base.registry.ShutdownableScheduledExecutorService (also extends com.linkedin.alpini.base.concurrency.ScheduledExecutorService)
    • java.util.concurrent.ScheduledExecutorService
      • io.netty.util.concurrent.EventExecutorGroup (also extends java.lang.Iterable<T>)
        • io.netty.channel.EventLoopGroup
          • com.linkedin.alpini.netty4.misc.SingleThreadEventLoopGroupSupplier
      • com.linkedin.alpini.base.concurrency.ScheduledExecutorService (also extends com.linkedin.alpini.base.concurrency.ExecutorService)
        • com.linkedin.alpini.base.registry.ShutdownableScheduledExecutorService (also extends com.linkedin.alpini.base.registry.ShutdownableExecutorService)
  • com.linkedin.alpini.router.api.RouterTimeoutProcessor
• com.linkedin.alpini.log.FastLogMBean
• java.util.function.Function<T,R>
  • com.linkedin.alpini.base.misc.TypedFieldAccessor<T,V> (also extends java.util.function.BiConsumer<T,U>)
• java.util.concurrent.Future<V>
  • com.linkedin.alpini.base.concurrency.AsyncFuture<T> (also extends java.util.concurrent.CompletionStage<T>)
    • com.linkedin.alpini.base.concurrency.AsyncPromise<T>
    • com.linkedin.alpini.base.misc.ScheduledFuture<V> (also extends java.util.concurrent.ScheduledFuture<V>)
      • com.linkedin.alpini.base.misc.RunnableScheduledFuture<V> (also extends java.util.concurrent.RunnableScheduledFuture<V>)
  • java.util.concurrent.RunnableFuture<V> (also extends java.lang.Runnable)
    • java.util.concurrent.RunnableScheduledFuture<V> (also extends java.util.concurrent.ScheduledFuture<V>)
      • com.linkedin.alpini.base.misc.RunnableScheduledFuture<V> (also extends com.linkedin.alpini.base.misc.ScheduledFuture<V>)
  • java.util.concurrent.ScheduledFuture<V> (also extends java.util.concurrent.Delayed)
    • java.util.concurrent.RunnableScheduledFuture<V> (also extends java.util.concurrent.RunnableFuture<V>)
      • com.linkedin.alpini.base.misc.RunnableScheduledFuture<V> (also extends com.linkedin.alpini.base.misc.ScheduledFuture<V>)
    • com.linkedin.alpini.base.misc.ScheduledFuture<V> (also extends com.linkedin.alpini.base.concurrency.AsyncFuture<T>)
      • com.linkedin.alpini.base.misc.RunnableScheduledFuture<V> (also extends java.util.concurrent.RunnableScheduledFuture<V>)
• com.linkedin.venice.hadoop.mapreduce.engine.HadoopJobClientProvider
• com.linkedin.alpini.base.hash.HashFunction
• com.linkedin.alpini.base.misc.HeaderNames.HeaderNamesProvider
• com.linkedin.alpini.base.misc.HeaderUtils.ContentType
• com.linkedin.venice.controller.HelixAdminClient
• com.linkedin.venice.router.api.routing.helix.HelixGroupSelectionStrategy
• com.linkedin.alpini.router.api.HostFinder<H,R>
• com.linkedin.alpini.router.api.HostHealthMonitor<H>
• com.linkedin.alpini.netty4.pool.Http2PingCallListener
• com.linkedin.venice.service.ICProvider
• com.linkedin.venice.authorization.IdentityParser
• com.linkedin.davinci.storage.IngestionMetadataRetriever
• java.lang.Iterable<T>
  • io.netty.util.concurrent.EventExecutorGroup (also extends java.util.concurrent.ScheduledExecutorService)
    • io.netty.channel.EventLoopGroup
      • com.linkedin.alpini.netty4.misc.SingleThreadEventLoopGroupSupplier
  • com.linkedin.alpini.netty4.misc.FullHttpMultiPartRequest (also extends io.netty.handler.codec.http.FullHttpRequest)
  • com.linkedin.alpini.base.misc.Headers
• com.linkedin.venice.hadoop.JobClientWrapper
• com.linkedin.venice.utils.lazy.Lazy<T>
  • com.linkedin.venice.utils.lazy.LazyResettable<C>
• com.sun.jna.Library
  • com.linkedin.alpini.jna.ThreadUtils.DarwinCLib
  • com.linkedin.alpini.jna.ThreadUtils.LinuxCLib
  • com.linkedin.alpini.jna.ThreadUtils.WindowsCLib
• com.linkedin.venice.controller.lingeringjob.LingeringStoreVersionChecker
• com.linkedin.venice.meta.LiveInstanceChangedListener
• com.linkedin.venice.meta.LiveInstanceMonitor
• com.linkedin.alpini.base.statistics.LongStats
• com.linkedin.alpini.base.statistics.LongStatsLowQuantile
• com.linkedin.alpini.router.api.LongTailRetrySupplier<P,K>
• java.util.Map<K,V>
  • com.linkedin.davinci.utils.IndexedMap<K,V>
  • com.linkedin.venice.utils.IndexedMap<K,V>
  • com.linkedin.venice.client.store.streaming.VeniceResponseMap<K,V>
• com.linkedin.venice.memory.Measurable
  • com.linkedin.venice.pubsub.api.PubSubMessage<K,V,OFFSET>
• com.linkedin.davinci.replication.merge.Merge<T>
• com.linkedin.davinci.schema.merge.MergeRecordHelper
• com.google.protobuf.MessageLiteOrBuilder
  • com.google.protobuf.MessageOrBuilder
    • com.linkedin.venice.protocols.VeniceClientRequestOrBuilder
    • com.linkedin.venice.protocols.VeniceServerResponseOrBuilder
• com.linkedin.venice.tehuti.MetricsAware
• com.linkedin.alpini.router.api.MetricsDecoder
• com.linkedin.alpini.router.api.MetricsDecorator
• com.linkedin.alpini.router.api.MetricsProvider
• com.linkedin.venice.utils.pools.ObjectPool<O>
• com.linkedin.venice.pushmonitor.OfflinePushAccessor
• com.linkedin.venice.offsets.OffsetManager
  • com.linkedin.davinci.storage.StorageMetadataService
• com.linkedin.venice.meta.OnlineInstanceFinder
  • com.linkedin.venice.meta.RoutingDataRepository (also extends com.linkedin.venice.VeniceResource)
• com.linkedin.alpini.router.api.PartitionDispatchHandler<H,P,K,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>
  • com.linkedin.alpini.router.api.PartitionDispatchHandler4<H,P,K>
• com.linkedin.alpini.router.api.PartitionFinder<K>
• com.linkedin.venice.pushmonitor.PartitionStatusListener
• com.linkedin.davinci.validation.PartitionTracker.DIVErrorMetricCallback
• com.linkedin.venice.utils.PathResourceRegistry<T>
• com.linkedin.venice.unit.kafka.consumer.poll.PollStrategy
• com.linkedin.alpini.base.pool.PoolStats
• com.linkedin.alpini.base.pool.PoolStats.LifeCycleStats
• com.linkedin.venice.router.httpclient.PortableHttpResponse
• com.linkedin.venice.client.store.predicate.Predicate
• com.linkedin.venice.pubsub.api.PubSubPosition
• com.linkedin.venice.pubsub.api.PubSubProducerAdapter
• com.linkedin.venice.pubsub.api.PubSubProducerCallback
  • com.linkedin.venice.writer.ChunkAwareCallback
• com.linkedin.venice.pubsub.api.PubSubProduceResult
• com.linkedin.venice.pubsub.api.PubSubTopic
• com.linkedin.venice.pubsub.api.PubSubTopicPartition
• com.linkedin.venice.heartbeat.PushJobHeartbeatSenderFactory
• com.linkedin.venice.pushmonitor.PushMonitor
• com.linkedin.venice.compute.ReadComputeOperator
• com.linkedin.davinci.storage.ReadMetadataRetriever
• com.linkedin.venice.meta.ReadOnlyStoreConfigRepository
• com.linkedin.davinci.listener.response.ReadResponse
• com.linkedin.davinci.listener.response.ReadResponseStats
• com.linkedin.venice.listener.response.stats.ReadResponseStatsRecorder
• com.linkedin.venice.serializer.RecordDeserializer<T>
• com.linkedin.venice.serializer.RecordSerializer<T>
• io.netty.util.ReferenceCounted
  • io.netty.buffer.ByteBufHolder
    • io.netty.handler.codec.http.HttpContent (also extends io.netty.handler.codec.http.HttpObject)
      • com.linkedin.alpini.netty4.misc.FullHttpMultiPart (also extends com.linkedin.alpini.netty4.misc.HttpMultiPart)
      • io.netty.handler.codec.http.LastHttpContent
        • io.netty.handler.codec.http.FullHttpMessage (also extends io.netty.handler.codec.http.HttpMessage)
          • io.netty.handler.codec.http.FullHttpRequest (also extends io.netty.handler.codec.http.HttpRequest)
            • com.linkedin.alpini.netty4.misc.FullHttpMultiPartRequest (also extends java.lang.Iterable<T>)
          • io.netty.handler.codec.http.FullHttpResponse (also extends io.netty.handler.codec.http.HttpResponse)
            • com.linkedin.alpini.netty4.misc.ChunkedHttpResponse
              • com.linkedin.alpini.netty4.misc.MultipartHttpResponse
      • com.linkedin.alpini.netty4.misc.MultipartContent
• com.linkedin.venice.client.stats.Reporter
• com.linkedin.alpini.router.api.RequestRetriableChecker<P,R,HRS>
• com.linkedin.alpini.router.api.ResourcePath<K>
• com.linkedin.alpini.router.api.ResourcePathParser<P,K>
  • com.linkedin.alpini.router.api.ExtendedResourcePathParser<P,K,HTTP_REQUEST>
• com.linkedin.venice.cleaner.ResourceReadUsageTracker
• com.linkedin.alpini.base.registry.ResourceRegistry.Factory<R>
  • com.linkedin.alpini.base.registry.ShutdownableExecutors
• com.linkedin.alpini.base.registry.ResourceRegistry.ShutdownFirst
• com.linkedin.alpini.base.registry.ResourceRegistry.ShutdownLast
• com.linkedin.alpini.base.registry.ResourceRegistry.Sync
• com.linkedin.alpini.router.api.ResponseAggregatorFactory<BASIC_HTTP_REQUEST,HTTP_RESPONSE>
• com.linkedin.venice.utils.RetryUtils.IntermediateFailureHandler
• com.linkedin.davinci.store.rocksdb.RocksDBThrottler.RocksDBSupplier
• com.linkedin.alpini.router.api.RoleFinder<Role>
• com.linkedin.alpini.router.impl.Router.Builder
• com.linkedin.alpini.router.impl.Router.PipelineFactory<CHANNEL_HANDLER>
• com.linkedin.venice.pushmonitor.RouterBasedHybridStoreQuotaMonitor.TransportClientReinitProvider
• com.linkedin.alpini.router.impl.RouterPipelineFactory<CHANNEL_HANDLER>
• com.linkedin.venice.meta.RoutersClusterManager
• com.linkedin.venice.meta.RoutersClusterManager.RouterCountChangedListener
• com.linkedin.venice.router.throttle.RouterThrottler
• com.linkedin.alpini.router.api.RouterTimeoutProcessor.TimeoutFuture
• com.linkedin.venice.meta.RoutingDataRepository.RoutingDataChangedListener
• java.lang.Runnable
  • com.linkedin.venice.heartbeat.PushJobHeartbeatSender
  • java.util.concurrent.RunnableFuture<V> (also extends java.util.concurrent.Future<V>)
    • java.util.concurrent.RunnableScheduledFuture<V> (also extends java.util.concurrent.ScheduledFuture<V>)
      • com.linkedin.alpini.base.misc.RunnableScheduledFuture<V> (also extends com.linkedin.alpini.base.misc.ScheduledFuture<V>)
• com.linkedin.alpini.router.monitoring.ScatterGatherStatsMBean
• com.linkedin.venice.schema.SchemaAdapter
• com.linkedin.venice.hadoop.schema.SchemaSource
• com.linkedin.venice.hadoop.SentPushJobDetailsTracker
• com.linkedin.venice.servicediscovery.ServiceDiscoveryAnnouncer
• com.linkedin.alpini.base.registry.Shutdownable
  • com.linkedin.alpini.base.registry.ShutdownableResource
    • com.linkedin.alpini.router.impl.Router
    • com.linkedin.alpini.base.registry.ShutdownableExecutorService (also extends com.linkedin.alpini.base.concurrency.ExecutorService)
      • com.linkedin.alpini.base.registry.ShutdownableScheduledExecutorService (also extends com.linkedin.alpini.base.concurrency.ScheduledExecutorService)
• com.linkedin.alpini.base.queuing.SimpleQueue<T>
• com.linkedin.venice.hadoop.ssl.SSLConfigurator
• com.linkedin.alpini.base.ssl.SslFactory
  • com.linkedin.alpini.netty4.ssl.SSLEngineFactory
• com.linkedin.venice.security.SSLFactory
• com.linkedin.venice.stats.StatsSupplier<T>
• com.linkedin.venice.status.StatusMessageChannel
• com.linkedin.venice.status.StatusMessageHandler<T>
• com.linkedin.venice.meta.Store
• com.linkedin.venice.meta.StoreCleaner
• com.linkedin.venice.meta.StoreDataChangedListener
• com.linkedin.venice.serialization.StoreDeserializerCache<T>
• com.linkedin.venice.meta.StoreGraveyard
• com.linkedin.davinci.kafka.consumer.StoreIngestionService
• com.linkedin.venice.meta.StoreListChangedListener
• com.linkedin.venice.client.store.streaming.StreamingCallback<K,V>
  • com.linkedin.venice.client.store.streaming.TrackingStreamingCallback<K,V>
• com.linkedin.venice.router.streaming.StreamingCallback<T>
• com.linkedin.venice.controller.supersetschema.SupersetSchemaGenerator
• java.util.function.Supplier<T>
  • com.linkedin.alpini.netty4.http2.Http2PipelineInitializer.BuilderSupplier
• com.linkedin.alpini.base.registry.SyncShutdownable
• com.linkedin.venice.hadoop.task.TaskTracker
  • com.linkedin.venice.hadoop.task.datawriter.DataWriterTaskTracker
• com.linkedin.venice.utils.TestUtils.NonDeterministicAssertion
• com.linkedin.venice.utils.Time
• com.linkedin.alpini.base.misc.Time.Awaitable
• com.linkedin.davinci.kafka.consumer.TopicExistenceChecker
• com.linkedin.venice.pubsub.manager.TopicManagerContext.PubSubPropertiesSupplier
• com.linkedin.davinci.kafka.consumer.TopicPartitionConsumerFunction
• com.linkedin.alpini.base.misc.TouchTimer.Visitor
• com.linkedin.venice.unit.kafka.producer.TransformingProducerAdapter.SendMessageParametersTransformer
• com.linkedin.venice.client.store.transport.TransportClientStreamingCallback
  • com.linkedin.venice.client.store.streaming.RecordStreamDecoder
• com.linkedin.alpini.base.misc.TriFunction<T,U,S,R>
• com.linkedin.venice.writer.update.UpdateBuilder
• com.linkedin.venice.controllerapi.routes.V1Route
• com.linkedin.venice.hadoop.validation.Validator
• com.linkedin.davinci.consumer.VeniceChangelogConsumer<K,V>
• com.linkedin.davinci.consumer.VeniceChangelogConsumerClientFactory.ViewClassGetter
• com.linkedin.venice.utils.VeniceCheckedRunnable
• com.linkedin.venice.utils.VeniceCheckedSupplier<T>
• com.linkedin.venice.router.streaming.VeniceChunkedWriteHandler.WriteMessageCallback
• com.linkedin.venice.utils.VeniceEnumValue
• com.linkedin.venice.controller.VeniceHelixAdmin.StoreMetadataOperation
• com.linkedin.venice.throttle.VeniceRateLimiter
• com.linkedin.venice.VeniceResource
  • com.linkedin.venice.meta.ReadOnlyLiveClusterConfigRepository
    • com.linkedin.venice.meta.ReadWriteLiveClusterConfigRepository
  • com.linkedin.venice.meta.ReadOnlySchemaRepository
    • com.linkedin.venice.meta.ReadWriteSchemaRepository
  • com.linkedin.venice.meta.ReadOnlyStoreRepository
    • com.linkedin.venice.meta.ReadWriteStoreRepository
    • com.linkedin.venice.meta.SubscriptionBasedReadOnlyStoreRepository
  • com.linkedin.venice.meta.RoutingDataRepository (also extends com.linkedin.venice.meta.OnlineInstanceFinder)
• com.linkedin.venice.meta.VeniceSerializer<T>
• com.linkedin.davinci.store.cache.VeniceStoreCache
• com.linkedin.venice.client.factory.VeniceStoreClientFactory
• com.linkedin.venice.client.factory.VeniceStoreClientFactory.ClientConfigUpdater
• com.linkedin.venice.writer.VeniceWriter.KeyProvider
• com.linkedin.venice.schema.writecompute.WriteComputeHandler

Annotation Type Hierarchy

• com.linkedin.alpini.cli.CLIArgument (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.cli.CLIFlag (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.cli.CLIFooter (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.cli.CLIHeader (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.cli.CLIUnknown (implements java.lang.annotation.Annotation)
• com.linkedin.venice.annotation.Experimental (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.base.misc.HeaderNames.XClusterName (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.base.misc.HeaderNames.XErrorCauseClass (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.base.misc.HeaderNames.XErrorCauseMessage (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.base.misc.HeaderNames.XErrorClass (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.base.misc.HeaderNames.XErrorInResponse (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.base.misc.HeaderNames.XErrorMessage (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.base.misc.HeaderNames.XMetrics (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.base.misc.HeaderNames.XMultipartContentStatus (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.base.misc.HeaderNames.XPartition (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.base.misc.HeaderNames.XRequestId (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.base.misc.HeaderNames.XResponseBoundary (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.base.misc.HeaderNames.XReturnMetrics (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.base.misc.HeaderNames.XServedBy (implements java.lang.annotation.Annotation)
• com.linkedin.alpini.router.api.NettyVersion (implements java.lang.annotation.Annotation)
• com.linkedin.venice.annotation.NotThreadsafe (implements java.lang.annotation.Annotation)
• com.linkedin.venice.annotation.Threadsafe (implements java.lang.annotation.Annotation)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • com.linkedin.davinci.store.AbstractStorageEngine.StoragePartitionAdjustmentTrigger
    • com.linkedin.venice.service.AbstractVeniceService.ServiceState
    • com.linkedin.venice.acl.handler.AccessResult
    • com.linkedin.venice.controllerapi.AdminCommandExecutionStatus
    • com.linkedin.venice.controller.kafka.protocol.enums.AdminMessageType
    • com.linkedin.venice.Arg
    • com.linkedin.alpini.netty4.misc.AsciiStringURLCodec
    • com.linkedin.alpini.base.concurrency.AsyncFuture.Status
    • com.linkedin.venice.serializer.AvroGenericDeserializer.IterableImpl
    • com.linkedin.venice.serialization.avro.AvroProtocolDefinition
    • com.linkedin.venice.meta.BackupStrategy
    • com.linkedin.alpini.netty4.misc.BasicHttpObjectDecoder.State
    • com.linkedin.davinci.replication.BatchConflictResolutionPolicy
    • com.linkedin.venice.client.store.deserialization.BatchDeserializerType
    • com.linkedin.davinci.blobtransfer.BlobTransferUtils.BlobTransferType
    • com.linkedin.venice.utils.concurrent.BlockingQueueType
    • com.linkedin.venice.meta.BufferReplayPolicy
    • com.linkedin.alpini.base.monitoring.CallTrackerImpl.Mode
    • com.linkedin.venice.kafka.validation.checksum.CheckSumType
    • com.linkedin.venice.chunking.ChunkKeyValueTransformer.KeyType
    • com.linkedin.venice.fastclient.meta.ClientRoutingStrategyType
    • com.linkedin.venice.fastclient.utils.ClientTestUtils.FastClientHTTPVariant
    • com.linkedin.alpini.base.misc.CollectionUtil
    • com.linkedin.venice.Command
    • com.linkedin.venice.compression.CompressionStrategy (implements com.linkedin.venice.utils.VeniceEnumValue)
    • com.linkedin.venice.jobs.ComputeJob.Status
    • com.linkedin.venice.compute.protocol.request.enums.ComputeOperationType (implements com.linkedin.venice.utils.VeniceEnumValue)
    • com.linkedin.alpini.base.concurrency.ConcurrentAccumulator.Mode
    • com.linkedin.davinci.kafka.consumer.ConsumerActionType
    • com.linkedin.davinci.kafka.consumer.ConsumerPoolType
    • com.linkedin.venice.controllerapi.ControllerRoute
    • com.linkedin.venice.kafka.protocol.enums.ControlMessageType (implements com.linkedin.venice.utils.VeniceEnumValue)
    • com.linkedin.venice.meta.DataReplicationPolicy
    • com.linkedin.alpini.base.misc.DateUtils
    • com.linkedin.davinci.client.DaVinciRecordTransformerResult.Result
    • com.linkedin.venice.schema.avro.DirectionalSchemaCompatibilityType
    • com.linkedin.venice.exceptions.ErrorType
    • com.linkedin.venice.etl.ETLValueSchemaTransformation
    • com.linkedin.venice.exceptions.ExceptionType
    • com.linkedin.alpini.base.misc.ExceptionUtil
    • com.linkedin.venice.pushmonitor.ExecutionStatus (implements com.linkedin.venice.utils.VeniceEnumValue)
    • com.linkedin.alpini.base.concurrency.Executors
    • com.linkedin.alpini.base.misc.HeaderNames
    • com.linkedin.alpini.base.misc.HeaderUtils
    • com.linkedin.venice.router.api.routing.helix.HelixGroupSelectionStrategyEnum
    • com.linkedin.venice.helix.HelixPartitionState
    • com.linkedin.venice.helix.HelixState
    • com.linkedin.venice.helix.HelixViewPropertyType
    • com.linkedin.venice.HttpMethod
    • com.linkedin.alpini.netty4.misc.HttpUtils
    • com.linkedin.venice.pushmonitor.HybridStoreQuotaStatus
    • com.linkedin.venice.ingestion.protocol.enums.IngestionAction
    • com.linkedin.venice.ingestion.protocol.enums.IngestionCommandType
    • com.linkedin.venice.ingestion.protocol.enums.IngestionComponentType
    • com.linkedin.venice.meta.IngestionMetadataUpdateType
    • com.linkedin.venice.meta.IngestionMode
    • com.linkedin.venice.ingestion.protocol.enums.IngestionReportType
    • com.linkedin.venice.controller.InstanceRemovableStatuses.NonStoppableReason
    • com.linkedin.venice.meta.InstanceStatus
    • com.linkedin.alpini.io.IOUtils
    • com.linkedin.alpini.base.misc.JDBCUtils
    • com.linkedin.davinci.kafka.consumer.KafkaConsumerService.ConsumerAssignmentStrategy
    • com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.ConsumerPoolStrategyType
    • com.linkedin.davinci.ingestion.LagType
    • com.linkedin.venice.writer.LeaderCompleteState (implements com.linkedin.venice.utils.VeniceEnumValue)
    • com.linkedin.davinci.helix.LeaderFollowerPartitionStateModelFactory.LeaderFollowerThreadPoolStrategy
    • com.linkedin.davinci.kafka.consumer.LeaderFollowerStateType
    • com.linkedin.davinci.ingestion.main.MainPartitionIngestionStatus
    • com.linkedin.venice.hadoop.input.kafka.avro.MapperValueType
    • com.linkedin.venice.kafka.protocol.enums.MessageType (implements com.linkedin.venice.utils.VeniceEnumValue)
    • com.linkedin.venice.system.store.MetaStoreDataType (implements com.linkedin.venice.utils.VeniceEnumValue)
    • com.linkedin.venice.authorization.Method
    • com.linkedin.alpini.base.misc.MetricNames
    • com.linkedin.venice.migration.MigrationPushStrategy
    • com.linkedin.alpini.router.api.Netty
    • com.linkedin.alpini.netty4.misc.NettyUtils.Mode
    • com.linkedin.alpini.netty4.misc.NettyUtils.ReadMode
    • com.linkedin.venice.controller.NodeRemovableResult.BlockingRemoveReason
    • com.linkedin.venice.controllerapi.NodeReplicasReadinessState
    • com.linkedin.venice.meta.OfflinePushStrategy
    • com.linkedin.venice.controller.ParentControllerRegionState
    • com.linkedin.venice.participant.protocol.enums.ParticipantMessageType
    • com.linkedin.davinci.kafka.consumer.PartitionReplicaIngestionContext.VersionRole
    • com.linkedin.davinci.kafka.consumer.PartitionReplicaIngestionContext.WorkloadType
    • com.linkedin.venice.authorization.Permission
    • com.linkedin.venice.meta.PersistenceType
    • com.linkedin.alpini.base.misc.Preconditions
    • com.linkedin.alpini.base.misc.ProcessUtil
    • com.linkedin.venice.pubsub.api.PubSubSecurityProtocol
    • com.linkedin.venice.pubsub.api.PubSubTopicType
    • com.linkedin.venice.PushJobCheckpoints (implements com.linkedin.venice.utils.VeniceEnumValue)
    • com.linkedin.venice.status.PushJobDetailsStatus (implements com.linkedin.venice.utils.VeniceEnumValue)
    • com.linkedin.venice.status.protocol.enums.PushJobStatus
    • com.linkedin.venice.pushmonitor.PushMonitorType
    • com.linkedin.venice.pushmonitor.PushStatusCleanUpServiceState
    • com.linkedin.venice.pushstatushelper.PushStatusStoreReader.InstanceStatus
    • com.linkedin.venice.common.PushStatusStoreUtils.PushStatusKeyType
    • com.linkedin.alpini.consts.QOS
    • com.linkedin.alpini.base.queuing.QOSPolicy
    • com.linkedin.venice.meta.QueryAction
    • com.linkedin.venice.schema.avro.ReadAvroProtocolDefinition
    • com.linkedin.venice.listener.ReadQuotaEnforcementHandler.QuotaEnforcementResult
    • com.linkedin.venice.meta.ReadStrategy
    • com.linkedin.venice.datarecovery.meta.RepushViabilityInfo.Result
    • com.linkedin.venice.read.RequestType
    • com.linkedin.venice.schema.rmd.RmdTimestampType
    • com.linkedin.davinci.store.rocksdb.RocksDBBlockCacheImplementations
    • com.linkedin.venice.router.api.RouterExceptionAndTrackingUtils.FailureType
    • com.linkedin.venice.router.api.RouterResourceType
    • com.linkedin.venice.meta.RoutingStrategy
    • com.linkedin.venice.samza.SamzaExitMode
    • com.linkedin.venice.schema.avro.SchemaCompatibility.SchemaCompatibilityType
    • com.linkedin.venice.controller.kafka.protocol.enums.SchemaType
    • com.linkedin.venice.kafka.validation.SegmentStatus
    • com.linkedin.venice.meta.ServerAdminAction
    • com.linkedin.alpini.base.misc.SimpleJsonMapper
    • com.linkedin.venice.router.stats.StaleVersionReason
    • com.linkedin.venice.stats.StatsErrorCode
    • com.linkedin.davinci.client.StorageClass
    • com.linkedin.venice.router.httpclient.StorageNodeClientType
    • com.linkedin.davinci.kafka.consumer.StoreIngestionTask.DelegateConsumerRecordResult
    • com.linkedin.venice.hooks.StoreLifecycleEventOutcome
    • com.linkedin.venice.fastclient.meta.StoreMetadataFetchMode
    • com.linkedin.venice.common.StoreMetadataType
    • com.linkedin.venice.meta.StoreStatus
    • com.linkedin.venice.hooks.StoreVersionLifecycleEventOutcome
    • com.linkedin.alpini.base.test.TestUtil
    • com.linkedin.venice.utils.TestWriteUtils.TestRecordType
    • com.linkedin.venice.utils.TestWriteUtils.TestTargetedField
    • com.linkedin.alpini.jna.ThreadUtils.OsPlatform
    • com.linkedin.alpini.base.misc.Time
    • com.linkedin.alpini.base.misc.TimeFormat
    • com.linkedin.venice.hadoop.input.kafka.ttl.TTLResolutionPolicy
    • com.linkedin.davinci.schema.merge.UpdateResultStatus
    • com.linkedin.alpini.base.misc.URLCodec
    • com.linkedin.venice.controllerapi.routes.V1Delete (implements com.linkedin.venice.controllerapi.routes.V1Route)
    • com.linkedin.venice.controllerapi.routes.V1Get (implements com.linkedin.venice.controllerapi.routes.V1Route)
    • com.linkedin.venice.controllerapi.routes.V1Post (implements com.linkedin.venice.controllerapi.routes.V1Route)
    • com.linkedin.venice.controllerapi.routes.V1Put (implements com.linkedin.venice.controllerapi.routes.V1Route)
    • com.linkedin.venice.utils.ValueSize
    • com.linkedin.venice.router.api.VeniceMultiKeyRoutingStrategy
    • com.linkedin.venice.throttle.VeniceRateLimiter.RateLimiterType
    • com.linkedin.venice.utils.VeniceResourceCloseResult
    • com.linkedin.venice.router.api.VeniceRole
    • com.linkedin.davinci.config.VeniceServerConfig.IncrementalPushStatusWriteMode
    • com.linkedin.venice.common.VeniceSystemStoreType
    • com.linkedin.venice.meta.VeniceUserStoreType
    • com.linkedin.venice.meta.Version.PushType
    • com.linkedin.venice.meta.VersionStatus
    • com.linkedin.venice.meta.ViewParameterKeys
    • com.linkedin.alpini.netty4.handlers.VIPRequestHandler.State
    • com.linkedin.venice.schema.vson.VsonTypes
    • com.linkedin.venice.schema.writecompute.WriteComputeOperation