Index (venice API)

A B C D E F G H I J K L M N O P Q R S T U V W X Z _
All Classes All Packages

A

ABORT_MIGRATION - com.linkedin.venice.Command
ABORT_MIGRATION - com.linkedin.venice.controller.kafka.protocol.enums.AdminMessageType
ABORT_MIGRATION - com.linkedin.venice.controllerapi.ControllerRoute
abortMigration(Admin) - Method in class com.linkedin.venice.controller.server.StoresRoutes
abortMigration(String, String) - Method in class com.linkedin.venice.controllerapi.ControllerClient: This command should be sent to src controller, not dest controller
abortMigration(String, String, String) - Method in interface com.linkedin.venice.controller.Admin
abortMigration(String, String, String) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin: Abort store migration by resetting migration flag at the source cluster, resetting storeConfig, and updating "cluster" in "/storeConfigs" znode back to the source cluster.
abortMigration(String, String, String) - Method in class com.linkedin.venice.controller.VeniceParentHelixAdmin: Abort store migration by sending a ABORT_MIGRATION admin message.
abortMigration(String, String, String, String, boolean, boolean[]) - Static method in class com.linkedin.venice.AdminTool
AbortMigration - Class in com.linkedin.venice.controller.kafka.protocol.admin
AbortMigration() - Constructor for class com.linkedin.venice.controller.kafka.protocol.admin.AbortMigration: Default constructor.
AbortMigration(CharSequence, CharSequence, CharSequence) - Constructor for class com.linkedin.venice.controller.kafka.protocol.admin.AbortMigration: All-args constructor.
AbstractAsyncFuture<T> - Class in com.linkedin.alpini.base.concurrency.impl: Created by acurtis on 5/1/18.
AbstractAsyncFuture() - Constructor for class com.linkedin.alpini.base.concurrency.impl.AbstractAsyncFuture
AbstractAvroChunkingAdapter<T> - Class in com.linkedin.davinci.storage.chunking: Read compute and write compute chunking adapter
AbstractAvroChunkingAdapter() - Constructor for class com.linkedin.davinci.storage.chunking.AbstractAvroChunkingAdapter
AbstractAvroComputeRequestBuilder<K> - Class in com.linkedin.venice.client.store: This abstract class contains all the common field and APIs for compute request builder; for each new compute request version, there will be a new builder class that extends this class and the new builder will include customized fields and APIs.
AbstractAvroComputeRequestBuilder(AvroGenericReadComputeStoreClient, Schema) - Constructor for class com.linkedin.venice.client.store.AbstractAvroComputeRequestBuilder
AbstractAvroStoreClient<K,V> - Class in com.linkedin.venice.client.store
AbstractAvroStoreClient(TransportClient, boolean, ClientConfig) - Constructor for class com.linkedin.venice.client.store.AbstractAvroStoreClient
AbstractClientRoutingStrategy - Class in com.linkedin.venice.fastclient.meta
AbstractClientRoutingStrategy() - Constructor for class com.linkedin.venice.fastclient.meta.AbstractClientRoutingStrategy
AbstractCoalescingBufferQueue10294 - Class in io.netty.channel: Forked from Netty's AbstractCoalescingBufferQueue (4.1.42) Includes fix to guard readableBytes from re-entry.
AbstractCoalescingBufferQueue10294(Channel, int) - Constructor for class io.netty.channel.AbstractCoalescingBufferQueue10294: Create a new instance.
AbstractHttp2StreamFrameCodec - Class in com.linkedin.alpini.netty4.http2: A copy of the netty Http2StreamFrameToHttpObjectCodec except with the methods which actually return the converted objects have been made abstract.
AbstractHttp2StreamFrameCodec(boolean) - Constructor for class com.linkedin.alpini.netty4.http2.AbstractHttp2StreamFrameCodec
AbstractMapReduceTask - Class in com.linkedin.venice.hadoop: Class for commonalities between AbstractVeniceMapper and VeniceReducer.
AbstractMapReduceTask() - Constructor for class com.linkedin.venice.hadoop.AbstractMapReduceTask
AbstractPartitionStateModel - Class in com.linkedin.davinci.helix: An abstraction of Helix State model behavior registry that defines how participants (Storage node) fetch data from Kafka.
AbstractPartitionStateModel(VeniceIngestionBackend, ReadOnlyStoreRepository, VeniceStoreVersionConfig, int, CompletableFuture<HelixPartitionStatusAccessor>, String) - Constructor for class com.linkedin.davinci.helix.AbstractPartitionStateModel
AbstractPollStrategy - Class in com.linkedin.venice.unit.kafka.consumer.poll: A base class which encapsulates the common plumbing needed by all PollStrategy implementations.
AbstractPollStrategy(boolean) - Constructor for class com.linkedin.venice.unit.kafka.consumer.poll.AbstractPollStrategy
AbstractPollStrategy(boolean, int) - Constructor for class com.linkedin.venice.unit.kafka.consumer.poll.AbstractPollStrategy
AbstractPushMonitor - Class in com.linkedin.venice.pushmonitor: AbstractPushMonitor is a high level abstraction that manages OfflinePushStatus.
AbstractPushMonitor(String, OfflinePushAccessor, StoreCleaner, ReadWriteStoreRepository, RoutingDataRepository, AggPushHealthStats, RealTimeTopicSwitcher, ClusterLockManager, String, List<String>, HelixAdminClient, VeniceControllerConfig, PushStatusStoreReader) - Constructor for class com.linkedin.venice.pushmonitor.AbstractPushMonitor
AbstractQOS - Class in com.linkedin.alpini.base.queuing: Created by acurtis on 7/27/17.
AbstractQOS(Map<QOS, Integer>) - Constructor for class com.linkedin.alpini.base.queuing.AbstractQOS
AbstractQOSBasedQueue<T extends QOSBasedRequestRunnable> - Class in com.linkedin.alpini.base.queuing: Abstract base class for QOS priority queues.
AbstractQOSBasedQueue(Map<QOS, Integer>) - Constructor for class com.linkedin.alpini.base.queuing.AbstractQOSBasedQueue
AbstractQuantileEstimation<SAMPLE extends AbstractQuantileEstimation.AbstractSample<SAMPLE>> - Class in com.linkedin.alpini.base.statistics: A memory efficient abstract implementation for calculating quantile summaries.
AbstractQuantileEstimation(double, int) - Constructor for class com.linkedin.alpini.base.statistics.AbstractQuantileEstimation
AbstractQuantileEstimation(double, int, ConcurrentAccumulator.Mode) - Constructor for class com.linkedin.alpini.base.statistics.AbstractQuantileEstimation
AbstractQuantileEstimation.AbstractSample<SAMPLE extends AbstractQuantileEstimation.AbstractSample<SAMPLE>> - Class in com.linkedin.alpini.base.statistics
AbstractQuantileEstimation.Data - Class in com.linkedin.alpini.base.statistics
AbstractQuantileEstimation.Quantile - Class in com.linkedin.alpini.base.statistics
AbstractQuantileEstimation.Quantiles - Class in com.linkedin.alpini.base.statistics
AbstractRecordStreamDecoder<ENVELOPE,K,V> - Class in com.linkedin.venice.client.store.streaming: Streaming callback for batch-get/compute.
AbstractRecordStreamDecoder(List<K>, TrackingStreamingCallback<K, V>, Executor) - Constructor for class com.linkedin.venice.client.store.streaming.AbstractRecordStreamDecoder
AbstractRoute - Class in com.linkedin.venice.controller.server
AbstractRoute(boolean, Optional<DynamicAccessController>) - Constructor for class com.linkedin.venice.controller.server.AbstractRoute: Default constructor for different controller request routes.
AbstractSample() - Constructor for class com.linkedin.alpini.base.statistics.AbstractQuantileEstimation.AbstractSample
AbstractSchemaEntrySerializer<T extends GeneratedSchemaEntry> - Class in com.linkedin.venice.helix
AbstractSchemaEntrySerializer() - Constructor for class com.linkedin.venice.helix.AbstractSchemaEntrySerializer
AbstractShutdownableResource<R> - Class in com.linkedin.alpini.base.registry: A simplified implementation of a ShutdownableResource.
AbstractShutdownableResource(R) - Constructor for class com.linkedin.alpini.base.registry.AbstractShutdownableResource
AbstractStateModelFactory - Class in com.linkedin.davinci.helix: ModelFactory manages Helix state model creation.
AbstractStateModelFactory(VeniceIngestionBackend, VeniceConfigLoader, ExecutorService, ParticipantStateTransitionStats, ReadOnlyStoreRepository, CompletableFuture<HelixPartitionStatusAccessor>, String) - Constructor for class com.linkedin.davinci.helix.AbstractStateModelFactory
AbstractStorageEngine<Partition extends AbstractStoragePartition> - Class in com.linkedin.davinci.store: A base storage abstract class which is actually responsible for data persistence.
AbstractStorageEngine(String, InternalAvroSpecificSerializer<StoreVersionState>, InternalAvroSpecificSerializer<PartitionState>) - Constructor for class com.linkedin.davinci.store.AbstractStorageEngine
AbstractStoragePartition - Class in com.linkedin.davinci.store: An abstract implementation of a storage partition.
AbstractStoragePartition(Integer) - Constructor for class com.linkedin.davinci.store.AbstractStoragePartition
AbstractStore - Class in com.linkedin.venice.meta: This is an abstraction of metadata maintained per Store.
AbstractStore() - Constructor for class com.linkedin.venice.meta.AbstractStore
AbstractStore.StoreVersionSupplier - Interface in com.linkedin.venice.meta
AbstractStoreBufferService - Class in com.linkedin.davinci.kafka.consumer: Abstract class capturing the responsibilities of drainers threads doing store ingestion.
AbstractStoreBufferService() - Constructor for class com.linkedin.davinci.kafka.consumer.AbstractStoreBufferService
AbstractStoreMetadata - Class in com.linkedin.venice.fastclient.meta
AbstractStoreMetadata(ClientConfig) - Constructor for class com.linkedin.venice.fastclient.meta.AbstractStoreMetadata
AbstractVeniceAggStats<T extends AbstractVeniceStats> - Class in com.linkedin.venice.stats
AbstractVeniceAggStats(MetricsRepository) - Constructor for class com.linkedin.venice.stats.AbstractVeniceAggStats
AbstractVeniceAggStats(MetricsRepository, StatsSupplier<T>) - Constructor for class com.linkedin.venice.stats.AbstractVeniceAggStats
AbstractVeniceAggStats(String, MetricsRepository, StatsSupplier<T>) - Constructor for class com.linkedin.venice.stats.AbstractVeniceAggStats
AbstractVeniceAggStoreStats<T extends AbstractVeniceStats> - Class in com.linkedin.venice.stats: This class is an aggregate place that keeps stats objects for multiple stores.
AbstractVeniceAggStoreStats(MetricsRepository, ReadOnlyStoreRepository, boolean) - Constructor for class com.linkedin.venice.stats.AbstractVeniceAggStoreStats
AbstractVeniceAggStoreStats(MetricsRepository, StatsSupplier<T>, ReadOnlyStoreRepository, boolean) - Constructor for class com.linkedin.venice.stats.AbstractVeniceAggStoreStats
AbstractVeniceAggStoreStats(String, MetricsRepository, StatsSupplier<T>, ReadOnlyStoreRepository, boolean) - Constructor for class com.linkedin.venice.stats.AbstractVeniceAggStoreStats
AbstractVeniceAggVersionedStats<STATS,STATS_REPORTER extends AbstractVeniceStatsReporter<STATS>> - Class in com.linkedin.davinci.stats
AbstractVeniceAggVersionedStats(MetricsRepository, ReadOnlyStoreRepository, Supplier<STATS>, StatsSupplier<STATS_REPORTER>, boolean) - Constructor for class com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats
AbstractVeniceFilter<INPUT_VALUE> - Class in com.linkedin.venice.hadoop: An abstraction to filter given data type.
AbstractVeniceFilter(VeniceProperties) - Constructor for class com.linkedin.venice.hadoop.AbstractVeniceFilter
AbstractVeniceHttpStats - Class in com.linkedin.venice.stats
AbstractVeniceHttpStats(MetricsRepository, String, RequestType) - Constructor for class com.linkedin.venice.stats.AbstractVeniceHttpStats
AbstractVeniceMapper<INPUT_KEY,INPUT_VALUE> - Class in com.linkedin.venice.hadoop: An abstraction of the mapper that would return serialized, and potentially compressed, Avro key/value pairs.
AbstractVeniceMapper() - Constructor for class com.linkedin.venice.hadoop.AbstractVeniceMapper
AbstractVeniceProducer<K,V> - Class in com.linkedin.venice.producer: A generic implementation of the VeniceProducer interface
AbstractVeniceProducer() - Constructor for class com.linkedin.venice.producer.AbstractVeniceProducer
AbstractVeniceRecordReader<INPUT_KEY,INPUT_VALUE> - Class in com.linkedin.venice.hadoop
AbstractVeniceRecordReader(String) - Constructor for class com.linkedin.venice.hadoop.AbstractVeniceRecordReader
AbstractVeniceService - Class in com.linkedin.venice.service: Blueprint for all Services initiated from Venice Server
AbstractVeniceService() - Constructor for class com.linkedin.venice.service.AbstractVeniceService
AbstractVeniceService.ServiceState - Enum in com.linkedin.venice.service
AbstractVeniceStats - Class in com.linkedin.venice.stats
AbstractVeniceStats(MetricsRepository, String) - Constructor for class com.linkedin.venice.stats.AbstractVeniceStats
AbstractVeniceStatsReporter<STATS> - Class in com.linkedin.davinci.stats
AbstractVeniceStatsReporter(MetricsRepository, String) - Constructor for class com.linkedin.davinci.stats.AbstractVeniceStatsReporter
AbstractVeniceWriter<K,V,U> - Class in com.linkedin.venice.writer: A base class which users of VeniceWriter can leverage in order to make unit tests easier.
AbstractVeniceWriter(String) - Constructor for class com.linkedin.venice.writer.AbstractVeniceWriter
AbstractVsonSchemaAdapter<T> - Class in com.linkedin.venice.schema.vson: Deprecated.
accept(double) - Method in class com.linkedin.alpini.base.statistics.DoubleQuantileEstimation
accept(double) - Method in class com.linkedin.alpini.base.statistics.Welfords
accept(long) - Method in class com.linkedin.alpini.base.statistics.LongQuantileEstimation
accept(long) - Method in class com.linkedin.alpini.base.statistics.Welfords.LongWelford
accept(SAMPLE) - Method in class com.linkedin.alpini.base.statistics.AbstractQuantileEstimation
accept(T) - Method in class com.linkedin.alpini.base.concurrency.ComplexAccumulator: Adds the given value.
accept(T) - Method in class com.linkedin.alpini.base.concurrency.ConcurrentAccumulator: Adds the given value.
accept(T) - Method in class com.linkedin.alpini.base.concurrency.ThreadedAccumulator
accept(T) - Method in class com.linkedin.alpini.base.statistics.GenericQuantileEstimation
acceptBoundary(String) - Method in class com.linkedin.alpini.netty4.handlers.HttpContentUnwrap
acceptEither(CompletionStage<? extends T>, Consumer<? super T>) - Method in class com.linkedin.alpini.base.concurrency.impl.AbstractAsyncFuture
acceptEither(CompletionStage<? extends T>, Consumer<? super T>) - Method in class com.linkedin.alpini.base.concurrency.impl.FailedAsyncFuture
acceptEither(CompletionStage<? extends V>, Consumer<? super V>) - Method in class com.linkedin.alpini.base.concurrency.CompletableFutureTask
acceptEitherAsync(CompletionStage<? extends T>, Consumer<? super T>) - Method in class com.linkedin.alpini.base.concurrency.impl.AbstractAsyncFuture
acceptEitherAsync(CompletionStage<? extends T>, Consumer<? super T>) - Method in class com.linkedin.alpini.base.concurrency.impl.FailedAsyncFuture
acceptEitherAsync(CompletionStage<? extends T>, Consumer<? super T>, Executor) - Method in class com.linkedin.alpini.base.concurrency.impl.AbstractAsyncFuture
acceptEitherAsync(CompletionStage<? extends T>, Consumer<? super T>, Executor) - Method in class com.linkedin.alpini.base.concurrency.impl.FailedAsyncFuture
acceptEitherAsync(CompletionStage<? extends V>, Consumer<? super V>) - Method in class com.linkedin.alpini.base.concurrency.CompletableFutureTask
acceptEitherAsync(CompletionStage<? extends V>, Consumer<? super V>, Executor) - Method in class com.linkedin.alpini.base.concurrency.CompletableFutureTask
acceptInboundMessage(Object) - Method in class com.linkedin.alpini.netty4.handlers.HttpContentUnwrap
acceptInboundMessage(Object) - Method in class com.linkedin.alpini.netty4.handlers.HttpMultiPartContentAggregator
acceptInboundMessage(Object) - Method in class com.linkedin.alpini.netty4.http2.AbstractHttp2StreamFrameCodec
acceptInboundMessage(Object) - Method in class io.netty.handler.codec.EspressoMessageAggregator
acceptInboundMessage(Object) - Method in class io.netty.handler.codec.EspressoMessageToMessageDecoder: Returns true if the given message should be handled.
acceptOutboundMessage(Object) - Method in class com.linkedin.alpini.netty4.handlers.BasicHttpContentEncoder
acceptOutboundMessage(Object) - Method in class io.netty.handler.codec.EspressoMessageToMessageEncoder
acceptOutboundMessage(Object) - Method in class io.netty.handler.codec.http.EspressoHttpObjectEncoder
ACCESS_CONTROL - com.linkedin.venice.Arg
ACCESS_CONTROLLED - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
ACCESS_PERMISSION - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
accessControlled - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore
accessControlled - Variable in class com.linkedin.venice.meta.systemstore.schemas.StoreProperties
accessControlled - Variable in class com.linkedin.venice.systemstore.schemas.StoreProperties: Store-level ACL switch.
AccessController - Interface in com.linkedin.venice.acl: An AccessController allows a request to be checked against an Access Control List (ACL).
accumulate(LongQuantileEstimation.Sample) - Method in class com.linkedin.alpini.base.statistics.LongStatsAggregator.LongData
AceEntry - Class in com.linkedin.venice.authorization: Represents an Access Control Entry.
AceEntry(Principal, Method, Permission) - Constructor for class com.linkedin.venice.authorization.AceEntry: Creates an Access Control entry
ACL_CHECK_FAILURE_WARN_MESSAGE_PREFIX - Static variable in class com.linkedin.venice.controller.server.VeniceRouteHandler
ACL_PERMS - com.linkedin.venice.Arg
AclBinding - Class in com.linkedin.venice.authorization: Represents an Access Control Binding.
AclBinding(Resource) - Constructor for class com.linkedin.venice.authorization.AclBinding: Creates an Access Control Binding for a given resource with empty AceEntries.
AclCreationDeletionListener - Class in com.linkedin.venice.acl: Update access controller resource list when a store is created/deleted
AclCreationDeletionListener(DynamicAccessController) - Constructor for class com.linkedin.venice.acl.AclCreationDeletionListener
AclException - Exception in com.linkedin.venice.acl
AclException() - Constructor for exception com.linkedin.venice.acl.AclException
AclException(String) - Constructor for exception com.linkedin.venice.acl.AclException
AclException(String, Throwable) - Constructor for exception com.linkedin.venice.acl.AclException
AclException(String, Throwable, boolean, boolean) - Constructor for exception com.linkedin.venice.acl.AclException
AclException(Throwable) - Constructor for exception com.linkedin.venice.acl.AclException
AclResponse - Class in com.linkedin.venice.controllerapi
AclResponse() - Constructor for class com.linkedin.venice.controllerapi.AclResponse
acquire() - Method in interface com.linkedin.alpini.base.pool.AsyncPool
acquire() - Method in class com.linkedin.alpini.base.pool.impl.AsyncPoolImpl
acquire() - Method in class com.linkedin.alpini.base.pool.impl.AsyncQOSPoolImpl
acquire() - Method in class com.linkedin.alpini.netty4.pool.EspressoSimpleChannelPool
acquire() - Method in class com.linkedin.alpini.netty4.pool.FastSimpleChannelPool
acquire() - Method in class com.linkedin.alpini.netty4.pool.Http2AwareChannelPool
acquire(EventLoop, String, String, QOS) - Method in interface com.linkedin.alpini.netty4.pool.ChannelPoolManager: Acquire a channel from the pool.
acquire(EventLoop, String, String, QOS) - Method in class com.linkedin.alpini.netty4.pool.ChannelPoolManagerImpl
acquire(EventLoop, String, String, QOS) - Method in class com.linkedin.alpini.netty4.pool.SimpleChannelPoolManagerImpl
acquire(Promise<Channel>) - Method in class com.linkedin.alpini.netty4.pool.EspressoFixedChannelPool
acquire(Promise<Channel>) - Method in class com.linkedin.alpini.netty4.pool.EspressoSimpleChannelPool
acquire(Promise<Channel>) - Method in class com.linkedin.alpini.netty4.pool.FastFixedChannelPool
acquire(Promise<Channel>) - Method in class com.linkedin.alpini.netty4.pool.FastSimpleChannelPool
acquire(Promise<Channel>) - Method in class com.linkedin.alpini.netty4.pool.FixedChannelPoolImpl
acquire(Promise<Channel>) - Method in class com.linkedin.alpini.netty4.pool.FixedFastChannelPoolImpl
acquire(Promise<Channel>) - Method in class com.linkedin.alpini.netty4.pool.Http2AwareChannelPool
acquire(String, QOS) - Method in interface com.linkedin.alpini.base.pool.AsyncQOSPool
acquire(String, QOS) - Method in class com.linkedin.alpini.base.pool.impl.AsyncQOSPoolImpl
acquire(String, String, QOS) - Method in interface com.linkedin.alpini.netty4.pool.ChannelPoolManager: Acquire a channel from the pool.
acquire(String, String, QOS) - Method in class com.linkedin.alpini.netty4.pool.ChannelPoolManagerImpl
acquire(String, String, QOS) - Method in class com.linkedin.alpini.netty4.pool.SimpleChannelPoolManagerImpl
acquire0() - Method in class com.linkedin.alpini.base.pool.impl.AsyncPoolImpl
acquire0(Promise<Channel>) - Method in class com.linkedin.alpini.netty4.pool.Http2AwareChannelPool
acquire0(String, QOS) - Method in class com.linkedin.alpini.base.pool.impl.AsyncQOSPoolImpl
acquireCallTracker() - Method in interface com.linkedin.alpini.netty4.pool.ChannelPoolManager.Stats: Call tracker for the ChannelPoolManager.acquire(String, String, QOS) method
acquireConnectSemaphore() - Method in class com.linkedin.alpini.netty4.pool.FastSimpleChannelPool
acquireConnectSemaphore() - Method in class com.linkedin.alpini.netty4.pool.FixedFastChannelPoolImpl
acquiredChannelCount() - Method in class com.linkedin.alpini.netty4.pool.EspressoFixedChannelPool: Returns the number of acquired channels that this pool thinks it has.
acquiredChannelCount() - Method in class com.linkedin.alpini.netty4.pool.FastFixedChannelPool: Returns the number of acquired channels that this pool thinks it has.
acquiredChannelCount() - Method in class com.linkedin.alpini.netty4.pool.FixedChannelPoolImpl
acquiredChannelCount() - Method in class com.linkedin.alpini.netty4.pool.FixedFastChannelPoolImpl
acquireSharedProducer(String) - Method in class com.linkedin.venice.pubsub.adapter.PubSubSharedProducerFactory
ACTION_DISABLE - Static variable in class com.linkedin.venice.router.api.VenicePathParser
ACTION_ENABLE - Static variable in class com.linkedin.venice.router.api.VenicePathParser
ACTIVE_ACTIVE - com.linkedin.venice.meta.DataReplicationPolicy: Samza job per colo pushes to local real-time topic.
ACTIVE_ACTIVE_ENABLED_ON_CONTROLLER - Static variable in class com.linkedin.venice.ConfigKeys: Whether A/A is enabled on the controller.
ACTIVE_ACTIVE_NOT_ENABLED - com.linkedin.venice.stats.StatsErrorCode: This metric should not be emitted as it is a metric specific to an A/A store.
ACTIVE_ACTIVE_REAL_TIME_SOURCE_FABRIC_LIST - Static variable in class com.linkedin.venice.ConfigKeys: A list of fabrics that are source(s) of the active active real time replication.
ACTIVE_ACTIVE_REPLICATION_ENABLED - com.linkedin.venice.Arg
ACTIVE_ACTIVE_REPLICATION_ENABLED - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
ACTIVE_ELEM_TS_FIELD_NAME - Static variable in class com.linkedin.venice.schema.rmd.v1.CollectionRmdTimestamp
ACTIVE_ELEM_TS_FIELD_POS - Static variable in class com.linkedin.venice.schema.rmd.v1.CollectionRmdTimestamp: Client readable elements that haven't been deleted yet.
ActiveActiveProducerCallback - Class in com.linkedin.davinci.kafka.consumer
ActiveActiveProducerCallback(LeaderFollowerStoreIngestionTask, PubSubMessage<KafkaKey, KafkaMessageEnvelope, Long>, PartitionConsumptionState, LeaderProducedRecordContext, int, String, long) - Constructor for class com.linkedin.davinci.kafka.consumer.ActiveActiveProducerCallback
activeActiveReplicationEnabled - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore: A command option to enable/disable Active/Active replication feature for a store
activeActiveReplicationEnabled - Variable in class com.linkedin.venice.systemstore.schemas.StoreProperties: Whether or not active/active replication is enabled for hybrid stores; eventually this config will replace native replication flag, when all stores are on A/A
activeActiveReplicationEnabled - Variable in class com.linkedin.venice.systemstore.schemas.StoreVersion: Whether or not active/active replication is enabled for hybrid stores; eventually this config will replace native replication flag, when all stores are on A/A
ActiveActiveStoreIngestionTask - Class in com.linkedin.davinci.kafka.consumer: This class contains logic that SNs must perform if a store-version is running in Active/Active mode.
ActiveActiveStoreIngestionTask(StoreIngestionTaskFactory.Builder, Store, Version, Properties, BooleanSupplier, VeniceStoreVersionConfig, int, boolean, Optional<ObjectCacheBackend>) - Constructor for class com.linkedin.davinci.kafka.consumer.ActiveActiveStoreIngestionTask
activeAllocations() - Method in class com.linkedin.alpini.base.safealloc.SafeAllocatorMetric
activeCount() - Method in interface com.linkedin.alpini.netty4.pool.ChannelPoolManager: Returns the total number of channels that are in use.
activeCount() - Method in interface com.linkedin.alpini.netty4.pool.ChannelPoolManager.Stats: The number of active (checked out) channels
activeCount() - Method in class com.linkedin.alpini.netty4.pool.ChannelPoolManagerImpl
activeCount() - Method in class com.linkedin.alpini.netty4.pool.SimpleChannelPoolManagerImpl
activeRequestCount() - Method in class com.linkedin.alpini.netty4.handlers.ClientConnectionTracker.ConnectionStats
activeStreamsCountHandler(ActiveStreamsCountHandler) - Method in class com.linkedin.alpini.netty4.http2.Http2PipelineInitializer.Builder
ActiveStreamsCountHandler - Class in io.netty.handler.codec.http2: Counts the number of the active HTTP/2 Streams
ActiveStreamsCountHandler() - Constructor for class io.netty.handler.codec.http2.ActiveStreamsCountHandler
activeThreadCount() - Method in class com.linkedin.venice.controller.spark.VeniceSparkEmbeddedJettyServer
adapt(TimeoutProcessor) - Static method in interface com.linkedin.alpini.router.api.RouterTimeoutProcessor
adapt(PartitionFinder<K>, Executor) - Static method in interface com.linkedin.alpini.router.api.AsyncPartitionFinder
adapt(Schema, Object) - Method in interface com.linkedin.venice.schema.SchemaAdapter
adaptSSLFactory(SslFactory) - Static method in interface com.linkedin.alpini.netty4.ssl.SSLEngineFactory
adaptToSchema(Schema, Object) - Static method in interface com.linkedin.venice.schema.SchemaAdapter: Checks if it is possible for some value to be modified to adapt to the provided schema type.
add(int) - Method in class com.linkedin.venice.serializer.ArrayBasedPrimitiveIntegerSet: To explicitly use this GC optimized API, declare variable type as ArrayBasedPrimitiveIntegerSet instead of Set.
add(int, E) - Method in class com.linkedin.venice.utils.SparseConcurrentList
add(int, E) - Method in class com.linkedin.venice.utils.SparseConcurrentListWithOffset
add(long) - Method in class com.linkedin.alpini.base.misc.MemoryPressureIndexMonitor.ByteCount
add(long) - Method in class com.linkedin.davinci.utils.StoragePartitionDiskUsage: Adds a usage size to the partition
add(TimeValue) - Method in class com.linkedin.alpini.base.misc.TimeValue
add(AbstractVeniceFilter<INPUT_VALUE>) - Method in class com.linkedin.venice.hadoop.FilterChain
add(PubSubMessageHeader) - Method in class com.linkedin.venice.pubsub.api.PubSubMessageHeaders
add(E) - Method in class com.linkedin.alpini.base.concurrency.ArraySortedSet
add(E) - Method in class com.linkedin.venice.utils.collections.ArrayCollection
add(E) - Method in class com.linkedin.venice.utils.SparseConcurrentList
add(ByteBuf) - Method in class io.netty.channel.AbstractCoalescingBufferQueue10294: Add a buffer to the end of the queue.
add(ByteBuf, ChannelFutureListener) - Method in class io.netty.channel.AbstractCoalescingBufferQueue10294: Add a buffer to the end of the queue and associate a listener with it that should be completed when all the buffers bytes have been consumed from the queue and written.
add(ByteBuf, ChannelPromise) - Method in class io.netty.channel.AbstractCoalescingBufferQueue10294: Add a buffer to the end of the queue and associate a promise with it that should be completed when all the buffer's bytes have been consumed from the queue and written.
add(Channel) - Method in class com.linkedin.alpini.netty4.handlers.AllChannelsHandler
add(HttpHeaders) - Method in class com.linkedin.alpini.netty4.http2.Http1Headers
add(CharSequence, int) - Method in interface com.linkedin.alpini.base.misc.Headers
add(CharSequence, int) - Method in class com.linkedin.alpini.netty4.misc.BasicHeaders
add(CharSequence, long) - Method in interface com.linkedin.alpini.base.misc.Headers
add(CharSequence, Iterable<?>) - Method in class com.linkedin.alpini.netty4.http2.Http1Headers
add(CharSequence, Object) - Method in interface com.linkedin.alpini.base.misc.Headers
add(CharSequence, Object) - Method in class com.linkedin.alpini.netty4.http2.Http1Headers
add(CharSequence, Object) - Method in class com.linkedin.alpini.netty4.misc.BasicHeaders
add(Integer) - Method in class com.linkedin.venice.serializer.ArrayBasedPrimitiveIntegerSet
add(String, byte[]) - Method in class com.linkedin.venice.pubsub.api.PubSubMessageHeaders
add(String, Boolean) - Method in class com.linkedin.venice.controllerapi.QueryParams
add(String, Integer) - Method in class com.linkedin.venice.controllerapi.QueryParams
add(String, Iterable<?>) - Method in class com.linkedin.alpini.netty4.http2.Http1Headers
add(String, Long) - Method in class com.linkedin.venice.controllerapi.QueryParams
add(String, Object) - Method in class com.linkedin.alpini.netty4.http2.Http1Headers
add(String, String) - Method in class com.linkedin.venice.controllerapi.QueryParams
add(String, Optional<TYPE>) - Method in class com.linkedin.venice.controllerapi.QueryParams
add(T) - Method in class com.linkedin.alpini.base.queuing.QOSBasedMultiQueue
add(T) - Method in class com.linkedin.alpini.base.queuing.QOSBasedQueue
add(T) - Method in class com.linkedin.alpini.base.queuing.QOSFCFSQueue
add(T) - Method in interface com.linkedin.alpini.base.queuing.SimpleQueue
add(T) - Method in class com.linkedin.davinci.kafka.consumer.MemoryBoundBlockingQueue
add(T) - Method in class com.linkedin.venice.utils.ExpiringSet
add(T, long, TimeUnit) - Method in class com.linkedin.venice.utils.ExpiringSet
ADD_DERIVED_SCHEMA - com.linkedin.venice.Command
ADD_DERIVED_SCHEMA - com.linkedin.venice.controllerapi.ControllerRoute
ADD_NULL_TO_UNION - com.linkedin.venice.etl.ETLValueSchemaTransformation
ADD_SCHEMA - com.linkedin.venice.Command
ADD_SCHEMA_TO_ZK - com.linkedin.venice.Command
ADD_TO_STORE_ACL - com.linkedin.venice.Command
ADD_VALUE_SCHEMA - com.linkedin.venice.authorization.Method
ADD_VALUE_SCHEMA - com.linkedin.venice.controllerapi.ControllerRoute
ADD_VERSION - com.linkedin.venice.authorization.Method
ADD_VERSION - com.linkedin.venice.controller.kafka.protocol.enums.AdminMessageType
ADD_VERSION - com.linkedin.venice.controllerapi.ControllerRoute
addAce(Resource, AceEntry) - Method in interface com.linkedin.venice.authorization.AuthorizerService: This will add a single AceEntry to the existing AceEntries for a resource.
addAce(Resource, AceEntry) - Method in class com.linkedin.venice.controller.MockVeniceAuthorizer
addAceEntries(Collection<AceEntry>) - Method in class com.linkedin.venice.authorization.AclBinding: Add a list of AceEntry to the existing list of Aces.
addAceEntry(AceEntry) - Method in class com.linkedin.venice.authorization.AclBinding: Add one AceEntry to the existing list of Aces.
addAcl(String) - Method in interface com.linkedin.venice.acl.DynamicAccessController: Add a resource to the resource list.
addAfter(C, ChannelHandler...) - Method in class com.linkedin.alpini.netty4.handlers.SimpleChannelInitializer
addAfter(C, EventExecutorGroup, String, ChannelHandler) - Method in class com.linkedin.alpini.netty4.handlers.SimpleChannelInitializer
addAfter(C, String, ChannelHandler) - Method in class com.linkedin.alpini.netty4.handlers.SimpleChannelInitializer
addAfter(ChannelHandler...) - Method in class com.linkedin.alpini.netty4.handlers.SimpleChannelInitializer
addAfter(EventExecutorGroup, ChannelHandler...) - Method in class com.linkedin.alpini.netty4.handlers.SimpleChannelInitializer
addAfter(EventExecutorGroup, String, ChannelHandler) - Method in class com.linkedin.alpini.netty4.handlers.SimpleChannelInitializer
addAfter(String, ChannelHandler) - Method in class com.linkedin.alpini.netty4.handlers.SimpleChannelInitializer
addAll(int, Collection<? extends E>) - Method in class com.linkedin.venice.utils.SparseConcurrentList
addAll(int, Collection<? extends E>) - Method in class com.linkedin.venice.utils.SparseConcurrentListWithOffset
addAll(ComplementSet<T>) - Method in class com.linkedin.venice.utils.ComplementSet
addAll(Collection<? extends E>) - Method in class com.linkedin.alpini.base.concurrency.ArraySortedSet
addAll(Collection<? extends E>) - Method in class com.linkedin.venice.utils.collections.ArrayCollection
addAll(Collection<? extends E>) - Method in class com.linkedin.venice.utils.SparseConcurrentList
addAll(Collection<? extends Channel>) - Method in class com.linkedin.alpini.netty4.handlers.AllChannelsHandler
addAll(Collection<? extends T>) - Method in class com.linkedin.davinci.kafka.consumer.MemoryBoundBlockingQueue
addAllAbsent(Collection<? extends E>) - Method in class com.linkedin.venice.utils.SparseConcurrentList
addBeforeChunkAggregator(String, Supplier<? extends CHANNEL_HANDLER>) - Method in interface com.linkedin.alpini.router.impl.Router.PipelineFactory
addBeforeChunkAggregator(String, Supplier<? extends CHANNEL_HANDLER>) - Method in interface com.linkedin.alpini.router.impl.RouterPipelineFactory
addBeforeChunkAggregator(String, Supplier<? extends ChannelHandler>) - Method in class com.linkedin.alpini.router.api.ScatterGatherHelper.Builder
addBeforeChunkAggregator(String, Supplier<? extends ChannelHandler>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
addBeforeChunkAggregator(String, Supplier<? extends ChannelHandler>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4PipelineFactory
addBeforeChunkAggregator(Consumer<ChannelPipeline>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4PipelineFactory
addBeforeHttpRequestHandler(String, Supplier<? extends CHANNEL_HANDLER>) - Method in interface com.linkedin.alpini.router.impl.Router.PipelineFactory
addBeforeHttpRequestHandler(String, Supplier<? extends CHANNEL_HANDLER>) - Method in interface com.linkedin.alpini.router.impl.RouterPipelineFactory
addBeforeHttpRequestHandler(String, Supplier<? extends ChannelHandler>) - Method in class com.linkedin.alpini.router.api.ScatterGatherHelper.Builder
addBeforeHttpRequestHandler(String, Supplier<? extends ChannelHandler>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
addBeforeHttpRequestHandler(String, Supplier<? extends ChannelHandler>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4PipelineFactory
addBeforeHttpRequestHandler(Consumer<ChannelPipeline>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4PipelineFactory
addBeforeHttpServerCodec(String, Supplier<?>) - Method in class com.linkedin.alpini.router.api.ScatterGatherHelper.Builder
addBeforeHttpServerCodec(String, Supplier<? extends CHANNEL_HANDLER>) - Method in interface com.linkedin.alpini.router.impl.Router.PipelineFactory
addBeforeHttpServerCodec(String, Supplier<? extends CHANNEL_HANDLER>) - Method in interface com.linkedin.alpini.router.impl.RouterPipelineFactory
addBeforeHttpServerCodec(String, Supplier<? extends ChannelHandler>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
addBeforeHttpServerCodec(String, Supplier<? extends ChannelHandler>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4PipelineFactory
addBeforeHttpServerCodec(Consumer<ChannelPipeline>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4PipelineFactory
addBeforeIdleStateHandler(String, Supplier<? extends CHANNEL_HANDLER>) - Method in interface com.linkedin.alpini.router.impl.Router.PipelineFactory
addBeforeIdleStateHandler(String, Supplier<? extends CHANNEL_HANDLER>) - Method in interface com.linkedin.alpini.router.impl.RouterPipelineFactory
addBeforeIdleStateHandler(String, Supplier<? extends ChannelHandler>) - Method in class com.linkedin.alpini.router.api.ScatterGatherHelper.Builder
addBeforeIdleStateHandler(String, Supplier<? extends ChannelHandler>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
addBeforeIdleStateHandler(String, Supplier<? extends ChannelHandler>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4PipelineFactory
addBeforeIdleStateHandler(Consumer<ChannelPipeline>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4PipelineFactory
addBootstrapFilter(Function<T, T>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
addBootstrapFilter(Function<T, T>) - Method in interface com.linkedin.alpini.router.impl.Router.Builder
addChannelToReadCompletePendingQueue() - Method in class io.netty.handler.codec.http2.EspressoHttp2MultiplexHandler.EspressoHttp2MultiplexHandlerStreamChannel
addChunkIntoContainer(CHUNKS_CONTAINER, int, byte[]) - Method in interface com.linkedin.davinci.storage.chunking.ChunkingAdapter: Used to incrementally add a {@param valueChunk} into the {@param CHUNKS_CONTAINER} container.
addChunkIntoContainer(ChunkedValueInputStream, int, byte[]) - Method in class com.linkedin.davinci.storage.chunking.AbstractAvroChunkingAdapter
addChunkIntoContainer(CompositeByteBuf, int, byte[]) - Method in class com.linkedin.davinci.storage.chunking.SingleGetChunkingAdapter
addChunkIntoContainer(ByteBuffer, int, byte[]) - Method in class com.linkedin.davinci.storage.chunking.BatchGetChunkingAdapter
addClusterConfig(VeniceControllerConfig) - Method in class com.linkedin.venice.controller.VeniceControllerMultiClusterConfig
addClusterfigChangeListener(ClusterConfigChangeListener) - Method in class com.linkedin.venice.helix.SafeHelixManager
addClusterToGrandCluster(String) - Method in interface com.linkedin.venice.controller.HelixAdminClient: Add the specified cluster as a resource to the grand cluster to be managed by HaaS controllers.
addClusterToGrandCluster(String) - Method in class com.linkedin.venice.controller.ZkHelixAdminClient
addConfigChangeListener(ScopedConfigChangeListener, HelixConfigScope.ConfigScopeProperty) - Method in class com.linkedin.venice.helix.SafeHelixManager
addConnectionPoolManager(PoolingNHttpClientConnectionManager) - Method in class com.linkedin.venice.stats.HttpConnectionPoolStats
addControllerListener(ControllerChangeListener) - Method in class com.linkedin.venice.helix.SafeHelixManager
addControllerMessageListener(MessageListener) - Method in class com.linkedin.venice.helix.SafeHelixManager
addCurrentStateChangeListener(CurrentStateChangeListener, String, String) - Method in class com.linkedin.venice.helix.SafeHelixManager
addDatabaseLookupLatency(double) - Method in class com.linkedin.davinci.listener.response.ReadResponse
addDerivedSchema(Admin) - Method in class com.linkedin.venice.controller.server.SchemaRoutes
addDerivedSchema(DerivedSchemaEntry) - Method in class com.linkedin.venice.schema.SchemaData
addDerivedSchema(String, int, String) - Method in class com.linkedin.venice.controllerapi.ControllerClient
addDerivedSchema(String, int, String, int) - Method in class com.linkedin.venice.controllerapi.ControllerClient
addDerivedSchema(String, DerivedSchemaEntry) - Method in class com.linkedin.venice.helix.HelixSchemaAccessor
addDerivedSchema(String, String, int) - Method in class com.linkedin.venice.helix.HelixReadWriteSchemaRepository
addDerivedSchema(String, String, int) - Method in class com.linkedin.venice.helix.HelixReadWriteSchemaRepositoryAdapter
addDerivedSchema(String, String, int) - Method in interface com.linkedin.venice.meta.ReadWriteSchemaRepository: Add a new derived schema for the given store and value schema id
addDerivedSchema(String, String, int, int) - Method in class com.linkedin.venice.helix.HelixReadWriteSchemaRepository
addDerivedSchema(String, String, int, int) - Method in class com.linkedin.venice.helix.HelixReadWriteSchemaRepositoryAdapter
addDerivedSchema(String, String, int, int) - Method in interface com.linkedin.venice.meta.ReadWriteSchemaRepository: Add a new derived schema for the given store by specifying derived schema id.
addDerivedSchema(String, String, int, int, String) - Method in interface com.linkedin.venice.controller.Admin: This method skips most precondition checks and is intended for only internal use.
addDerivedSchema(String, String, int, int, String) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin: Add a new derived schema for the given store with all specified properties.
addDerivedSchema(String, String, int, int, String) - Method in class com.linkedin.venice.controller.VeniceParentHelixAdmin: Unsupported operation in the parent controller.
addDerivedSchema(String, String, int, String) - Method in interface com.linkedin.venice.controller.Admin
addDerivedSchema(String, String, int, String) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin: Add a new derived schema for the given store with all specified properties and return a new DerivedSchemaEntry object containing the schema and its id.
addDerivedSchema(String, String, int, String) - Method in class com.linkedin.venice.controller.VeniceParentHelixAdmin: Add a new superset schema for the given store with all specified properties by sending a DERIVED_SCHEMA_CREATION admin message.
addExternalViewChangeListener(ExternalViewChangeListener) - Method in class com.linkedin.venice.helix.SafeHelixManager
addFilledSize(int) - Method in class com.linkedin.venice.hadoop.PushJobZstdConfig
addFirst(E) - Method in class com.linkedin.alpini.base.misc.DoublyLinkedList: Inserts the specified element at the beginning of this list.
addFirst(ByteBuf, ChannelPromise) - Method in class io.netty.channel.AbstractCoalescingBufferQueue10294: Add a buffer to the front of the queue and associate a promise with it that should be completed when all the buffer's bytes have been consumed from the queue and written.
addHandler(VeniceServerGrpcHandler) - Method in class com.linkedin.venice.listener.grpc.handlers.VeniceServerGrpcRequestProcessor
addIdealStateChangeListener(IdealStateChangeListener) - Method in class com.linkedin.venice.helix.SafeHelixManager
addIngestionIsolationToProperties(Properties) - Static method in class com.linkedin.venice.utils.TestUtils
addIngestionNotifier(VeniceNotifier) - Method in class com.linkedin.davinci.ingestion.DefaultIngestionBackend
addIngestionNotifier(VeniceNotifier) - Method in interface com.linkedin.davinci.ingestion.IngestionBackendBase
addIngestionNotifier(VeniceNotifier) - Method in class com.linkedin.davinci.ingestion.IsolatedIngestionBackend
addIngestionNotifier(VeniceNotifier) - Method in class com.linkedin.davinci.ingestion.main.MainIngestionMonitorService
addIngestionNotifier(VeniceNotifier) - Method in class com.linkedin.davinci.kafka.consumer.KafkaStoreIngestionService
addIngestionNotifier(VeniceNotifier) - Method in interface com.linkedin.davinci.kafka.consumer.StoreIngestionService: Adds Notifier to get Notifications for get various status of the consumption tasks like start, completed, progress and error states.
addInstanceConfigChangeListener(InstanceConfigChangeListener) - Method in class com.linkedin.venice.helix.SafeHelixManager
addInstanceToAllowlist(String, String) - Method in interface com.linkedin.venice.controller.Admin
addInstanceToAllowlist(String, String) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin: Add the given helix nodeId into the allowlist in ZK.
addInstanceToAllowlist(String, String) - Method in class com.linkedin.venice.controller.VeniceParentHelixAdmin: Unsupported operation in the parent controller.
addInstanceToAllowList(String, String) - Method in interface com.linkedin.venice.helix.AllowlistAccessor: Add the given helix nodeId into the allowlist in ZK.
addInstanceToAllowList(String, String) - Method in class com.linkedin.venice.helix.ZkAllowlistAccessor: Add the given helix nodeId into the allowlist in ZK.
addInt(CharSequence, int) - Method in class com.linkedin.alpini.netty4.http2.Http1Headers
addLast(E) - Method in class com.linkedin.alpini.base.misc.DoublyLinkedList: Appends the specified element to the end of this list.
addListener(AsyncFutureListener<T>) - Method in interface com.linkedin.alpini.base.concurrency.AsyncFuture: Adds the specified listener to this future.
addListener(AsyncFutureListener<T>) - Method in interface com.linkedin.alpini.base.concurrency.AsyncPromise: Adds the specified listener to this future.
addListener(AsyncFutureListener<T>) - Method in class com.linkedin.alpini.base.concurrency.impl.DefaultAsyncFuture
addListener(AsyncFutureListener<T>) - Method in class com.linkedin.alpini.base.concurrency.impl.FailedAsyncFuture: Adds the specified listener to this future.
addListener(AsyncFutureListener<T>) - Method in class com.linkedin.alpini.base.concurrency.impl.SuccessAsyncFuture: Adds the specified listener to this future.
addListener(AsyncPromise<T>) - Method in interface com.linkedin.alpini.base.concurrency.AsyncFuture: Adds the specified future as a listener to this future.
addListener(AsyncPromise<T>) - Method in interface com.linkedin.alpini.base.concurrency.AsyncPromise: Adds the specified future as a listener to this future.
addListener(AsyncPromise<T>) - Method in class com.linkedin.alpini.base.concurrency.impl.DefaultAsyncFuture: Adds the specified future as a listener to this future.
addListener(AsyncPromise<T>) - Method in class com.linkedin.alpini.base.concurrency.impl.FailedAsyncFuture: Adds the specified future as a listener to this future.
addListener(AsyncPromise<T>) - Method in class com.linkedin.alpini.base.concurrency.impl.SuccessAsyncFuture: Adds the specified future as a listener to this future.
addListener(GenericFutureListener<? extends Future<? super Void>>) - Method in class io.netty.bootstrap.PendingConnectFuturePromise
addListener(GenericFutureListener<? extends Future<? super Void>>) - Method in class io.netty.bootstrap.PendingConnectPromise
addListener(GenericFutureListener<? extends Future<? super V>>) - Method in class com.linkedin.alpini.base.misc.PromiseDelegate
addListeners(GenericFutureListener<? extends Future<? super Void>>...) - Method in class io.netty.bootstrap.PendingConnectFuturePromise
addListeners(GenericFutureListener<? extends Future<? super Void>>...) - Method in class io.netty.bootstrap.PendingConnectPromise
addListeners(GenericFutureListener<? extends Future<? super V>>...) - Method in class com.linkedin.alpini.base.misc.PromiseDelegate
addLiveInstanceChangeListener(LiveInstanceChangeListener) - Method in class com.linkedin.venice.helix.SafeHelixManager
addLocalStorageEngine(AbstractStorageEngine) - Method in class com.linkedin.davinci.storage.StorageEngineRepository
addMessageListener(MessageListener, String) - Method in class com.linkedin.venice.helix.SafeHelixManager
addMetaSystemStoreReplicaStatusNotifier() - Method in class com.linkedin.davinci.kafka.consumer.KafkaStoreIngestionService: This function should only be triggered in classical Venice since replica status reporting is only valid in classical Venice for meta system store.
addMetric(TehutiMetric) - Method in class com.linkedin.venice.tehuti.MockTehutiReporter
addMilliseconds(long) - Method in class com.linkedin.venice.utils.TestMockTime
addNextHandler(VeniceServerGrpcHandler) - Method in class com.linkedin.venice.listener.grpc.handlers.VeniceServerGrpcHandler
addNodeIntoAllowList(Admin) - Method in class com.linkedin.venice.controller.server.NodesAndReplicas
addNodeIntoAllowList(String) - Method in class com.linkedin.venice.controllerapi.ControllerClient
addOfflineRequest(ScatterGatherRequest<H, K>) - Method in class com.linkedin.alpini.router.api.Scatter
addOnlineRequest(ScatterGatherRequest<H, K>) - Method in class com.linkedin.alpini.router.api.Scatter
addOptionalChannelHandler(String, ChannelHandler) - Method in class com.linkedin.venice.router.RouterServer
addPartition(Partition) - Method in class com.linkedin.venice.meta.PartitionAssignment
addPartitionConsumptionState(PartitionConsumptionState) - Method in class com.linkedin.davinci.listener.response.AdminResponse: Add a partition consumption state to the admin response record
addPartitionConsumptionState(Integer, PartitionConsumptionState) - Method in class com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask
addPartitionDetails(OfflinePushStatus) - Method in class com.linkedin.venice.meta.RegionPushDetails
addPartitionNameToQuery(String) - Method in class com.linkedin.alpini.router.api.BroadcastScatterGatherRequest
addPersona(String, long, Set<String>, Set<String>) - Method in class com.linkedin.venice.helix.StoragePersonaRepository: Creates a new persona with the given parameters.
addPingTasks(List<CompletableFuture<?>>, ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.Http2PingResponseHandler
addPreConnectCallback(PreConnectCallback) - Method in class com.linkedin.venice.helix.SafeHelixManager
addProducerTask(String) - Method in class com.linkedin.venice.pubsub.adapter.PubSubSharedProducerAdapter
addPropertyDiff(String, String, String, String, String) - Method in class com.linkedin.venice.controllerapi.StoreComparisonInfo
addPushStatusNotifier(VeniceNotifier) - Method in class com.linkedin.davinci.ingestion.DefaultIngestionBackend
addPushStatusNotifier(VeniceNotifier) - Method in class com.linkedin.davinci.ingestion.IsolatedIngestionBackend
addPushStatusNotifier(VeniceNotifier) - Method in class com.linkedin.davinci.ingestion.main.MainIngestionMonitorService
addPushStatusNotifier(VeniceNotifier) - Method in interface com.linkedin.davinci.ingestion.VeniceIngestionBackend: Adds ingestion listener which reports ingestion status for different push monitors.
addReadComputeDeserializationLatency(double) - Method in class com.linkedin.davinci.listener.response.ReadResponse
addReadComputeLatency(double) - Method in class com.linkedin.davinci.listener.response.ReadResponse
addReadComputeOutputSize(int) - Method in class com.linkedin.davinci.listener.response.ReadResponse
addReadComputeSerializationLatency(double) - Method in class com.linkedin.davinci.listener.response.ReadResponse
addRecord(K) - Method in class com.linkedin.venice.listener.response.MultiKeyResponseWrapper
addReferentAndByteCount(T, long) - Method in class com.linkedin.alpini.base.misc.MemoryPressureIndexMonitor: Add an referent if it is not in the map, other wise add the ByteCount.
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.linkedin.venice.protocols.VeniceServerResponse.Builder
addReplicationMetadataSchema(RmdSchemaEntry) - Method in class com.linkedin.venice.schema.SchemaData
addReplicationMetadataSchema(String, int, String, int) - Method in class com.linkedin.venice.helix.HelixReadWriteSchemaRepository
addReplicationMetadataSchema(String, int, String, int) - Method in class com.linkedin.venice.helix.HelixReadWriteSchemaRepositoryAdapter
addReplicationMetadataSchema(String, int, String, int) - Method in interface com.linkedin.venice.meta.ReadWriteSchemaRepository
addReplicationMetadataSchema(String, RmdSchemaEntry) - Method in class com.linkedin.venice.helix.HelixSchemaAccessor
addReplicationMetadataSchema(String, String, int, int, String) - Method in interface com.linkedin.venice.controller.Admin
addReplicationMetadataSchema(String, String, int, int, String) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin: Create a new ReplicationMetadataSchemaEntry object with the given properties and add it into schema repository if no duplication.
addReplicationMetadataSchema(String, String, int, int, String) - Method in class com.linkedin.venice.controller.VeniceParentHelixAdmin: Create a new ReplicationMetadataSchemaEntry object with the given properties and add it into schema repository by sending REPLICATION_METADATA_SCHEMA_CREATION admin message.
addResourceConfigChangeListener(ResourceConfigChangeListener) - Method in class com.linkedin.venice.helix.SafeHelixManager
addSchemaDiff(String, String, String, String, String) - Method in class com.linkedin.venice.controllerapi.StoreComparisonInfo
addServerConfigs(Properties) - Method in class com.linkedin.davinci.listener.response.AdminResponse: Load all server configs into admin response record
addShort(CharSequence, short) - Method in class com.linkedin.alpini.netty4.http2.Http1Headers
addSpecificVersion(String, String, Version) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin: TODO refactor addVersion to these broken down methods instead of doing everything in one giant method.
addSslContextHandler(ChannelPipeline, SslContext, String, int) - Method in class com.linkedin.alpini.netty4.pool.Http2AwareChannelPoolFactory
addStatsForRoute(String) - Method in class com.linkedin.venice.stats.HttpConnectionPoolStats: This function is used to gradually populate per-route stats.
addStoragePartition(int) - Method in class com.linkedin.davinci.store.AbstractStorageEngine
addStoragePartition(StoragePartitionConfig) - Method in class com.linkedin.davinci.store.AbstractStorageEngine
addStore(Store) - Method in class com.linkedin.venice.helix.HelixReadWriteStoreRepository
addStore(Store) - Method in class com.linkedin.venice.helix.HelixReadWriteStoreRepositoryAdapter: This function only be used to add regular venice store, and the system store is bundled with regular venice store.
addStore(Store) - Method in interface com.linkedin.venice.meta.ReadWriteStoreRepository: Add store into repository.
addStoresToPersona(String, List<String>) - Method in class com.linkedin.venice.helix.StoragePersonaRepository: This operation assumes that stores which are added to the persona are not contained within any store, but does not do any validity checks.
addStoreVersionState(StoreVersionState) - Method in class com.linkedin.davinci.listener.response.AdminResponse: Add store version state metadata into the admin response record
addSubrequest(Metrics) - Method in class com.linkedin.alpini.base.misc.Metrics
addSupersetSchema(String, String, String, int, String, int) - Method in interface com.linkedin.venice.controller.Admin
addSupersetSchema(String, String, String, int, String, int) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin: Add a new superset schema for the given store with all specified properties.
addSupersetSchema(String, String, String, int, String, int) - Method in class com.linkedin.venice.controller.VeniceParentHelixAdmin: Unsupported operation in the parent controller.
addTargetExternalViewChangeListener(ExternalViewChangeListener) - Method in class com.linkedin.venice.helix.SafeHelixManager
addToCheckSum(KafkaKey, KafkaMessageEnvelope) - Method in class com.linkedin.venice.kafka.validation.Segment: This function updates the running checksum as follows, depending on the MessageType: 1.
addToSupposedlyOngoingIncrementalPushVersions(String, int, String, ExecutionStatus) - Method in class com.linkedin.venice.pushstatushelper.PushStatusStoreWriter
addValueSchema(Admin) - Method in class com.linkedin.venice.controller.server.SchemaRoutes: Route to handle adding value schema request.
addValueSchema(SchemaEntry) - Method in class com.linkedin.venice.schema.SchemaData
addValueSchema(String, SchemaEntry) - Method in class com.linkedin.venice.helix.HelixSchemaAccessor
addValueSchema(String, String) - Method in class com.linkedin.venice.controllerapi.ControllerClient
addValueSchema(String, String) - Method in interface com.linkedin.venice.meta.ReadWriteSchemaRepository: Add a new value schema for the given store
addValueSchema(String, String, int) - Method in class com.linkedin.venice.controllerapi.ControllerClient
addValueSchema(String, String, int) - Method in class com.linkedin.venice.helix.HelixReadWriteSchemaRepository
addValueSchema(String, String, int) - Method in class com.linkedin.venice.helix.HelixReadWriteSchemaRepositoryAdapter
addValueSchema(String, String, int) - Method in interface com.linkedin.venice.meta.ReadWriteSchemaRepository: Add a new value schema for the given store by specifying schema id.
addValueSchema(String, String, int, DirectionalSchemaCompatibilityType) - Method in class com.linkedin.venice.controllerapi.ControllerClient
addValueSchema(String, String, DirectionalSchemaCompatibilityType) - Method in class com.linkedin.venice.helix.HelixReadWriteSchemaRepository: Add new value schema for the given store.
addValueSchema(String, String, DirectionalSchemaCompatibilityType) - Method in class com.linkedin.venice.helix.HelixReadWriteSchemaRepositoryAdapter
addValueSchema(String, String, DirectionalSchemaCompatibilityType) - Method in interface com.linkedin.venice.meta.ReadWriteSchemaRepository: Add a new value schema for the given store
addValueSchema(String, String, String, int) - Method in interface com.linkedin.venice.controller.Admin: This method skips most precondition checks and is intended for only internal use.
addValueSchema(String, String, String, int, DirectionalSchemaCompatibilityType) - Method in interface com.linkedin.venice.controller.Admin
addValueSchema(String, String, String, int, DirectionalSchemaCompatibilityType) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin: Add a new value schema for the given store with all specified properties and return a new SchemaEntry object containing the schema and its id.
addValueSchema(String, String, String, int, DirectionalSchemaCompatibilityType) - Method in class com.linkedin.venice.controller.VeniceParentHelixAdmin
addValueSchema(String, String, String, DirectionalSchemaCompatibilityType) - Method in interface com.linkedin.venice.controller.Admin
addValueSchema(String, String, String, DirectionalSchemaCompatibilityType) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin
addValueSchema(String, String, String, DirectionalSchemaCompatibilityType) - Method in class com.linkedin.venice.controller.VeniceParentHelixAdmin: Add a new value schema for the given store with all specified properties by sending a VALUE_SCHEMA_CREATION admin message.
addValueSize(int) - Method in class com.linkedin.davinci.listener.response.ReadResponse
addVeniceStorageClusterToControllerCluster(String) - Method in interface com.linkedin.venice.controller.HelixAdminClient: Add the given Venice storage cluster's cluster resource to the controller cluster.
addVeniceStorageClusterToControllerCluster(String) - Method in class com.linkedin.venice.controller.ZkHelixAdminClient
addVersion(int) - Method in class com.linkedin.davinci.stats.VeniceVersionedStats
addVersion(int) - Method in class com.linkedin.venice.meta.RegionPushDetails
addVersion(Version) - Method in class com.linkedin.venice.meta.AbstractStore
addVersion(Version) - Method in class com.linkedin.venice.meta.ReadOnlyStore
addVersion(Version) - Method in interface com.linkedin.venice.meta.Store
addVersion(Version, boolean) - Method in class com.linkedin.venice.meta.AbstractStore
addVersion(Version, boolean) - Method in class com.linkedin.venice.meta.ReadOnlyStore
addVersion(Version, boolean) - Method in interface com.linkedin.venice.meta.Store
AddVersion - Class in com.linkedin.venice.controller.kafka.protocol.admin
AddVersion() - Constructor for class com.linkedin.venice.controller.kafka.protocol.admin.AddVersion: Default constructor.
AddVersion(CharSequence, CharSequence, CharSequence, Integer, Integer, Integer, CharSequence, Long, Integer, Boolean, List<CharSequence>) - Constructor for class com.linkedin.venice.controller.kafka.protocol.admin.AddVersion: All-args constructor.
addVersionAndStartIngestion(Admin) - Method in class com.linkedin.venice.controller.server.CreateVersion: This function is only being used by store migration parent controllers, which write add version admin message.
addVersionAndStartIngestion(String, String, int, int, Version.PushType, String, long, int) - Method in class com.linkedin.venice.controllerapi.ControllerClient: Used for store migration to add version and start ingestion in destination cluster for new pushes in the source cluster during the ingestion.
addVersionAndStartIngestion(String, String, String, int, int, Version.PushType, String, long, int, boolean) - Method in interface com.linkedin.venice.controller.Admin: This method behaves differently in VeniceHelixAdmin and VeniceParentHelixAdmin.
addVersionAndStartIngestion(String, String, String, int, int, Version.PushType, String, long, int, boolean) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin: This is a wrapper for VeniceHelixAdmin#addVersion but performs additional operations needed for add version invoked from the admin channel.
addVersionAndStartIngestion(String, String, String, int, int, Version.PushType, String, long, int, boolean) - Method in class com.linkedin.venice.controller.VeniceParentHelixAdmin
addVersionAndTopicOnly(String, String, String, int, int, int, boolean, boolean, Version.PushType, String, String, Optional<String>, long, int, Optional<String>, boolean) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin
addVersionAndTopicOnly(String, String, String, int, int, int, boolean, boolean, Version.PushType, String, String, Optional<String>, long, int, Optional<String>, boolean, String) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin: A wrapper to invoke VeniceHelixAdmin#addVersion to only increment the version and create the topic(s) needed without starting ingestion.
addVersionOnly(String, String, String, int, int, Version.PushType, String, long, int) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin: Only add version to the store without creating the topic or start ingestion.
addVersionStateDiff(String, String, int, VersionStatus, VersionStatus) - Method in class com.linkedin.venice.controllerapi.StoreComparisonInfo
addWaiter(Promise<Channel>) - Method in class com.linkedin.alpini.netty4.pool.FastSimpleChannelPool
adjustStoragePartition(StoragePartitionConfig) - Method in class com.linkedin.davinci.store.AbstractStorageEngine: Adjust the opened storage partition according to the provided storagePartitionConfig.
ADLER32 - com.linkedin.venice.kafka.validation.checksum.CheckSumType: Deprecated.
Adler32CheckSum - Class in com.linkedin.venice.kafka.validation.checksum: Running checksum implementations based on Adler32.
Adler32CheckSum() - Constructor for class com.linkedin.venice.kafka.validation.checksum.Adler32CheckSum
Admin - Interface in com.linkedin.venice.controller
ADMIN - com.linkedin.venice.meta.QueryAction
ADMIN_CHECK_READ_METHOD_FOR_KAFKA - Static variable in class com.linkedin.venice.ConfigKeys: Whether controller should check "Read" method against Kafka wildcard ACL while users request for a topic to write.
ADMIN_CONSUMPTION_CYCLE_TIMEOUT_MS - Static variable in class com.linkedin.venice.ConfigKeys: The maximum time allowed for worker threads to execute admin messages in one cycle.
ADMIN_CONSUMPTION_MAX_WORKER_THREAD_POOL_SIZE - Static variable in class com.linkedin.venice.ConfigKeys: The maximum number of threads allowed in the pool for executing admin messages.
ADMIN_CONSUMPTION_TIMEOUT_MINUTES - Static variable in class com.linkedin.venice.ConfigKeys: If there is a failure in consuming from the admin topic, skip the message after retrying for this many minutes Default 5 days
ADMIN_HELIX_MESSAGING_CHANNEL_ENABLED - Static variable in class com.linkedin.venice.ConfigKeys: Flag to enable the controller to send kill push job helix messages to the storage node upon consuming kill push job admin messages.
ADMIN_HOSTNAME - Static variable in class com.linkedin.venice.ConfigKeys
ADMIN_OPERATION - com.linkedin.venice.serialization.avro.AvroProtocolDefinition: Used to encode metadata changes about the system as a whole.
ADMIN_PORT - Static variable in class com.linkedin.venice.ConfigKeys
ADMIN_SECURE_PORT - Static variable in class com.linkedin.venice.ConfigKeys
ADMIN_TOPIC - com.linkedin.venice.pubsub.api.PubSubTopicType
ADMIN_TOPIC_PARTITION_ID - Static variable in class com.linkedin.venice.controller.kafka.AdminTopicUtils
ADMIN_TOPIC_PREFIX - Static variable in enum com.linkedin.venice.pubsub.api.PubSubTopicType
ADMIN_TOPIC_REMOTE_CONSUMPTION_ENABLED - Static variable in class com.linkedin.venice.ConfigKeys: Whether child controllers will directly consume the source admin topic in the parent Kafka cluster.
ADMIN_TOPIC_REPLICATION_FACTOR - Static variable in class com.linkedin.venice.ConfigKeys: The replication factor to set for admin topics.
ADMIN_TOPIC_SOURCE_REGION - Static variable in class com.linkedin.venice.ConfigKeys: This config defines the source region name of the admin topic
Admin.OfflinePushStatusInfo - Class in com.linkedin.venice.controller
adminCheckReadMethodForKafka() - Method in class com.linkedin.venice.controller.VeniceControllerConfig
adminCheckReadMethodForKafka() - Method in class com.linkedin.venice.controller.VeniceControllerMultiClusterConfig
AdminCommandExecution - Class in com.linkedin.venice.controllerapi: The execution object is a kind of context for a admin command including essential information used to track the status of this command.
AdminCommandExecution() - Constructor for class com.linkedin.venice.controllerapi.AdminCommandExecution: CTOR used by JSON serializer.
AdminCommandExecution(long, String, String, Collection<String>) - Constructor for class com.linkedin.venice.controllerapi.AdminCommandExecution
AdminCommandExecutionResponse - Class in com.linkedin.venice.controllerapi.routes
AdminCommandExecutionResponse() - Constructor for class com.linkedin.venice.controllerapi.routes.AdminCommandExecutionResponse
AdminCommandExecutionRoutes - Class in com.linkedin.venice.controller.server
AdminCommandExecutionRoutes(boolean, Optional<DynamicAccessController>) - Constructor for class com.linkedin.venice.controller.server.AdminCommandExecutionRoutes
AdminCommandExecutionStatus - Enum in com.linkedin.venice.controllerapi
AdminCommandExecutionTracker - Class in com.linkedin.venice.controller: This class is used to track the execution of the async admin command.
AdminCommandExecutionTracker(String, ExecutionIdAccessor, Map<String, ControllerClient>) - Constructor for class com.linkedin.venice.controller.AdminCommandExecutionTracker
AdminCommandExecutionTracker(String, ExecutionIdAccessor, Map<String, ControllerClient>, int) - Constructor for class com.linkedin.venice.controller.AdminCommandExecutionTracker
AdminConsumerService - Class in com.linkedin.venice.controller.kafka.consumer: One consumer service for one cluster.
AdminConsumerService(VeniceHelixAdmin, VeniceControllerConfig, MetricsRepository, PubSubTopicRepository, PubSubMessageDeserializer) - Constructor for class com.linkedin.venice.controller.kafka.consumer.AdminConsumerService
AdminConsumptionStats - Class in com.linkedin.venice.controller.stats
AdminConsumptionStats(MetricsRepository, String) - Constructor for class com.linkedin.venice.controller.stats.AdminConsumptionStats
AdminConsumptionTask - Class in com.linkedin.venice.controller.kafka.consumer: This class is used to create a task, which will consume the admin messages from the special admin topics.
AdminConsumptionTask(String, PubSubConsumerAdapter, boolean, Optional<String>, VeniceHelixAdmin, AdminTopicMetadataAccessor, ExecutionIdAccessor, boolean, AdminConsumptionStats, int, Optional<Integer>, long, int, PubSubTopicRepository, PubSubMessageDeserializer, String) - Constructor for class com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask
AdminExecutionTask - Class in com.linkedin.venice.controller.kafka.consumer: This class is used to create Callable that execute AdminOperations for a given store.
AdminMessageType - Enum in com.linkedin.venice.controller.kafka.protocol.enums
adminOperation - Variable in class com.linkedin.venice.DumpAdminMessages.AdminOperationInfo
AdminOperation - Class in com.linkedin.venice.controller.kafka.protocol.admin
AdminOperation() - Constructor for class com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation: Default constructor.
AdminOperation(Integer, Long, Object) - Constructor for class com.linkedin.venice.controller.kafka.protocol.admin.AdminOperation: All-args constructor.
AdminOperationInfo() - Constructor for class com.linkedin.venice.DumpAdminMessages.AdminOperationInfo
AdminOperationSerializer - Class in com.linkedin.venice.controller.kafka.protocol.serializer
AdminOperationSerializer() - Constructor for class com.linkedin.venice.controller.kafka.protocol.serializer.AdminOperationSerializer
AdminOperationsHandler - Class in com.linkedin.venice.router
AdminOperationsHandler(AccessController, RouterServer, AdminOperationsStats) - Constructor for class com.linkedin.venice.router.AdminOperationsHandler
AdminOperationsStats - Class in com.linkedin.venice.router.stats
AdminOperationsStats(MetricsRepository, String, VeniceRouterConfig) - Constructor for class com.linkedin.venice.router.stats.AdminOperationsStats
AdminOperationWrapper - Class in com.linkedin.venice.controller.kafka.consumer
AdminRequest - Class in com.linkedin.venice.listener.request: AdminRequest encapsulates an admin request from server admin tools.
AdminResponse - Class in com.linkedin.davinci.listener.response: This class stores all the information required for answering a server admin request.
AdminResponse() - Constructor for class com.linkedin.davinci.listener.response.AdminResponse
AdminResponseRecord - Class in com.linkedin.venice.admin.protocol.response: Response record for admin request, version 1
AdminResponseRecord() - Constructor for class com.linkedin.venice.admin.protocol.response.AdminResponseRecord: Default constructor.
AdminResponseRecord(List<ConsumptionStateSnapshot>, Object, ServerConfigSnapshot) - Constructor for class com.linkedin.venice.admin.protocol.response.AdminResponseRecord: All-args constructor.
AdminSparkServer - Class in com.linkedin.venice.controller.server: Controller admin API leveraging sparkjava: http://sparkjava.com/documentation.html
AdminSparkServer(int, Admin, MetricsRepository, Set<String>, boolean, Optional<SSLConfig>, boolean, Optional<DynamicAccessController>, List<ControllerRoute>, VeniceProperties, boolean, PubSubTopicRepository) - Constructor for class com.linkedin.venice.controller.server.AdminSparkServer
AdminTool - Class in com.linkedin.venice
AdminTool() - Constructor for class com.linkedin.venice.AdminTool
AdminTopicMetadataAccessor - Class in com.linkedin.venice.controller
AdminTopicMetadataAccessor() - Constructor for class com.linkedin.venice.controller.AdminTopicMetadataAccessor
AdminTopicMetadataResponse - Class in com.linkedin.venice.controllerapi
AdminTopicMetadataResponse() - Constructor for class com.linkedin.venice.controllerapi.AdminTopicMetadataResponse
AdminTopicMetadataRoutes - Class in com.linkedin.venice.controller.server
AdminTopicMetadataRoutes(boolean, Optional<DynamicAccessController>) - Constructor for class com.linkedin.venice.controller.server.AdminTopicMetadataRoutes
AdminTopicUtils - Class in com.linkedin.venice.controller.kafka
AdminTopicUtils() - Constructor for class com.linkedin.venice.controller.kafka.AdminTopicUtils
advance(long, TimeUnit) - Static method in enum com.linkedin.alpini.base.misc.Time
afterHttpServerCodec(ChannelPipeline) - Method in class com.linkedin.alpini.netty4.handlers.BasicServerChannelInitializer
AggHostHealthStats - Class in com.linkedin.venice.router.stats
AggHostHealthStats(MetricsRepository) - Constructor for class com.linkedin.venice.router.stats.AggHostHealthStats
AggHostLevelIngestionStats - Class in com.linkedin.davinci.stats: This class provides aggregate initialization support for host level ingestion stats class HostLevelIngestionStats
AggHostLevelIngestionStats(MetricsRepository, VeniceServerConfig, Map<String, StoreIngestionTask>, ReadOnlyStoreRepository, boolean, Time) - Constructor for class com.linkedin.davinci.stats.AggHostLevelIngestionStats
aggKafkaConsumerService - Variable in class com.linkedin.davinci.kafka.consumer.StoreIngestionTask
AggKafkaConsumerService - Class in com.linkedin.davinci.kafka.consumer: AggKafkaConsumerService supports Kafka consumer pool for multiple Kafka clusters from different data centers; for each Kafka bootstrap server url, AggKafkaConsumerService will create one KafkaConsumerService.
AggKafkaConsumerService(PubSubConsumerAdapterFactory, TopicManagerRepository.SSLPropertiesSupplier, VeniceServerConfig, EventThrottler, EventThrottler, KafkaClusterBasedRecordThrottler, MetricsRepository, TopicExistenceChecker, PubSubMessageDeserializer) - Constructor for class com.linkedin.davinci.kafka.consumer.AggKafkaConsumerService
AggLagStats - Class in com.linkedin.davinci.stats
AggLagStats(StoreIngestionService, MetricsRepository) - Constructor for class com.linkedin.davinci.stats.AggLagStats
AggPartitionHealthStats - Class in com.linkedin.venice.controller.stats: Monitor the change of Helix's external view and warn in case that any partition is unhealthy.
AggPartitionHealthStats(String, ReadOnlyStoreRepository, PushMonitor) - Constructor for class com.linkedin.venice.controller.stats.AggPartitionHealthStats: Only for test usage.
AggPartitionHealthStats(String, MetricsRepository, RoutingDataRepository, ReadOnlyStoreRepository, PushMonitor) - Constructor for class com.linkedin.venice.controller.stats.AggPartitionHealthStats
AggPushHealthStats - Class in com.linkedin.venice.pushmonitor
AggPushHealthStats(String, MetricsRepository, ReadOnlyStoreRepository, boolean) - Constructor for class com.linkedin.venice.pushmonitor.AggPushHealthStats
AggPushStatusCleanUpStats - Class in com.linkedin.venice.pushmonitor
AggPushStatusCleanUpStats(String, MetricsRepository, ReadOnlyStoreRepository, boolean) - Constructor for class com.linkedin.venice.pushmonitor.AggPushStatusCleanUpStats
aggregate(FullHttpMessage, HttpContent) - Method in class com.linkedin.alpini.netty4.handlers.BasicHttpObjectAggregator
aggregate(FullHttpMessage, HttpContent) - Method in class io.netty.handler.codec.http.EspressoHttpObjectAggregator
aggregate(O, C) - Method in class io.netty.handler.codec.EspressoMessageAggregator: Transfers the information provided by the specified content message to the specified aggregated message.
AGGREGATE - com.linkedin.venice.meta.DataReplicationPolicy: Single Samza job or Samza job per colo pushes to real-time topic in parent colo.
AGGREGATE_REAL_TIME_SOURCE_REGION - Static variable in class com.linkedin.venice.ConfigKeys: This config defines the source region of aggregate hybrid store real-time data when native replication is enabled
aggregatedMetrics - Variable in class com.linkedin.venice.ingestion.protocol.IngestionMetricsReport: A map of string key and double map value.
aggregateResponse(BASIC_HTTP_REQUEST, Metrics, List<HTTP_RESPONSE>, ResponseAggregatorFactory<BASIC_HTTP_REQUEST, HTTP_RESPONSE>) - Method in class com.linkedin.alpini.router.api.ScatterGatherHelper
aggregates - Variable in class com.linkedin.venice.kafka.protocol.state.ProducerPartitionState: The aggregates that have been computed so far since the last StartOfSegment ControlMessage.
AggRocksDBStats - Class in com.linkedin.venice.stats: Right now, Venice SN only reports aggregated metrics for RocksDB.
AggRocksDBStats(MetricsRepository, Statistics) - Constructor for class com.linkedin.venice.stats.AggRocksDBStats
AggRouterHttpRequestStats - Class in com.linkedin.venice.router.stats
AggRouterHttpRequestStats(MetricsRepository, RequestType, boolean, ReadOnlyStoreRepository, boolean) - Constructor for class com.linkedin.venice.router.stats.AggRouterHttpRequestStats
AggRouterHttpRequestStats(MetricsRepository, RequestType, ReadOnlyStoreRepository, boolean) - Constructor for class com.linkedin.venice.router.stats.AggRouterHttpRequestStats
AggServerHttpRequestStats - Class in com.linkedin.venice.stats: AggServerHttpRequestStats is the aggregate statistics for ServerHttpRequestStats corresponding to the type of requests defined in RequestType.
AggServerHttpRequestStats(MetricsRepository, RequestType, boolean, ReadOnlyStoreRepository, boolean) - Constructor for class com.linkedin.venice.stats.AggServerHttpRequestStats
AggServerQuotaTokenBucketStats - Class in com.linkedin.venice.stats: AggServerQuotaTokenBucketStats is the aggregate statistics for ServerQuotaTokenBucketStats.
AggServerQuotaTokenBucketStats(MetricsRepository, ReadQuotaEnforcementHandler) - Constructor for class com.linkedin.venice.stats.AggServerQuotaTokenBucketStats
AggServerQuotaUsageStats - Class in com.linkedin.venice.stats: AggServerQuotaUsageStats is the aggregate statistics for ServerQuotaUsageStats which measures requests and quota rejections of each store.
AggServerQuotaUsageStats(MetricsRepository) - Constructor for class com.linkedin.venice.stats.AggServerQuotaUsageStats
AggStoreStats - Class in com.linkedin.venice.controller.stats
AggStoreStats(MetricsRepository, ReadOnlyStoreRepository) - Constructor for class com.linkedin.venice.controller.stats.AggStoreStats
AggVersionedDIVStats - Class in com.linkedin.davinci.stats
AggVersionedDIVStats(MetricsRepository, ReadOnlyStoreRepository, boolean) - Constructor for class com.linkedin.davinci.stats.AggVersionedDIVStats
AggVersionedIngestionStats - Class in com.linkedin.davinci.stats: The store level stats or the total stats will be unpopulated because there is no easy and reliable way to aggregate gauge stats such as rt topic offset lag.
AggVersionedIngestionStats(MetricsRepository, ReadOnlyStoreRepository, VeniceServerConfig) - Constructor for class com.linkedin.davinci.stats.AggVersionedIngestionStats
AggVersionedStorageEngineStats - Class in com.linkedin.davinci.stats
AggVersionedStorageEngineStats(MetricsRepository, ReadOnlyStoreRepository, boolean) - Constructor for class com.linkedin.davinci.stats.AggVersionedStorageEngineStats
ALL - com.linkedin.venice.meta.VeniceUserStoreType: All user stores in Venice, excluding system stores.
ALL - Static variable in class com.linkedin.alpini.consts.Level: The ALL has the lowest possible rank and is intended to turn on all logging.
ALL_INT - Static variable in class com.linkedin.alpini.consts.Level
AllChannelsHandler - Class in com.linkedin.alpini.netty4.handlers
AllChannelsHandler() - Constructor for class com.linkedin.alpini.netty4.handlers.AllChannelsHandler
allOf(EventExecutor, Future<?>...) - Static method in class com.linkedin.alpini.netty4.misc.Futures
allOf(Future<?>...) - Static method in class com.linkedin.alpini.netty4.misc.Futures
ALLOW - com.linkedin.venice.authorization.Permission
ALLOW_CLUSTER_WIPE - Static variable in class com.linkedin.venice.ConfigKeys: Whether a cluster in a data center could be wiped.
ALLOW_DUPLICATE_KEY - Static variable in class com.linkedin.venice.hadoop.VenicePushJob
ALLOW_LIST_ADD_NODE - com.linkedin.venice.Command
ALLOW_LIST_ADD_NODE - com.linkedin.venice.controllerapi.ControllerRoute
ALLOW_LIST_REMOVE_NODE - com.linkedin.venice.Command
ALLOW_LIST_REMOVE_NODE - com.linkedin.venice.controllerapi.ControllerRoute
ALLOW_STORE_MIGRATION - com.linkedin.venice.Arg
ALLOW_STORE_MIGRATION - Static variable in class com.linkedin.venice.ConfigKeys: Whether stores are allowed to be migrated from/to a specific cluster.
ALLOW_STORE_MIGRATION - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants: Whether stores are allowed to be migrated from/to a specific cluster.
allowFieldValueToBeNull() - Method in class com.linkedin.venice.compute.CosineSimilarityOperator
allowFieldValueToBeNull() - Method in class com.linkedin.venice.compute.CountOperator
allowFieldValueToBeNull() - Method in class com.linkedin.venice.compute.DotProductOperator
allowFieldValueToBeNull() - Method in class com.linkedin.venice.compute.HadamardProductOperator
allowFieldValueToBeNull() - Method in interface com.linkedin.venice.compute.ReadComputeOperator: Whether the extracted value of the field in the read value record is allowed to be null.
AllowlistAccessor - Interface in com.linkedin.venice.helix: Interface defines the ways to access to the allowlist of Helix NodeId.
allPermutationGenerator(Object[]...) - Static method in class com.linkedin.venice.utils.DataProviderUtils: Generate permutations to be fed to a DataProvider.
allPermutationGenerator(Function<Object[], Boolean>, Object[]...) - Static method in class com.linkedin.venice.utils.DataProviderUtils: Generate permutations to be fed to a DataProvider.
ALWAYS_ON_MULTI_THREADED_PIPELINE - com.linkedin.venice.client.store.deserialization.BatchDeserializerType: Deprecated.
AMPLIFICATION_FACTOR - com.linkedin.venice.Arg
AMPLIFICATION_FACTOR - Static variable in class com.linkedin.venice.ConfigKeys: A configs of over-partitioning factor number of Kafka partitions in each partition
AMPLIFICATION_FACTOR - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
amplificationFactor - Variable in class com.linkedin.davinci.kafka.consumer.StoreIngestionTask
amplificationFactor - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.PartitionerConfigRecord
amplificationFactor - Variable in class com.linkedin.venice.meta.systemstore.schemas.PartitionerConfig
amplificationFactor - Variable in class com.linkedin.venice.metadata.response.VersionProperties: Partitioner amplification factor
amplificationFactor - Variable in class com.linkedin.venice.systemstore.schemas.StorePartitionerConfig
amplificationFactor() - Static method in class com.linkedin.venice.utils.DataProviderUtils
amplificationFactorAdapter - Variable in class com.linkedin.davinci.kafka.consumer.StoreIngestionTask
AmplificationFactorAdapter - Class in com.linkedin.davinci.kafka.consumer: This class hides and handles amplification factor concept for each user partition.
AmplificationFactorAdapter(int, ConcurrentMap<Integer, PartitionConsumptionState>) - Constructor for class com.linkedin.davinci.kafka.consumer.AmplificationFactorAdapter
amplificationFactorAndObjectCacheConfigProvider() - Static method in class com.linkedin.venice.utils.DataProviderUtils
and(Predicate...) - Static method in class com.linkedin.venice.client.store.predicate.PredicateBuilder
AndPredicate - Class in com.linkedin.venice.client.store.predicate
annotateRmdSchema(Schema) - Static method in class com.linkedin.davinci.schema.SchemaUtils: Annotate all the top-level map and string array's deleted elements field of the RMD schema to use Java String as key.
annotateUpdateSchema(Schema) - Static method in class com.linkedin.davinci.schema.SchemaUtils: Annotate all the top-level map field and string array of the update schema to use Java String as key.
annotateValueSchema(Schema) - Static method in class com.linkedin.davinci.schema.SchemaUtils: Annotate all the top-level map field and string array field of the input schema to use Java String as key.
ANY_OF_ONLINE - com.linkedin.venice.meta.ReadStrategy
anyOf(Future<?>...) - Static method in class com.linkedin.alpini.netty4.misc.Futures
APACHE_HTTP_ASYNC_CLIENT - com.linkedin.venice.router.httpclient.StorageNodeClientType: Deprecated.
APACHE_KAFKA_OFFSET - Static variable in class com.linkedin.venice.pubsub.PubSubPositionType
ApacheHttpAsyncStorageNodeClient - Class in com.linkedin.venice.router.httpclient
ApacheHttpAsyncStorageNodeClient(VeniceRouterConfig, Optional<SSLFactory>, MetricsRepository, LiveInstanceMonitor) - Constructor for class com.linkedin.venice.router.httpclient.ApacheHttpAsyncStorageNodeClient
ApacheKafkaAdminAdapter - Class in com.linkedin.venice.pubsub.adapter.kafka.admin: An implementation of PubSubAdminAdapter for Apache Kafka.
ApacheKafkaAdminAdapter(ApacheKafkaAdminConfig, PubSubTopicRepository) - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.admin.ApacheKafkaAdminAdapter
ApacheKafkaAdminAdapterFactory - Class in com.linkedin.venice.pubsub.adapter.kafka.admin: Implementation of PubSubProducerAdapterFactory used to create Apache Kafka admin clients.
ApacheKafkaAdminAdapterFactory() - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.admin.ApacheKafkaAdminAdapterFactory
ApacheKafkaAdminConfig - Class in com.linkedin.venice.pubsub.adapter.kafka.admin
ApacheKafkaAdminConfig(VeniceProperties) - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.admin.ApacheKafkaAdminConfig
ApacheKafkaConsumerAdapter - Class in com.linkedin.venice.pubsub.adapter.kafka.consumer: This class is not thread safe because of the internal KafkaConsumer being used.
ApacheKafkaConsumerAdapter(Properties, boolean, PubSubMessageDeserializer) - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerAdapter
ApacheKafkaConsumerAdapter(Consumer<byte[], byte[]>, VeniceProperties, boolean, PubSubMessageDeserializer) - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerAdapter
ApacheKafkaConsumerAdapter(Consumer<byte[], byte[]>, VeniceProperties, PubSubMessageDeserializer, TopicPartitionsOffsetsTracker) - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerAdapter
ApacheKafkaConsumerAdapterFactory - Class in com.linkedin.venice.pubsub.adapter.kafka.consumer
ApacheKafkaConsumerAdapterFactory() - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerAdapterFactory
ApacheKafkaConsumerConfig - Class in com.linkedin.venice.pubsub.adapter.kafka.consumer
ApacheKafkaConsumerConfig(VeniceProperties, String) - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerConfig
ApacheKafkaOffsetPosition - Class in com.linkedin.venice.pubsub.adapter.kafka: Offset position for Apache Kafka topics
ApacheKafkaOffsetPosition(long) - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.ApacheKafkaOffsetPosition
ApacheKafkaOffsetPosition(ByteBuffer) - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.ApacheKafkaOffsetPosition
ApacheKafkaProducerAdapter - Class in com.linkedin.venice.pubsub.adapter.kafka.producer: A wrapper over Apache Kafka producer which implements PubSubProducerAdapter
ApacheKafkaProducerAdapter(ApacheKafkaProducerConfig) - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerAdapter
ApacheKafkaProducerAdapterFactory - Class in com.linkedin.venice.pubsub.adapter.kafka.producer: Implementation of PubSubProducerAdapterFactory used to create Apache Kafka producers.
ApacheKafkaProducerAdapterFactory() - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerAdapterFactory
ApacheKafkaProducerCallback - Class in com.linkedin.venice.pubsub.adapter.kafka.producer: A Kafka specific callback which wraps generic PubSubProducerCallback
ApacheKafkaProducerCallback(PubSubProducerCallback, ApacheKafkaProducerAdapter) - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerCallback
ApacheKafkaProducerConfig - Class in com.linkedin.venice.pubsub.adapter.kafka.producer: This class holds all properties used to construct ApacheKafkaProducerAdapter (This class could be refactored to hold consumer properties as well).
ApacheKafkaProducerConfig(VeniceProperties, String, String, boolean) - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerConfig
ApacheKafkaProducerConfig(Properties) - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerConfig
ApacheKafkaProduceResult - Class in com.linkedin.venice.pubsub.adapter.kafka.producer: Converts RecordMetadata to PubSubProduceResult
ApacheKafkaProduceResult(RecordMetadata) - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProduceResult
ApacheKafkaUtils - Class in com.linkedin.venice.pubsub.adapter.kafka
ApacheKafkaUtils() - Constructor for class com.linkedin.venice.pubsub.adapter.kafka.ApacheKafkaUtils
APP_DEFAULT_LOGICAL_TS - Static variable in class com.linkedin.venice.writer.VeniceWriter: This sentinel value indicates that the venice samza apps have not provided the logical timestamp.
append(LogEvent) - Method in class com.linkedin.venice.utils.InMemoryLogAppender
appendCommon(StringBuilder, HttpMessage) - Static method in class com.linkedin.alpini.netty4.misc.HttpToStringUtils
appendError(BHS, List<HR>, HRS, String, Throwable, Map<String, String>) - Method in class com.linkedin.alpini.router.ScatterGatherRequestHandlerImpl
appendErrorForEveryKey(BHS, List<HR>, HRS, String, Throwable, ResourcePathParser<P, K>, ScatterGatherRequest<H, K>, P) - Method in class com.linkedin.alpini.router.ScatterGatherRequestHandlerImpl
appendErrorsForOfflinePartitions(BHS, Scatter<H, P, K>, List<AsyncFuture<List<HR>>>) - Method in class com.linkedin.alpini.router.ScatterGatherRequestHandlerImpl
appendFullCommon(StringBuilder, FullHttpMessage) - Static method in class com.linkedin.alpini.netty4.misc.HttpToStringUtils
appendFullRequest(StringBuilder, FullHttpRequest) - Static method in class com.linkedin.alpini.netty4.misc.HttpToStringUtils
appendHeaders(StringBuilder, HttpHeaders) - Static method in class com.linkedin.alpini.netty4.misc.HttpToStringUtils
appendHex(StringBuilder, int) - Static method in enum com.linkedin.alpini.base.misc.HeaderUtils
appendInitialLine(StringBuilder, HttpRequest) - Static method in class com.linkedin.alpini.netty4.misc.HttpToStringUtils
appendStackTrace(StringBuilder, Throwable) - Static method in enum com.linkedin.alpini.base.misc.ExceptionUtil
appendStackTraceElement(StringBuilder, StackTraceElement) - Static method in enum com.linkedin.alpini.base.misc.ExceptionUtil: Appends a StackTraceElement in the same way that StackTraceElement.toString() would except without creating intermediate String objects.
appendTo(B, Iterable<T>) - Method in class com.linkedin.alpini.base.misc.Joiner
appendTo(B, Iterator<T>) - Method in class com.linkedin.alpini.base.misc.Joiner
appendTo(B, T...) - Method in class com.linkedin.alpini.base.misc.Joiner
appendTo(B, T, T, T[]) - Method in class com.linkedin.alpini.base.misc.Joiner
appendTo(StringBuilder, Iterable<T>) - Method in class com.linkedin.alpini.base.misc.Joiner
appendTo(StringBuilder, Iterator<T>) - Method in class com.linkedin.alpini.base.misc.Joiner
appendTo(StringBuilder, T...) - Method in class com.linkedin.alpini.base.misc.Joiner
appendTo(StringBuilder, T, T, T[]) - Method in class com.linkedin.alpini.base.misc.Joiner
apply() - Method in class com.linkedin.alpini.router.monitoring.ScatterGatherStats.Delta
apply(int, int) - Method in interface com.linkedin.venice.utils.BiIntFunction
apply(BasicFullHttpRequest) - Method in class com.linkedin.venice.router.api.VeniceMetricsProvider
apply(DaVinciConfig, ClientConfig, VeniceProperties, Optional<Set<String>>, ICProvider) - Method in interface com.linkedin.davinci.client.factory.CachingDaVinciClientFactory.DaVinciClientConstructor
apply(VenicePath) - Method in class com.linkedin.venice.router.stats.LongTailRetryStatsProvider
apply(INPUT_VALUE) - Method in class com.linkedin.venice.hadoop.AbstractVeniceFilter: This function implements how to parse the value and determine if filtering is needed.
apply(INPUT_VALUE) - Method in class com.linkedin.venice.hadoop.FilterChain: This function passes the value through the filter chain to determine if the value can be filtered out or not.
apply(INPUT_VALUE) - Method in class com.linkedin.venice.hadoop.input.kafka.ttl.VeniceRmdTTLFilter
apply(String, String, D2ControllerClient, int) - Method in interface com.linkedin.davinci.consumer.VeniceChangelogConsumerClientFactory.ViewClassGetter
apply(T, U, S) - Method in interface com.linkedin.alpini.base.misc.TriFunction: Applies this function to the given arguments.
applyAdditionalWriterConfigs(Map<String, String>) - Method in class com.linkedin.venice.samza.VeniceSystemProducer
applyFactoryModifiers(T, List<Function<T, T>>) - Static method in enum com.linkedin.alpini.base.misc.CollectionUtil
applyParams(StoragePersona) - Method in class com.linkedin.venice.controllerapi.UpdateStoragePersonaQueryParams
applyTargetVersionFilterForIncPush - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore: An UpdateStore command option to enable/disable applying the target version filter for incremental pushes
applyTargetVersionFilterForIncPush - Variable in class com.linkedin.venice.systemstore.schemas.StoreProperties: Whether or not the target version field in Kafka messages will be used in increment push to RT policy
applyToEither(CompletionStage<? extends T>, Function<? super T, U>) - Method in class com.linkedin.alpini.base.concurrency.impl.AbstractAsyncFuture
applyToEither(CompletionStage<? extends T>, Function<? super T, U>) - Method in class com.linkedin.alpini.base.concurrency.impl.FailedAsyncFuture
applyToEither(CompletionStage<? extends V>, Function<? super V, U>) - Method in class com.linkedin.alpini.base.concurrency.CompletableFutureTask
applyToEitherAsync(CompletionStage<? extends T>, Function<? super T, U>) - Method in class com.linkedin.alpini.base.concurrency.impl.AbstractAsyncFuture
applyToEitherAsync(CompletionStage<? extends T>, Function<? super T, U>) - Method in class com.linkedin.alpini.base.concurrency.impl.FailedAsyncFuture
applyToEitherAsync(CompletionStage<? extends T>, Function<? super T, U>, Executor) - Method in class com.linkedin.alpini.base.concurrency.impl.AbstractAsyncFuture
applyToEitherAsync(CompletionStage<? extends T>, Function<? super T, U>, Executor) - Method in class com.linkedin.alpini.base.concurrency.impl.FailedAsyncFuture
applyToEitherAsync(CompletionStage<? extends V>, Function<? super V, U>) - Method in class com.linkedin.alpini.base.concurrency.CompletableFutureTask
applyToEitherAsync(CompletionStage<? extends V>, Function<? super V, U>, Executor) - Method in class com.linkedin.alpini.base.concurrency.CompletableFutureTask
applyWriteCompute(GenericRecord, int, int, ByteBuffer, int, int) - Method in class com.linkedin.davinci.kafka.consumer.StoreWriteComputeProcessor: Apply Update operation on the current value record.
AppTimeOutTrackingCompletableFuture<T> - Class in com.linkedin.venice.client.store: CompletableFuture implementation, which is able to track the timeout behavior when happening.
appWorkerChannelMaxMemorySize(long) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
appWorkerChannelMaxMemorySize(long) - Method in interface com.linkedin.alpini.router.impl.Router.Builder
appWorkerCorePoolSize(int) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
appWorkerCorePoolSize(int) - Method in interface com.linkedin.alpini.router.impl.Router.Builder
appWorkerKeepAliveSeconds(long) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
appWorkerKeepAliveSeconds(long) - Method in interface com.linkedin.alpini.router.impl.Router.Builder
appWorkerTotalMaxMemorySize(long) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
appWorkerTotalMaxMemorySize(long) - Method in interface com.linkedin.alpini.router.impl.Router.Builder
ArbitraryOrderingPollStrategy - Class in com.linkedin.venice.unit.kafka.consumer.poll: A PollStrategy implementation which delivers messages in the order specified at construction time.
ArbitraryOrderingPollStrategy(Queue<PubSubTopicPartitionOffset>) - Constructor for class com.linkedin.venice.unit.kafka.consumer.poll.ArbitraryOrderingPollStrategy
ARCHIVED - com.linkedin.venice.pushmonitor.ExecutionStatus: Job is terminated and be removed from repository.
Arg - Enum in com.linkedin.venice: TODO: Merge this with ControllerApiConstants
argumentName() - Method in annotation type com.linkedin.alpini.cli.CLIArgument: Argument name.
array(P...) - Static method in class com.linkedin.alpini.base.misc.Pair: Return an array of Pair.
ARRAY_BLOCKING_QUEUE - com.linkedin.venice.utils.concurrent.BlockingQueueType
ARRAY_LIST - com.linkedin.alpini.base.monitoring.CallTrackerImpl.Mode
ArrayBackedNullSkippingIterator<E> - Class in com.linkedin.venice.utils.collections: This iterator traverses the entire backing array, while skipping over null entries.
ArrayBackedNullSkippingIterator(E[]) - Constructor for class com.linkedin.venice.utils.collections.ArrayBackedNullSkippingIterator
ArrayBasedPrimitiveIntegerSet - Class in com.linkedin.venice.serializer: This class is not thread-safe; it's optimized for GC by maintaining a primitive int array without boxing, but it's slow in add(), contains(), remove(), etc.
ArrayBasedPrimitiveIntegerSet() - Constructor for class com.linkedin.venice.serializer.ArrayBasedPrimitiveIntegerSet
ArrayBasedPrimitiveIntegerSet(int) - Constructor for class com.linkedin.venice.serializer.ArrayBasedPrimitiveIntegerSet
ArrayBasedPrimitiveIntegerSet(int[], int) - Constructor for class com.linkedin.venice.serializer.ArrayBasedPrimitiveIntegerSet
ArrayBasedPrimitiveIntegerSet.PrimitiveIntegerSetIterator - Class in com.linkedin.venice.serializer
ArrayCollection<E> - Class in com.linkedin.venice.utils.collections: Expose an array of ArrayCollection as an immutable Collection Changes to the array are reflected in the collection.
ArrayCollection(E[]) - Constructor for class com.linkedin.venice.utils.collections.ArrayCollection
ArrayCollection(E[], IntSupplier) - Constructor for class com.linkedin.venice.utils.collections.ArrayCollection
ArrayMap<K,V> - Class in com.linkedin.alpini.base.misc: Simple ArrayList backed Map implementation which uses simple linear scans of the list for searching for matching keys.
ArrayMap() - Constructor for class com.linkedin.alpini.base.misc.ArrayMap
ArrayMap(int) - Constructor for class com.linkedin.alpini.base.misc.ArrayMap
ArrayMap(int, BiPredicate<K, K>) - Constructor for class com.linkedin.alpini.base.misc.ArrayMap
ArrayMap(BiPredicate<K, K>) - Constructor for class com.linkedin.alpini.base.misc.ArrayMap
ArrayMap(Map<K, V>) - Constructor for class com.linkedin.alpini.base.misc.ArrayMap
arrayNext() - Method in class org.apache.avro.io.ByteBufferOptimizedBinaryDecoder
ArraySortedSet<E> - Class in com.linkedin.alpini.base.concurrency: A thread-safe SortedSet implementation which uses an array as a backing store.
ArraySortedSet(Comparator<? super E>, int) - Constructor for class com.linkedin.alpini.base.concurrency.ArraySortedSet
asBroadcast() - Method in class com.linkedin.alpini.router.api.ScatterGatherMode
AsciiStringURLCodec - Enum in com.linkedin.alpini.netty4.misc
asCompletableFuture(Future<T>) - Static method in class com.linkedin.alpini.netty4.misc.Futures
ASCTIME_DATE_FORMAT - Static variable in enum com.linkedin.alpini.base.misc.DateUtils
asNettyFuture(EventExecutor, CompletableFuture<T>) - Static method in class com.linkedin.alpini.netty4.misc.Futures
asNettyFuture(CompletableFuture<T>) - Static method in class com.linkedin.alpini.netty4.misc.Futures
asReadOnly() - Method in class com.linkedin.alpini.base.safealloc.DerivedMutableByteBuf
asReadOnly() - Method in class com.linkedin.alpini.base.safealloc.DerivedReadOnlyByteBuf
asScatter() - Method in class com.linkedin.alpini.router.api.ScatterGatherMode
assembleAndGetValue(byte[], Iterator<BytesWritable>) - Method in class com.linkedin.venice.hadoop.input.kafka.chunk.ChunkAssembler: The `valueIterator` of this function is supposed to be in descending order by offset.
assertCommand(T) - Static method in class com.linkedin.venice.utils.TestUtils
assertCommand(T, String) - Static method in class com.linkedin.venice.utils.TestUtils
assignConsumerFor(PubSubTopic, PubSubTopicPartition) - Method in class com.linkedin.davinci.kafka.consumer.KafkaConsumerService: This function assigns a consumer for the given StoreIngestionTask and returns the assigned consumer.
asUnmodifiableList(float[]) - Static method in class com.linkedin.venice.utils.CollectionUtils
asyncDelete(long, K) - Method in class com.linkedin.venice.producer.AbstractVeniceProducer
asyncDelete(long, K) - Method in interface com.linkedin.venice.producer.VeniceProducer: A write operation to delete the record for a key.
asyncDelete(K) - Method in class com.linkedin.venice.producer.AbstractVeniceProducer
asyncDelete(K) - Method in interface com.linkedin.venice.producer.VeniceProducer: A write operation to delete the record for a key.
AsyncFullHttpRequestHandler - Class in com.linkedin.alpini.netty4.handlers
AsyncFullHttpRequestHandler(AsyncFullHttpRequestHandler.RequestHandler, BooleanSupplier) - Constructor for class com.linkedin.alpini.netty4.handlers.AsyncFullHttpRequestHandler
AsyncFullHttpRequestHandler(AsyncFullHttpRequestHandler.RequestHandler, BooleanSupplier, BooleanSupplier) - Constructor for class com.linkedin.alpini.netty4.handlers.AsyncFullHttpRequestHandler
AsyncFullHttpRequestHandler.RequestHandler - Interface in com.linkedin.alpini.netty4.handlers
AsyncFuture<T> - Interface in com.linkedin.alpini.base.concurrency: A Future which has very netty-style semantics where AsyncFutureListener can be added to the future to be executed upon condition of Success or Failure has been satisfied.
AsyncFuture.Status - Enum in com.linkedin.alpini.base.concurrency
AsyncFutureListener<T> - Interface in com.linkedin.alpini.base.concurrency: An interface (lambda) which is fired upon completion of an AsyncFuture.
AsyncPartitionFinder<K> - Interface in com.linkedin.alpini.router.api: Created by acurtis on 1/26/18.
AsyncPool<T> - Interface in com.linkedin.alpini.base.pool
AsyncPool.LifeCycle<T> - Interface in com.linkedin.alpini.base.pool
AsyncPoolImpl<T> - Class in com.linkedin.alpini.base.pool.impl
AsyncPoolImpl(AsyncPool.LifeCycle<T>, Executor, int, int, int, int, long, TimeUnit) - Constructor for class com.linkedin.alpini.base.pool.impl.AsyncPoolImpl
AsyncPoolImpl.ShutdownException - Exception in com.linkedin.alpini.base.pool.impl
AsyncPoolImpl.TooManyWaitersException - Exception in com.linkedin.alpini.base.pool.impl
AsyncPromise<T> - Interface in com.linkedin.alpini.base.concurrency: A completable AsyncFuture interface.
asyncPut(long, K, V) - Method in class com.linkedin.venice.producer.AbstractVeniceProducer
asyncPut(long, K, V) - Method in interface com.linkedin.venice.producer.VeniceProducer: A write operation where a full value is written to replace the existing value.
asyncPut(K, V) - Method in class com.linkedin.venice.producer.AbstractVeniceProducer
asyncPut(K, V) - Method in interface com.linkedin.venice.producer.VeniceProducer: A write operation where a full value is written to replace the existing value.
AsyncQOSPool<T> - Interface in com.linkedin.alpini.base.pool
AsyncQOSPoolImpl<T> - Class in com.linkedin.alpini.base.pool.impl
AsyncQOSPoolImpl(AsyncPool.LifeCycle<T>, QOSPolicy.StaticConfig, Executor, int, int, int, long, TimeUnit) - Constructor for class com.linkedin.alpini.base.pool.impl.AsyncQOSPoolImpl
asyncSendControlMessage(ControlMessage, int, Map<String, String>, PubSubProducerCallback, LeaderMetadataWrapper) - Method in class com.linkedin.venice.writer.VeniceWriter: This API should be only used in Leader/Standby model for store ingestion.
asyncUpdate(long, K, Consumer<UpdateBuilder>) - Method in class com.linkedin.venice.producer.AbstractVeniceProducer
asyncUpdate(long, K, Consumer<UpdateBuilder>) - Method in interface com.linkedin.venice.producer.VeniceProducer: A write operation to modify a subset of fields in the record for a key.
asyncUpdate(K, Consumer<UpdateBuilder>) - Method in class com.linkedin.venice.producer.AbstractVeniceProducer
asyncUpdate(K, Consumer<UpdateBuilder>) - Method in interface com.linkedin.venice.producer.VeniceProducer: A write operation to modify a subset of fields in the record for a key.
attr(AttributeKey<T>) - Method in class com.linkedin.alpini.netty4.misc.BasicHttpMultiPart: Get the Attribute for the given AttributeKey.
attr(AttributeKey<T>) - Method in class com.linkedin.alpini.netty4.misc.BasicHttpRequest: Get the Attribute for the given AttributeKey.
attr(AttributeKey<T>) - Method in class com.linkedin.alpini.netty4.misc.BasicHttpResponse: Get the Attribute for the given AttributeKey.
attr(AttributeKey<T>, T) - Method in class io.netty.handler.codec.http2.EspressoHttp2StreamChannelBootstrap: Allow to specify an initial attribute of the newly created Http2StreamChannel.
AuditInfo - Class in com.linkedin.venice.controller
AuditInfo(Request) - Constructor for class com.linkedin.venice.controller.AuditInfo
AuthorizerService - Interface in com.linkedin.venice.authorization: An interface to provide functionality to manage ACL's for a Resource and provide access permission Permission to principals Principal when performing Method.
AUTO_SCHEMA_REGISTER_FOR_PUSHJOB_ENABLED - com.linkedin.venice.Arg
AUTO_SCHEMA_REGISTER_FOR_PUSHJOB_ENABLED - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
AutoCloseableLock - Class in com.linkedin.venice.utils.locks: Concrete implementations are expected to lock their inner lock(s) in their own constructor.
AutoCloseableLock() - Constructor for class com.linkedin.venice.utils.locks.AutoCloseableLock
AutoCloseableMultiLock - Class in com.linkedin.venice.utils.locks
AutoCloseableSingleLock - Class in com.linkedin.venice.utils.locks
AUTOCREATE_DATA_PATH - Static variable in class com.linkedin.venice.ConfigKeys
available() - Method in class com.linkedin.alpini.io.ZeroInputStream
availableSchemaIds - Variable in class com.linkedin.davinci.kafka.consumer.StoreIngestionTask
avgAndMax() - Method in class com.linkedin.venice.stats.AbstractVeniceStats
avgAndTotal() - Method in class com.linkedin.venice.stats.AbstractVeniceStats
AVRO_1_4 - com.linkedin.venice.controller.kafka.protocol.enums.SchemaType
AVRO_BINARY - Static variable in class com.linkedin.venice.HttpConstants
AvroBlackHoleResponseStoreClientImpl<K,V> - Class in com.linkedin.venice.client.store: This class should be used for experiments only.
AvroBlackHoleResponseStoreClientImpl(TransportClient, ClientConfig) - Constructor for class com.linkedin.venice.client.store.AvroBlackHoleResponseStoreClientImpl
AvroCollectionElementComparator - Class in com.linkedin.davinci.schema.merge: This comparator is used to compare GenericRecord collection field elements which must have schemas.
AvroCompatibilityUtils - Class in com.linkedin.venice.utils
AvroCompatibilityUtils() - Constructor for class com.linkedin.venice.utils.AvroCompatibilityUtils
AvroComputeRequestBuilderV3<K> - Class in com.linkedin.venice.client.store: This class is used to build a ComputeRequestWrapper object according to the specification, and this class will invoke AbstractAvroStoreClient to send the 'compute' request to backend.
AvroComputeRequestBuilderV3(AvroGenericReadComputeStoreClient, Schema) - Constructor for class com.linkedin.venice.client.store.AvroComputeRequestBuilderV3
AvroComputeRequestBuilderV4<K> - Class in com.linkedin.venice.client.store
AvroComputeRequestBuilderV4(AvroGenericReadComputeStoreClient, Schema) - Constructor for class com.linkedin.venice.client.store.AvroComputeRequestBuilderV4
avroElementComparator - Variable in class com.linkedin.davinci.schema.merge.CollectionFieldOperationHandler
AvroGenericDaVinciClient<K,V> - Class in com.linkedin.davinci.client
AvroGenericDaVinciClient(DaVinciConfig, ClientConfig, VeniceProperties, Optional<Set<String>>) - Constructor for class com.linkedin.davinci.client.AvroGenericDaVinciClient
AvroGenericDaVinciClient(DaVinciConfig, ClientConfig, VeniceProperties, Optional<Set<String>>, ICProvider) - Constructor for class com.linkedin.davinci.client.AvroGenericDaVinciClient
AvroGenericDaVinciClient(DaVinciConfig, ClientConfig, VeniceProperties, Optional<Set<String>>, ICProvider, AbstractAvroChunkingAdapter<V>, Runnable) - Constructor for class com.linkedin.davinci.client.AvroGenericDaVinciClient
AvroGenericDeserializer<V> - Class in com.linkedin.venice.serializer
AvroGenericDeserializer(DatumReader<V>) - Constructor for class com.linkedin.venice.serializer.AvroGenericDeserializer
AvroGenericDeserializer(Schema, Schema) - Constructor for class com.linkedin.venice.serializer.AvroGenericDeserializer
AvroGenericDeserializer.IterableImpl - Enum in com.linkedin.venice.serializer: Deprecated.
AvroGenericReadComputeStoreClient<K,V> - Interface in com.linkedin.venice.client.store: Venice avro generic client to provide read compute operations
AvroGenericStoreClient<K,V> - Interface in com.linkedin.venice.client.store: Venice avro generic client to communicate with Venice backend for key-value lookup.
AvroGenericStoreClientImpl<K,V> - Class in com.linkedin.venice.client.store: AvroGenericStoreClient implementation for Avro generic type.
AvroGenericStoreClientImpl(TransportClient, boolean, ClientConfig) - Constructor for class com.linkedin.venice.client.store.AvroGenericStoreClientImpl
AvroGenericStoreClientImpl(TransportClient, ClientConfig) - Constructor for class com.linkedin.venice.client.store.AvroGenericStoreClientImpl
AvroProtocolDefinition - Enum in com.linkedin.venice.serialization.avro: This enum lays out the basic specs of the various stateful protocols used in Venice.
AvroRecordUtils - Class in com.linkedin.venice.utils
AvroSchemaParseUtils - Class in com.linkedin.venice.schema
AvroSchemaUtils - Class in com.linkedin.venice.utils
AvroSerializer<K> - Class in com.linkedin.venice.serializer: AvroSerializer provides the functionality to serialize objects by using Avro.
AvroSerializer(DatumWriter<K>, DatumWriter<K>) - Constructor for class com.linkedin.venice.serializer.AvroSerializer
AvroSerializer(DatumWriter<K>, DatumWriter<K>, boolean) - Constructor for class com.linkedin.venice.serializer.AvroSerializer
AvroSerializer(Schema) - Constructor for class com.linkedin.venice.serializer.AvroSerializer
AvroSerializer(Schema, boolean) - Constructor for class com.linkedin.venice.serializer.AvroSerializer
AvroSpecificDaVinciClient<K,V extends org.apache.avro.specific.SpecificRecord> - Class in com.linkedin.davinci.client
AvroSpecificDaVinciClient(DaVinciConfig, ClientConfig, VeniceProperties, Optional<Set<String>>, ICProvider) - Constructor for class com.linkedin.davinci.client.AvroSpecificDaVinciClient
AvroSpecificDeserializer<T extends org.apache.avro.specific.SpecificRecord> - Class in com.linkedin.venice.serializer
AvroSpecificDeserializer(DatumReader<T>) - Constructor for class com.linkedin.venice.serializer.AvroSpecificDeserializer
AvroSpecificDeserializer(Schema, Class<T>) - Constructor for class com.linkedin.venice.serializer.AvroSpecificDeserializer
AvroSpecificStoreClient<K,V extends org.apache.avro.specific.SpecificRecord> - Interface in com.linkedin.venice.client.store: AvroSpecificStoreClient for type safety purpose.
AvroSpecificStoreClientImpl<K,V extends org.apache.avro.specific.SpecificRecord> - Class in com.linkedin.venice.client.store: AvroSpecificStoreClient implementation for Avro SpecificRecord.
AvroSpecificStoreClientImpl(TransportClient, ClientConfig) - Constructor for class com.linkedin.venice.client.store.AvroSpecificStoreClientImpl
AvroStoreDeserializerCache<T> - Class in com.linkedin.venice.serialization: Container for the deserializers of a single store.
AvroStoreDeserializerCache(ReadOnlySchemaRepository, String, boolean) - Constructor for class com.linkedin.venice.serialization.AvroStoreDeserializerCache
AvroStoreDeserializerCache(ReadOnlySchemaRepository, String, Class) - Constructor for class com.linkedin.venice.serialization.AvroStoreDeserializerCache
AvroSupersetSchemaUtils - Class in com.linkedin.venice.utils
await() - Method in interface com.linkedin.alpini.base.concurrency.AsyncFuture: Waits for this future to be completed.
await() - Method in class com.linkedin.alpini.base.concurrency.BlockingLatch
await() - Method in class com.linkedin.alpini.base.concurrency.impl.DefaultAsyncFuture
await() - Method in class com.linkedin.alpini.base.concurrency.impl.FailedAsyncFuture: Waits for this future to be completed.
await() - Method in class com.linkedin.alpini.base.concurrency.impl.SuccessAsyncFuture: Waits for this future to be completed.
await() - Method in class com.linkedin.alpini.base.misc.PromiseDelegate
await() - Method in class com.linkedin.alpini.io.CompressOutputStream
await() - Method in class io.netty.bootstrap.PendingConnectFuturePromise
await() - Method in class io.netty.bootstrap.PendingConnectPromise
await(long) - Method in class com.linkedin.alpini.base.misc.PromiseDelegate
await(long, TimeUnit) - Method in interface com.linkedin.alpini.base.concurrency.AsyncFuture: Waits for this future to be completed within the specified time limit.
await(long, TimeUnit) - Method in class com.linkedin.alpini.base.concurrency.BlockingLatch
await(long, TimeUnit) - Method in class com.linkedin.alpini.base.concurrency.impl.DefaultAsyncFuture
await(long, TimeUnit) - Method in class com.linkedin.alpini.base.concurrency.impl.FailedAsyncFuture: Waits for this future to be completed within the specified time limit.
await(long, TimeUnit) - Method in class com.linkedin.alpini.base.concurrency.impl.SuccessAsyncFuture: Waits for this future to be completed within the specified time limit.
await(long, TimeUnit) - Method in class com.linkedin.alpini.base.misc.PromiseDelegate
await(long, TimeUnit) - Method in interface com.linkedin.alpini.base.misc.Time.Awaitable
await(long, TimeUnit) - Method in class com.linkedin.alpini.io.CompressOutputStream
await(Time.Awaitable, long, TimeUnit) - Static method in enum com.linkedin.alpini.base.misc.Time
await(CountDownLatch, long, TimeUnit) - Static method in enum com.linkedin.alpini.base.misc.Time
await(Condition, long, TimeUnit) - Static method in enum com.linkedin.alpini.base.misc.Time
awaitTermination(int, TimeUnit) - Method in class com.linkedin.alpini.base.concurrency.TimeoutProcessor
awaitTermination(long, TimeUnit) - Method in class com.linkedin.alpini.base.registry.impl.ShutdownableExecutorServiceImpl
awaitTermination(long, TimeUnit) - Method in class com.linkedin.alpini.netty4.misc.BalancedEventLoopGroup
awaitTermination(long, TimeUnit) - Method in class com.linkedin.alpini.netty4.misc.InstrumentibleEventExecutor
awaitTermination(long, TimeUnit) - Method in class com.linkedin.alpini.netty4.misc.LocalThreadEventLoopGroup
awaitTermination(long, TimeUnit) - Method in class com.linkedin.alpini.netty4.misc.ShutdownableEventLoopGroup
awaitUninterruptibly() - Method in interface com.linkedin.alpini.base.concurrency.AsyncFuture: Waits for this future to be completed without interruption.
awaitUninterruptibly() - Method in class com.linkedin.alpini.base.concurrency.BlockingLatch
awaitUninterruptibly() - Method in class com.linkedin.alpini.base.concurrency.impl.DefaultAsyncFuture
awaitUninterruptibly() - Method in class com.linkedin.alpini.base.concurrency.impl.FailedAsyncFuture: Waits for this future to be completed without interruption.
awaitUninterruptibly() - Method in class com.linkedin.alpini.base.concurrency.impl.SuccessAsyncFuture: Waits for this future to be completed without interruption.
awaitUninterruptibly() - Method in class com.linkedin.alpini.base.misc.PromiseDelegate
awaitUninterruptibly() - Method in class io.netty.bootstrap.PendingConnectFuturePromise
awaitUninterruptibly() - Method in class io.netty.bootstrap.PendingConnectPromise
awaitUninterruptibly(long) - Method in class com.linkedin.alpini.base.misc.PromiseDelegate
awaitUninterruptibly(long, TimeUnit) - Method in interface com.linkedin.alpini.base.concurrency.AsyncFuture: Waits for this future to be completed within the specified time limit without interruption.
awaitUninterruptibly(long, TimeUnit) - Method in class com.linkedin.alpini.base.concurrency.BlockingLatch
awaitUninterruptibly(long, TimeUnit) - Method in class com.linkedin.alpini.base.concurrency.impl.DefaultAsyncFuture
awaitUninterruptibly(long, TimeUnit) - Method in class com.linkedin.alpini.base.concurrency.impl.FailedAsyncFuture: Waits for this future to be completed within the specified time limit without interruption.
awaitUninterruptibly(long, TimeUnit) - Method in class com.linkedin.alpini.base.concurrency.impl.SuccessAsyncFuture: Waits for this future to be completed within the specified time limit without interruption.
awaitUninterruptibly(long, TimeUnit) - Method in class com.linkedin.alpini.base.misc.PromiseDelegate

B

b2c(byte) - Static method in class com.linkedin.alpini.base.misc.ByteBufAsciiString
B64_FORMAT - Static variable in class com.linkedin.venice.client.store.AbstractAvroStoreClient
B64_FORMAT - Static variable in class com.linkedin.venice.RequestConstants
backendConfig - Variable in class com.linkedin.davinci.client.factory.CachingDaVinciClientFactory
BACKFILL_SYSTEM_STORES - com.linkedin.venice.Command
BackgroundChannelHandler - Class in com.linkedin.alpini.netty4.handlers: Created by acurtis on 5/4/17.
BackgroundChannelHandler(ChannelHandler...) - Constructor for class com.linkedin.alpini.netty4.handlers.BackgroundChannelHandler
BackgroundChannelHandler(Supplier<ChannelHandler[]>) - Constructor for class com.linkedin.alpini.netty4.handlers.BackgroundChannelHandler
BACKUP_STRATEGY - com.linkedin.venice.Arg
BACKUP_STRATEGY - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
BACKUP_VERSION_RETENTION_DAY - com.linkedin.venice.Arg
BACKUP_VERSION_RETENTION_MS - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
backupStrategy - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore: Strategies to store backup versions.
backupStrategy - Variable in class com.linkedin.venice.meta.systemstore.schemas.StoreProperties
backupStrategy - Variable in class com.linkedin.venice.systemstore.schemas.StoreProperties: Strategies to store backup versions, and default is 'DELETE_ON_NEW_PUSH_START'
BackupStrategy - Enum in com.linkedin.venice.meta: Enums of the strategies used to backup older store versions in Venice.
BackupVersionOptimizationService - Class in com.linkedin.venice.cleaner: This class is used to periodically scan inactive store versions and perform optimization if the inactive period of some store version meets the pre-configured threshold, this class will trigger the database reopen action to unload unnecessary RAM usage, which was built up when there were active reads coming.
BackupVersionOptimizationService(ReadOnlyStoreRepository, StorageEngineRepository, long, long, BackupVersionOptimizationServiceStats) - Constructor for class com.linkedin.venice.cleaner.BackupVersionOptimizationService: Allocate and initialize a new BackupVersionOptimizationService object.
BackupVersionOptimizationServiceStats - Class in com.linkedin.venice.stats: BackupVersionOptimizationServiceStats record the statistics for the database optimization done by the BackupVersionOptimizationService including both successes and failures.
BackupVersionOptimizationServiceStats(MetricsRepository, String) - Constructor for class com.linkedin.venice.stats.BackupVersionOptimizationServiceStats
backupVersionRetentionMs - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore: Backup version retention time after a new version is promoted to the current version, if not specified, Venice will use the configured retention as the default policy
backupVersionRetentionMs - Variable in class com.linkedin.venice.systemstore.schemas.StoreProperties: Backup retention time, and if it is not set (-1), Venice Controller will use the default configured retention.
BACKWARD - com.linkedin.venice.schema.avro.DirectionalSchemaCompatibilityType: Clients using the new schema should be able to read data written with the old schema.
BAD_MESSAGE - com.linkedin.alpini.netty4.misc.BasicHttpObjectDecoder.State
BAD_REQUEST - com.linkedin.venice.exceptions.ErrorType
BAD_REQUEST - com.linkedin.venice.exceptions.ExceptionType: Deprecated.
BAD_REQUEST - Static variable in class com.linkedin.venice.grpc.GrpcErrorCodes
BadHttpRequest - Interface in com.linkedin.alpini.netty4.misc: Created by acurtis on 9/28/17.
badRequest() - Method in class com.linkedin.alpini.router.ScatterGatherRequestHandler4
badRequest() - Method in class com.linkedin.alpini.router.ScatterGatherRequestHandlerImpl
BalancedEventLoopGroup - Class in com.linkedin.alpini.netty4.misc: An EventLoopGroup instance which may be passed to an instance of Bootstrap to ensure that there is a reasonably fair balance of connections for the supplied AllChannelsHandler.
BalancedEventLoopGroup(EventLoopGroup, AllChannelsHandler) - Constructor for class com.linkedin.alpini.netty4.misc.BalancedEventLoopGroup
BalancedEventLoopGroup(EventLoopGroup, AllChannelsHandler, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BalancedEventLoopGroup
base64Decode(byte[]) - Static method in class com.linkedin.venice.utils.EncodingUtils
base64DecodeFromString(String) - Static method in class com.linkedin.venice.utils.EncodingUtils
base64Encode(byte[]) - Static method in class com.linkedin.venice.utils.EncodingUtils
base64Encoded() - Method in class com.linkedin.venice.router.api.RouterKey
base64EncodeToString(byte[]) - Static method in class com.linkedin.venice.utils.EncodingUtils
base64EncodeToString(ByteBuffer) - Static method in class com.linkedin.venice.utils.EncodingUtils
BasicClientStats - Class in com.linkedin.venice.client.stats: This class offers very basic metrics for client, and right now, it is directly used by DaVinci.
BasicClientStats(MetricsRepository, String, RequestType) - Constructor for class com.linkedin.venice.client.stats.BasicClientStats
BasicDnsResolver - Class in com.linkedin.alpini.netty4.pool: A simple asynchronous resolver which uses the default JVM blocking resolver.
BasicDnsResolver() - Constructor for class com.linkedin.alpini.netty4.pool.BasicDnsResolver
BasicFullHttpMultiPart - Class in com.linkedin.alpini.netty4.misc: Created by acurtis on 3/22/17.
BasicFullHttpMultiPart() - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPart(boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPart(boolean, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPart(ByteBuf) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPart(ByteBuf, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPart(ByteBuf, boolean, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPart(ByteBuf, HttpHeaders) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPart(HttpMessage) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPart(HttpMessage, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPart(HttpMessage, boolean, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPart(HttpMessage, ByteBuf) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPart(HttpMessage, ByteBuf, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPart(HttpMessage, ByteBuf, boolean, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPart(HttpMessage, ByteBuf, HttpHeaders) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPart(AttributeMap, ByteBuf, HttpHeaders) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPart
BasicFullHttpMultiPartRequest - Class in com.linkedin.alpini.netty4.misc: Created by acurtis on 3/27/17.
BasicFullHttpMultiPartRequest(HttpVersion, HttpMethod, String, boolean, long, long) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPartRequest
BasicFullHttpMultiPartRequest(HttpVersion, HttpMethod, String, long, long) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPartRequest
BasicFullHttpMultiPartRequest(HttpVersion, HttpMethod, String, Collection<FullHttpMultiPart>, boolean, long, long) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPartRequest
BasicFullHttpMultiPartRequest(HttpVersion, HttpMethod, String, Collection<FullHttpMultiPart>, long, long) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPartRequest
BasicFullHttpMultiPartRequest(HttpVersion, HttpMethod, String, Collection<FullHttpMultiPart>, HttpHeaders, HttpHeaders, UUID, long, long) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpMultiPartRequest
BasicFullHttpRequest - Class in com.linkedin.alpini.netty4.misc
BasicFullHttpRequest(FullHttpRequest) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpRequest
BasicFullHttpRequest(HttpRequest, HttpHeaders, HttpHeaders, ByteBuf) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpRequest
BasicFullHttpRequest(HttpVersion, HttpMethod, String, boolean, long, long) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpRequest
BasicFullHttpRequest(HttpVersion, HttpMethod, String, long, long) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpRequest
BasicFullHttpRequest(HttpVersion, HttpMethod, String, ByteBuf, boolean, long, long) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpRequest
BasicFullHttpRequest(HttpVersion, HttpMethod, String, ByteBuf, long, long) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpRequest
BasicFullHttpRequest(HttpVersion, HttpMethod, String, ByteBuf, HttpHeaders, HttpHeaders, UUID, long, long) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpRequest
BasicFullHttpResponse - Class in com.linkedin.alpini.netty4.misc: Created by acurtis on 4/19/17.
BasicFullHttpResponse(FullHttpResponse) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpResponse
BasicFullHttpResponse(HttpRequest, HttpResponseStatus) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpResponse
BasicFullHttpResponse(HttpRequest, HttpResponseStatus, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpResponse
BasicFullHttpResponse(HttpRequest, HttpResponseStatus, boolean, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpResponse
BasicFullHttpResponse(HttpRequest, HttpResponseStatus, ByteBuf) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpResponse
BasicFullHttpResponse(HttpRequest, HttpResponseStatus, ByteBuf, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpResponse
BasicFullHttpResponse(HttpRequest, HttpResponseStatus, ByteBuf, boolean, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpResponse
BasicFullHttpResponse(HttpRequest, HttpResponseStatus, ByteBuf, HttpHeaders, HttpHeaders) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpResponse
BasicFullHttpResponse(HttpResponse, HttpHeaders, HttpHeaders, ByteBuf) - Constructor for class com.linkedin.alpini.netty4.misc.BasicFullHttpResponse
BasicHeaders - Class in com.linkedin.alpini.netty4.misc
BasicHeaders(HttpHeaders) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHeaders
BasicHttpClientCodec - Class in com.linkedin.alpini.netty4.handlers: A combination of HttpRequestEncoder and BasicHttpResponseDecoder which enables easier client side HTTP implementation.
BasicHttpClientCodec() - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpClientCodec: Creates a new instance with the default decoder options (maxInitialLineLength (4096}, maxHeaderSize (8192), and maxChunkSize (8192)).
BasicHttpClientCodec(int, int, int) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpClientCodec: Creates a new instance with the specified decoder options.
BasicHttpClientCodec(int, int, int, boolean) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpClientCodec: Creates a new instance with the specified decoder options.
BasicHttpClientCodec(int, int, int, boolean, boolean) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpClientCodec: Creates a new instance with the specified decoder options.
BasicHttpClientCodec(int, int, int, boolean, boolean, boolean) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpClientCodec: Creates a new instance with the specified decoder options.
BasicHttpClientCodec(int, int, int, boolean, boolean, int) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpClientCodec: Creates a new instance with the specified decoder options.
BasicHttpClientCodec(int, int, int, boolean, boolean, int, boolean) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpClientCodec: Creates a new instance with the specified decoder options.
BasicHttpContentEncoder - Class in com.linkedin.alpini.netty4.handlers: A replacement for the Netty HttpContentEncoder which can handle use in client and server pipelines.
BasicHttpContentEncoder() - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpContentEncoder
BasicHttpMultiPart - Class in com.linkedin.alpini.netty4.misc: Created by acurtis on 3/22/17.
BasicHttpMultiPart() - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpMultiPart
BasicHttpMultiPart(boolean, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpMultiPart
BasicHttpMultiPart(HttpHeaders) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpMultiPart
BasicHttpMultiPart(HttpMessage) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpMultiPart
BasicHttpMultiPart(HttpMessage, boolean, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpMultiPart
BasicHttpMultiPart(HttpMessage, HttpHeaders) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpMultiPart
BasicHttpNonMultiPartAggregator - Class in com.linkedin.alpini.netty4.handlers: Created by acurtis on 3/24/17.
BasicHttpNonMultiPartAggregator(int) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpNonMultiPartAggregator
BasicHttpNonMultiPartAggregator(int, boolean) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpNonMultiPartAggregator
BasicHttpObjectAggregator - Class in com.linkedin.alpini.netty4.handlers
BasicHttpObjectAggregator(int) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpObjectAggregator: Creates a new instance.
BasicHttpObjectAggregator(int, boolean) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpObjectAggregator: Creates a new instance.
BasicHttpObjectDecoder - Class in com.linkedin.alpini.netty4.misc
BasicHttpObjectDecoder() - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpObjectDecoder: Creates a new instance with the default maxInitialLineLength (4096}, maxHeaderSize (8192), and maxChunkSize (8192).
BasicHttpObjectDecoder(int, int, int, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpObjectDecoder: Creates a new instance with the specified parameters.
BasicHttpObjectDecoder(int, int, int, boolean, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpObjectDecoder: Creates a new instance with the specified parameters.
BasicHttpObjectDecoder(int, int, int, boolean, boolean, int) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpObjectDecoder
BasicHttpObjectDecoder.State - Enum in com.linkedin.alpini.netty4.misc: The internal state of BasicHttpObjectDecoder.
BasicHttpRequest - Class in com.linkedin.alpini.netty4.misc
BasicHttpRequest(HttpRequest) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpRequest
BasicHttpRequest(HttpRequest, HttpHeaders) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpRequest
BasicHttpRequest(HttpVersion, HttpMethod, String) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpRequest: Creates a new instance.
BasicHttpRequest(HttpVersion, HttpMethod, String, boolean, long, long) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpRequest: Creates a new instance.
BasicHttpRequest(HttpVersion, HttpMethod, String, long, long) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpRequest: Creates a new instance.
BasicHttpRequest(HttpVersion, HttpMethod, String, HttpHeaders, UUID, long, long) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpRequest: Creates a new instance.
BasicHttpRequestDecoder - Class in com.linkedin.alpini.netty4.misc
BasicHttpRequestDecoder() - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpRequestDecoder: Creates a new instance with the default maxInitialLineLength (4096), maxHeaderSize (8192), and maxChunkSize (8192).
BasicHttpRequestDecoder(int, int, int) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpRequestDecoder: Creates a new instance with the specified parameters.
BasicHttpRequestDecoder(int, int, int, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpRequestDecoder
BasicHttpRequestDecoder(int, int, int, boolean, int) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpRequestDecoder
BasicHttpRequestSerializer - Class in com.linkedin.alpini.netty4.misc: Created by acurtis on 8/15/17.
BasicHttpRequestSerializer(ByteBufAllocator) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpRequestSerializer
BasicHttpResponse - Class in com.linkedin.alpini.netty4.misc: Created by acurtis on 3/23/17.
BasicHttpResponse(HttpRequest, HttpResponseStatus) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpResponse
BasicHttpResponse(HttpRequest, HttpResponseStatus, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpResponse
BasicHttpResponse(HttpRequest, HttpResponseStatus, boolean, boolean) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpResponse
BasicHttpResponse(HttpRequest, HttpResponseStatus, HttpHeaders) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpResponse
BasicHttpResponse(HttpResponse) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpResponse
BasicHttpResponse(HttpResponse, HttpHeaders) - Constructor for class com.linkedin.alpini.netty4.misc.BasicHttpResponse
BasicHttpResponseDecoder - Class in com.linkedin.alpini.netty4.handlers: Decodes ByteBufs into HttpResponses and HttpContents.
BasicHttpResponseDecoder() - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpResponseDecoder: Creates a new instance with the default maxInitialLineLength (4096), maxHeaderSize (8192), and maxChunkSize (8192).
BasicHttpResponseDecoder(int, int, int) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpResponseDecoder: Creates a new instance with the specified parameters.
BasicHttpResponseDecoder(int, int, int, boolean) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpResponseDecoder
BasicHttpResponseDecoder(int, int, int, boolean, int) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpResponseDecoder
BasicHttpServerCodec - Class in com.linkedin.alpini.netty4.handlers
BasicHttpServerCodec() - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpServerCodec: Creates a new instance with the default decoder options (maxInitialLineLength (4096}, maxHeaderSize (8192), and maxChunkSize (8192)).
BasicHttpServerCodec(int, int, int) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpServerCodec: Creates a new instance with the specified decoder options.
BasicHttpServerCodec(int, int, int, boolean) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpServerCodec: Creates a new instance with the specified decoder options.
BasicHttpServerCodec(int, int, int, boolean, int) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicHttpServerCodec: Creates a new instance with the specified decoder options.
BasicHttpServerCodec.Decoder - Class in com.linkedin.alpini.netty4.handlers
BasicHttpServerCodec.Encoder - Class in com.linkedin.alpini.netty4.handlers
BasicHttpServerCodec.ResponseOutOfSequence - Exception in com.linkedin.alpini.netty4.handlers
BasicRequest - Interface in com.linkedin.alpini.base.misc
BasicServerChannelInitializer<C extends io.netty.channel.Channel,FACTORY extends BasicServerChannelInitializer<C,FACTORY>> - Class in com.linkedin.alpini.netty4.handlers
BasicServerChannelInitializer(ConnectionLimitHandler, ActiveStreamsCountHandler, Http2SettingsFrameLogger, Timer, BooleanSupplier, AsyncFullHttpRequestHandler.RequestHandler) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicServerChannelInitializer
BasicServerChannelInitializer(ConnectionLimitHandler, ActiveStreamsCountHandler, Http2SettingsFrameLogger, Timer, BooleanSupplier, BooleanSupplier, AsyncFullHttpRequestHandler.RequestHandler) - Constructor for class com.linkedin.alpini.netty4.handlers.BasicServerChannelInitializer
BATCH - com.linkedin.venice.meta.Version.PushType
BATCH_CREATE - com.linkedin.venice.authorization.Method
BATCH_DELETE - com.linkedin.venice.authorization.Method
BATCH_FOLLOWER_OFFSET_LAG - Static variable in class com.linkedin.davinci.stats.IngestionStats
BATCH_GET - com.linkedin.venice.authorization.Method
BATCH_GET_LIMIT - com.linkedin.venice.Arg
BATCH_GET_LIMIT - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
BATCH_GET_ROUTER_CACHE_ENABLED - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
BATCH_JOB_HEARTBEAT - com.linkedin.venice.serialization.avro.AvroProtocolDefinition
BATCH_JOB_HEARTBEAT_ENABLED - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
BATCH_JOB_HEARTBEAT_STORE - com.linkedin.venice.common.VeniceSystemStoreType
BATCH_LEADER_OFFSET_LAG - Static variable in class com.linkedin.davinci.stats.IngestionStats
BATCH_NUM_BYTES_PROP - Static variable in class com.linkedin.venice.hadoop.VenicePushJob
BATCH_ONLY - com.linkedin.venice.meta.VeniceUserStoreType: The data in batch-only stores will be populated by offline pushes/Samza reprocessing only.
BATCH_PARTIAL_UPDATE - com.linkedin.venice.authorization.Method
BATCH_REPLICATION_LAG - Static variable in class com.linkedin.davinci.stats.IngestionStats
BATCH_UPDATE - com.linkedin.venice.authorization.Method
BATCH_WRITE_LOSES - com.linkedin.davinci.replication.BatchConflictResolutionPolicy: Incoming data from Batch push should always be overwritten by real-time updates.
batchConflictResolutionPolicy - Variable in class com.linkedin.venice.kafka.protocol.state.StoreVersionState: The policy to determine timestamps of batch push records.
BatchConflictResolutionPolicy - Enum in com.linkedin.davinci.replication
BatchDeserializer<E,K,V> - Class in com.linkedin.venice.client.store.deserialization: This API controls the behavior of the user payload deserialization phase of the batch get response handling.
BatchDeserializerType - Enum in com.linkedin.venice.client.store.deserialization: This enum controls the behavior of the user payload deserialization phase of the batch get response handling.
batchGet(BatchGetRequestContext<K, V>, Set<K>) - Method in class com.linkedin.venice.fastclient.DelegatingAvroStoreClient
batchGet(BatchGetRequestContext<K, V>, Set<K>) - Method in class com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient: batchGet using streamingBatchGet implementation
batchGet(BatchGetRequestContext<K, V>, Set<K>) - Method in class com.linkedin.venice.fastclient.DualReadAvroGenericStoreClient
batchGet(BatchGetRequestContext<K, V>, Set<K>) - Method in class com.linkedin.venice.fastclient.InternalAvroStoreClient
batchGet(BatchGetRequestContext<K, V>, Set<K>) - Method in class com.linkedin.venice.fastclient.RetriableAvroGenericStoreClient: The logic is copied from DispatchingAvroGenericStoreClient.streamingBatchGet(BatchGetRequestContext, Set) to reuse RetriableAvroGenericStoreClient.streamingBatchGet(BatchGetRequestContext, Set, StreamingCallback) to add the retry functionality to batchGet API.
batchGet(BatchGetRequestContext<K, V>, Set<K>) - Method in class com.linkedin.venice.fastclient.StatsAvroGenericStoreClient
batchGet(VeniceClientRequest) - Method in class com.linkedin.venice.protocols.VeniceReadServiceGrpc.VeniceReadServiceBlockingStub
batchGet(VeniceClientRequest) - Method in class com.linkedin.venice.protocols.VeniceReadServiceGrpc.VeniceReadServiceFutureStub
batchGet(VeniceClientRequest, StreamObserver<VeniceServerResponse>) - Method in class com.linkedin.venice.listener.grpc.VeniceReadServiceImpl
batchGet(VeniceClientRequest, StreamObserver<VeniceServerResponse>) - Method in class com.linkedin.venice.protocols.VeniceReadServiceGrpc.VeniceReadServiceImplBase
batchGet(VeniceClientRequest, StreamObserver<VeniceServerResponse>) - Method in class com.linkedin.venice.protocols.VeniceReadServiceGrpc.VeniceReadServiceStub
batchGet(Set<K>) - Method in class com.linkedin.davinci.client.AvroGenericDaVinciClient
batchGet(Set<K>) - Method in class com.linkedin.davinci.client.DelegatingAvroGenericDaVinciClient
batchGet(Set<K>) - Method in class com.linkedin.davinci.client.StatsAvroGenericDaVinciClient
batchGet(Set<K>) - Method in interface com.linkedin.venice.client.store.AvroGenericStoreClient: Get the values associated with the given keys and return them in a map of keys to values.
batchGet(Set<K>) - Method in class com.linkedin.venice.client.store.DelegatingStoreClient
batchGet(Set<K>) - Method in class com.linkedin.venice.client.store.RetriableStoreClient: Adding retry logic on router error as this method returning the completion stage value.
batchGet(Set<K>) - Method in class com.linkedin.venice.client.store.StatTrackingStoreClient
batchGet(Set<K>) - Method in class com.linkedin.venice.fastclient.InternalAvroStoreClient: Use StatsAvroGenericStoreClient to get a client instance.
BatchGetChunkingAdapter - Class in com.linkedin.davinci.storage.chunking: Batch get chunking adapter
batchGetLimit - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore: The max key number allowed in batch get request, and Venice will use cluster-level config if the limit (not positive) is not valid
batchGetLimit - Variable in class com.linkedin.venice.meta.systemstore.schemas.StoreProperties
batchGetLimit - Variable in class com.linkedin.venice.systemstore.schemas.StoreProperties: Batch get key number limit, and Venice will use cluster-level config if it is not positive.
BatchGetRequestContext<K,V> - Class in com.linkedin.venice.fastclient: Keep track of the progress of a batch get request .
BatchGetRequestContext.KeyInfo<K> - Class in com.linkedin.venice.fastclient: represents a key requested on a route and tracks info related to it but specific to the route
batchGetRouterCacheEnabled - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore
batchGetRouterCacheEnabled - Variable in class com.linkedin.venice.meta.systemstore.schemas.StoreProperties
batchGetUsingSingleGet(Set<K>) - Method in class com.linkedin.venice.fastclient.DelegatingAvroStoreClient: Transient change to support ClientConfig.useStreamingBatchGetAsDefault
batchGetUsingSingleGet(Set<K>) - Method in class com.linkedin.venice.fastclient.StatsAvroGenericStoreClient: Leverage single-get implementation here: 1.
batchGetUsingStreamingBatchGet(BatchGetRequestContext<K, V>, Set<K>) - Method in class com.linkedin.venice.fastclient.StatsAvroGenericStoreClient
BatchJobHeartbeatConfigs - Class in com.linkedin.venice.status
BatchJobHeartbeatKey - Class in com.linkedin.venice.status.protocol: Key part of the heartbeat sent by a push job.
BatchJobHeartbeatKey() - Constructor for class com.linkedin.venice.status.protocol.BatchJobHeartbeatKey: Default constructor.
BatchJobHeartbeatKey(CharSequence, Integer) - Constructor for class com.linkedin.venice.status.protocol.BatchJobHeartbeatKey: All-args constructor.
BatchJobHeartbeatValue - Class in com.linkedin.venice.status.protocol: Value part of the heartbeat sent by a push job
BatchJobHeartbeatValue() - Constructor for class com.linkedin.venice.status.protocol.BatchJobHeartbeatValue: Default constructor.
BatchJobHeartbeatValue(Long) - Constructor for class com.linkedin.venice.status.protocol.BatchJobHeartbeatValue: All-args constructor.
batchOf(int) - Static method in enum com.linkedin.alpini.base.misc.CollectionUtil
batchUnsubscribe(Set<PubSubTopicPartition>) - Method in class com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerAdapter
batchUnsubscribe(Set<PubSubTopicPartition>) - Method in interface com.linkedin.venice.pubsub.api.PubSubConsumerAdapter
batchUnsubscribe(Set<PubSubTopicPartition>) - Method in class com.linkedin.venice.unit.kafka.consumer.MockInMemoryConsumer
BDB - com.linkedin.venice.meta.PersistenceType: Persistent storage engine that writes to durable media and maintains a B+ tree in the Java heap.
beforeChunkAggregator(ChannelPipeline) - Method in class com.linkedin.alpini.netty4.handlers.BasicServerChannelInitializer
beforeChunkAggregator(ChannelPipeline) - Method in class com.linkedin.alpini.router.impl.netty4.Router4PipelineFactory
beforeChunkAggregator(Class<CHANNEL_PIPELINE>, Consumer<CHANNEL_PIPELINE>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
beforeChunkAggregator(Class<CHANNEL_PIPELINE>, Consumer<CHANNEL_PIPELINE>) - Method in interface com.linkedin.alpini.router.impl.Router.Builder
beforeHttpRequestHandler(ChannelPipeline) - Method in class com.linkedin.alpini.netty4.handlers.BasicServerChannelInitializer
beforeHttpRequestHandler(ChannelPipeline) - Method in class com.linkedin.alpini.router.impl.netty4.Router4PipelineFactory
beforeHttpRequestHandler(Class<CHANNEL_PIPELINE>, Consumer<CHANNEL_PIPELINE>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
beforeHttpRequestHandler(Class<CHANNEL_PIPELINE>, Consumer<CHANNEL_PIPELINE>) - Method in interface com.linkedin.alpini.router.impl.Router.Builder
beforeHttpServerCodec(ChannelPipeline) - Method in class com.linkedin.alpini.netty4.handlers.BasicServerChannelInitializer
beforeHttpServerCodec(ChannelPipeline) - Method in class com.linkedin.alpini.router.impl.netty4.Router4PipelineFactory
beforeHttpServerCodec(Class<CHANNEL_PIPELINE>, Consumer<CHANNEL_PIPELINE>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
beforeHttpServerCodec(Class<CHANNEL_PIPELINE>, Consumer<CHANNEL_PIPELINE>) - Method in interface com.linkedin.alpini.router.impl.Router.Builder
beforeIdleStateHandler(ChannelPipeline) - Method in class com.linkedin.alpini.netty4.handlers.BasicServerChannelInitializer
beforeIdleStateHandler(ChannelPipeline) - Method in class com.linkedin.alpini.router.impl.netty4.Router4PipelineFactory
beforeIdleStateHandler(Class<CHANNEL_PIPELINE>, Consumer<CHANNEL_PIPELINE>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
beforeIdleStateHandler(Class<CHANNEL_PIPELINE>, Consumer<CHANNEL_PIPELINE>) - Method in interface com.linkedin.alpini.router.impl.Router.Builder
beginAggregation(HttpMessage, ByteBuf) - Method in class com.linkedin.alpini.netty4.handlers.BasicHttpObjectAggregator
beginAggregation(HttpMessage, ByteBuf) - Method in class com.linkedin.alpini.netty4.handlers.HttpMultiPartContentAggregator
beginAggregation(HttpMessage, ByteBuf) - Method in class io.netty.handler.codec.http.EspressoHttpObjectAggregator
beginAggregation(S, ByteBuf) - Method in class io.netty.handler.codec.EspressoMessageAggregator: Creates a new aggregated message from the specified start message and the specified content.
beginBatchWrite(StoragePartitionConfig, Map<String, String>, Optional<Supplier<byte[]>>) - Method in class com.linkedin.davinci.store.AbstractStorageEngine: A lot of storage engines support efficient methods for performing large number of writes (puts/deletes) against the data source.
beginBatchWrite(Map<String, String>, Optional<Supplier<byte[]>>) - Method in class com.linkedin.davinci.store.AbstractStoragePartition
beginBatchWrite(Map<String, String>, Optional<Supplier<byte[]>>) - Method in class com.linkedin.davinci.store.rocksdb.ReplicationMetadataRocksDBStoragePartition
beginBatchWrite(Map<String, String>, Optional<Supplier<byte[]>>) - Method in class com.linkedin.davinci.store.rocksdb.RocksDBStoragePartition
beginEncode(HttpMessage, String) - Method in class com.linkedin.alpini.netty4.compression.ContentCompressor: Prepare to encode the HTTP message content.
beginEncode(HttpMessage, String) - Method in class com.linkedin.alpini.netty4.handlers.BasicHttpContentEncoder: Prepare to encode the HTTP message content.
beginningOffset(PubSubTopicPartition, Duration) - Method in class com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerAdapter
beginningOffset(PubSubTopicPartition, Duration) - Method in interface com.linkedin.venice.pubsub.api.PubSubConsumerAdapter
beginningOffset(PubSubTopicPartition, Duration) - Method in class com.linkedin.venice.unit.kafka.consumer.MockInMemoryConsumer
between(int, String, int, int) - Static method in enum com.linkedin.alpini.base.misc.Preconditions
BiIntFunction<R> - Interface in com.linkedin.venice.utils
BiIntKeyCache<E> - Class in com.linkedin.venice.utils.collections: Read-through cache for items retrievable by two positive integer IDs.
BiIntKeyCache(BiIntFunction<E>) - Constructor for class com.linkedin.venice.utils.collections.BiIntKeyCache
BINARY - Static variable in class com.linkedin.venice.HttpConstants
BinaryResponse - Class in com.linkedin.venice.listener.response
BinaryResponse(ByteBuf) - Constructor for class com.linkedin.venice.listener.response.BinaryResponse
BinaryResponse(ByteBuffer) - Constructor for class com.linkedin.venice.listener.response.BinaryResponse
bind(ChannelHandlerContext, SocketAddress, ChannelPromise) - Method in class com.linkedin.alpini.netty4.handlers.Log4J2LoggingHandler
bindService() - Method in class com.linkedin.venice.protocols.VeniceReadServiceGrpc.VeniceReadServiceImplBase
BLACK_HOLE - com.linkedin.venice.client.store.deserialization.BatchDeserializerType: Test mode used primarily for targeted benchmarking of non-serde code paths
BLACK_HOLE - com.linkedin.venice.meta.PersistenceType: Fastest lock-free most secure of all storage engines.
BlackHoleDeserializer<E,K,V> - Class in com.linkedin.venice.client.store.deserialization: This BatchDeserializer does nothing, and always returns an empty list.
BlackHoleDeserializer(Executor, ClientConfig) - Constructor for class com.linkedin.venice.client.store.deserialization.BlackHoleDeserializer
BlackHoleStorageEngine - Class in com.linkedin.davinci.store.blackhole
BlackHoleStorageEngine(String) - Constructor for class com.linkedin.davinci.store.blackhole.BlackHoleStorageEngine
BlackHoleStorageEngineFactory - Class in com.linkedin.davinci.store.blackhole
BlackHoleStorageEngineFactory() - Constructor for class com.linkedin.davinci.store.blackhole.BlackHoleStorageEngineFactory
BlackHoleStorageEnginePartition - Class in com.linkedin.davinci.store.blackhole
BlackHoleStorageEnginePartition(Integer) - Constructor for class com.linkedin.davinci.store.blackhole.BlackHoleStorageEnginePartition
block() - Method in class com.linkedin.alpini.base.concurrency.BlockingLatch
BLOCK_STRATEGY - Static variable in class com.linkedin.venice.throttle.EventThrottler
BLOCKING - com.linkedin.venice.client.store.deserialization.BatchDeserializerType: Only supported working mode
BLOCKING - com.linkedin.venice.serializer.AvroGenericDeserializer.IterableImpl: Deprecated.

Only supported mode.
BlockingDeserializer<E,K,V> - Class in com.linkedin.venice.client.store.deserialization: This BatchDeserializer does not do anything asynchronously.
BlockingDeserializer(Executor, ClientConfig) - Constructor for class com.linkedin.venice.client.store.deserialization.BlockingDeserializer
BlockingLatch - Class in com.linkedin.alpini.base.concurrency: Created by acurtis on 10/16/17.
BlockingLatch() - Constructor for class com.linkedin.alpini.base.concurrency.BlockingLatch
BlockingObserverPollStrategy - Class in com.linkedin.venice.unit.kafka.consumer.poll: This PollStrategy delegates polling to another implementation, and also executes an arbitrary function during each poll.
BlockingObserverPollStrategy(AbstractPollStrategy, Consumer<PubSubTopicPartitionOffset>) - Constructor for class com.linkedin.venice.unit.kafka.consumer.poll.BlockingObserverPollStrategy
BlockingQueueType - Enum in com.linkedin.venice.utils.concurrent
BOOLEAN - com.linkedin.venice.schema.vson.VsonTypes: Deprecated.
BOOLEAN - Static variable in class com.linkedin.venice.utils.DataProviderUtils
BOOLEAN_FALSE - Static variable in class com.linkedin.venice.utils.DataProviderUtils
BOOLEAN_TRUE - Static variable in class com.linkedin.venice.utils.DataProviderUtils
booleanBooleanCompression() - Static method in class com.linkedin.venice.utils.DataProviderUtils
booleanCompression() - Static method in class com.linkedin.venice.utils.DataProviderUtils
bootstrap() - Method in class com.linkedin.alpini.netty4.pool.EspressoSimpleChannelPool: Returns the Bootstrap this pool will use to open new connections.
bootstrap() - Method in class com.linkedin.alpini.netty4.pool.FastSimpleChannelPool: Returns the Bootstrap this pool will use to open new connections.
bootstrap() - Method in class com.linkedin.alpini.router.impl.netty4.Router4Impl
BOOTSTRAP_TO_ONLINE_TIMEOUT_IN_HOUR - com.linkedin.venice.Arg
BOOTSTRAP_TO_ONLINE_TIMEOUT_IN_HOURS - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
BOOTSTRAP_TO_ONLINE_TIMEOUT_IN_HOURS - Static variable in interface com.linkedin.venice.meta.Store
bootstrapChannel(Promise<Channel>) - Method in class com.linkedin.alpini.netty4.pool.FastSimpleChannelPool
bootstrapTimeoutInMs - Variable in class com.linkedin.davinci.kafka.consumer.StoreIngestionTask
bootstrapToOnlineTimeoutInHours - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore: Maximum number of hours allowed for the store to transition from bootstrap to online state
bootstrapToOnlineTimeoutInHours - Variable in class com.linkedin.venice.meta.systemstore.schemas.StoreProperties
bootstrapToOnlineTimeoutInHours - Variable in class com.linkedin.venice.systemstore.schemas.StoreProperties: Maximum number of hours allowed for the store to transition from bootstrap to online state.
bossPoolBuilder(Class<POOL_TYPE>, Function<Executor, POOL_TYPE>) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
bossPoolBuilder(Class<POOL_TYPE>, Function<Executor, POOL_TYPE>) - Method in interface com.linkedin.alpini.router.impl.Router.Builder
bossPoolSize(int) - Method in class com.linkedin.alpini.router.impl.netty4.Router4
bossPoolSize(int) - Method in interface com.linkedin.alpini.router.impl.Router.Builder
BOTH - com.linkedin.venice.helix.HelixViewPropertyType
BoundedHashMap<K,V> - Class in com.linkedin.venice.utils: A map implementation with a bounded size.
BoundedHashMap(int, boolean) - Constructor for class com.linkedin.venice.utils.BoundedHashMap
BROADCAST_BY_PARTITION - Static variable in class com.linkedin.alpini.router.api.ScatterGatherMode: Sends request to every partition.
BROADCAST_BY_PRIMARY_HOST - Static variable in class com.linkedin.alpini.router.api.ScatterGatherMode: Sends request to the first host found for every partition, grouped by host.
broadcastEndOfIncrementalPush(String, Map<String, String>) - Method in class com.linkedin.venice.writer.VeniceWriter
broadcastEndOfPush(Map<String, String>) - Method in class com.linkedin.venice.writer.VeniceWriter: This function might need synchronized locking.
broadcastMode(ScatterGatherMode) - Method in class com.linkedin.alpini.router.api.ScatterGatherHelper.Builder
BroadcastScatterGatherRequest<H,K> - Class in com.linkedin.alpini.router.api: This type of specialized ScatterGatherRequest does not use keys for routing, and carry some extra state.
BroadcastScatterGatherRequest(List) - Constructor for class com.linkedin.alpini.router.api.BroadcastScatterGatherRequest
broadcastStartOfIncrementalPush(String, Map<String, String>) - Method in class com.linkedin.venice.writer.VeniceWriter
broadcastStartOfPush(boolean, boolean, CompressionStrategy, Map<String, String>) - Method in class com.linkedin.venice.writer.VeniceWriter
broadcastStartOfPush(boolean, boolean, CompressionStrategy, Optional<ByteBuffer>, Map<String, String>) - Method in class com.linkedin.venice.writer.VeniceWriter
broadcastStartOfPush(boolean, Map<String, String>) - Method in class com.linkedin.venice.writer.VeniceWriter
broadcastStartOfPush(Map<String, String>) - Method in class com.linkedin.venice.writer.VeniceWriter
broadcastTopicSwitch(List<CharSequence>, String, Long, Map<String, String>) - Method in class com.linkedin.venice.writer.VeniceWriter
broadcastVersionSwap(String, String, Map<String, String>) - Method in class com.linkedin.venice.writer.VeniceWriter: Broadcast control message to real-time topic partition, to be consumed by venice leader.
BUFFER_REPLAY_MINIMAL_SAFETY_MARGIN - Static variable in class com.linkedin.venice.kafka.TopicManager
BUFFER_REPLAY_POLICY - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
bufferAndAssembleRecordChangeEvent(PubSubTopicPartition, int, byte[], ByteBuffer, long, AbstractAvroChunkingAdapter<T>, Lazy<RecordDeserializer<T>>, AvroStoreDeserializerCache<T>, int) - Method in class com.linkedin.davinci.consumer.VeniceChangelogConsumerImpl
bufferReplayEnabledForHybrid - Variable in class com.linkedin.venice.meta.systemstore.schemas.StoreVersionState
bufferReplayEnabledForHybrid - Variable in class com.linkedin.venice.systemstore.schemas.StoreVersion: Whether or not to enable buffer replay for hybrid.
bufferReplayPolicy - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.HybridStoreConfigRecord: Policy that will be used during buffer replay.
bufferReplayPolicy - Variable in class com.linkedin.venice.systemstore.schemas.StoreHybridConfig: Policy that will be used during buffer replay.
BufferReplayPolicy - Enum in com.linkedin.venice.meta: Enums of the policies used to decide how buffer replay start timestamps are calculated.
build() - Method in class com.linkedin.alpini.base.misc.CollectionUtil.ListBuilder
build() - Method in class com.linkedin.alpini.base.misc.CollectionUtil.MapBuilder
build() - Method in class com.linkedin.alpini.base.misc.CollectionUtil.SetBuilder
build() - Method in class com.linkedin.alpini.base.queuing.QOSPolicy.Config
build() - Method in interface com.linkedin.alpini.consts.config.ConfigBuilder
build() - Method in class com.linkedin.alpini.netty4.http2.Http2PipelineInitializer.Builder
build() - Method in class com.linkedin.alpini.router.api.ScatterGatherHelper.Builder
build() - Method in class com.linkedin.alpini.router.impl.netty4.Router4
build() - Method in interface com.linkedin.alpini.router.impl.Router.Builder
build() - Method in class com.linkedin.davinci.kafka.consumer.StoreIngestionTaskFactory.Builder
build() - Method in class com.linkedin.venice.controller.VeniceControllerContext.Builder
build() - Method in class com.linkedin.venice.datarecovery.EstimateDataRecoveryTimeCommand.Params.Builder
build() - Method in class com.linkedin.venice.datarecovery.MonitorCommand.Params.Builder
build() - Method in class com.linkedin.venice.datarecovery.StoreRepushCommand.Params.Builder
build() - Method in class com.linkedin.venice.fastclient.ClientConfig.ClientConfigBuilder
build() - Method in class com.linkedin.venice.fastclient.GrpcClientConfig.Builder
build() - Method in class com.linkedin.venice.grpc.VeniceGrpcServerConfig.Builder
build() - Method in class com.linkedin.venice.hadoop.input.kafka.KafkaInputDictTrainer.ParamBuilder
build() - Method in class com.linkedin.venice.httpclient5.HttpClient5Utils.HttpClient5Builder
build() - Method in class com.linkedin.venice.httpclient5.VeniceClientTlsStrategyBuilder
build() - Method in class com.linkedin.venice.kafka.TopicManagerRepository.Builder
build() - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder
build() - Method in class com.linkedin.venice.protocols.VeniceServerResponse.Builder
build() - Method in class com.linkedin.venice.server.VeniceServerContext.Builder
build() - Method in class com.linkedin.venice.utils.InMemoryLogAppender.Builder
build() - Method in class com.linkedin.venice.utils.PropertyBuilder
build() - Method in class com.linkedin.venice.utils.PushInputSchemaBuilder
build() - Method in class com.linkedin.venice.utils.SslUtils.VeniceTlsConfiguration.Builder
build() - Method in interface com.linkedin.venice.writer.update.UpdateBuilder: Build a GenericRecord that is ready to be sent as an Update request.
build() - Method in class com.linkedin.venice.writer.update.UpdateBuilderImpl
build() - Method in class com.linkedin.venice.writer.VeniceWriterOptions.Builder
build(Channel, CallOptions) - Method in class com.linkedin.venice.protocols.VeniceReadServiceGrpc.VeniceReadServiceBlockingStub
build(Channel, CallOptions) - Method in class com.linkedin.venice.protocols.VeniceReadServiceGrpc.VeniceReadServiceFutureStub
build(Channel, CallOptions) - Method in class com.linkedin.venice.protocols.VeniceReadServiceGrpc.VeniceReadServiceStub
build(Http2ConnectionDecoder, Http2ConnectionEncoder, Http2Settings) - Method in class io.netty.handler.codec.http2.EspressoHttp2FrameCodecBuilder
build(SslContextBuilder) - Static method in class com.linkedin.alpini.netty4.http2.SSLContextBuilder
build(File, String, String, File, String) - Method in class com.linkedin.alpini.io.ssl.SSLContextBuilder: The keyStoreFile takes a File object of p12 or jks file depends on keyStoreType The trustStoreFile always takes a File object of JKS file.
build(String, String) - Method in class com.linkedin.alpini.io.ssl.SSLContextBuilder: Deprecated.
Builds from key store file instead of raw key store data.
buildAndSaveConfigsForForkedIngestionProcess(VeniceConfigLoader) - Static method in class com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils
buildAndStart() - Method in class com.linkedin.venice.httpclient5.HttpClient5Utils.HttpClient5Builder
buildClient(String, int, int, boolean, SSLFactory) - Static method in class com.linkedin.venice.client.store.transport.HttpTransportClient: Note: The callback that is triggered by CloseableHttpAsyncClient runs in the same thread as one of it's worker threads and if the users of the future run tasks that block the release of the future thread, a deadlock will occur.
buildConfig(Properties) - Static method in class com.linkedin.venice.security.SSLConfig: Build a Config class from Properties that contains all SSL settings
buildContentType(String, String, Collection<Map.Entry<String, String>>) - Static method in enum com.linkedin.alpini.base.misc.HeaderUtils
buildContentType(String, String, Iterator<Map.Entry<String, String>>) - Static method in enum com.linkedin.alpini.base.misc.HeaderUtils
buildControllerClient(String, String, Optional<SSLFactory>) - Method in class com.linkedin.venice.datarecovery.Command
buildDictionaryOnSyntheticAvroData() - Static method in class com.linkedin.venice.compression.ZstdWithDictCompressor: Build a dictionary based on synthetic data.
builder() - Method in class com.linkedin.alpini.io.SubprocessBuilder
builder() - Static method in class com.linkedin.alpini.router.api.ScatterGatherHelper
builder() - Method in class com.linkedin.alpini.router.impl.netty4.Router4
builder() - Method in interface com.linkedin.alpini.router.impl.Router.PipelineFactory
builder() - Static method in class com.linkedin.davinci.kafka.consumer.StoreIngestionTaskFactory
builder() - Static method in class com.linkedin.venice.kafka.TopicManagerRepository
builder() - Static method in class com.linkedin.venice.utils.SslUtils.VeniceTlsConfiguration
builder(ScatterGatherHelper<H, P, K, R, ?, ?, ?>) - Static method in interface com.linkedin.alpini.router.impl.Router
Builder() - Constructor for class com.linkedin.alpini.netty4.http2.Http2PipelineInitializer.Builder
Builder() - Constructor for class com.linkedin.davinci.kafka.consumer.StoreIngestionTaskFactory.Builder
Builder() - Constructor for class com.linkedin.venice.controller.VeniceControllerContext.Builder
Builder() - Constructor for class com.linkedin.venice.datarecovery.EstimateDataRecoveryTimeCommand.Params.Builder
Builder() - Constructor for class com.linkedin.venice.datarecovery.MonitorCommand.Params.Builder
Builder() - Constructor for class com.linkedin.venice.datarecovery.StoreRepushCommand.Params.Builder
Builder() - Constructor for class com.linkedin.venice.fastclient.GrpcClientConfig.Builder
Builder() - Constructor for class com.linkedin.venice.grpc.VeniceGrpcServerConfig.Builder
Builder() - Constructor for class com.linkedin.venice.kafka.TopicManagerRepository.Builder
Builder() - Constructor for class com.linkedin.venice.server.VeniceServerContext.Builder
Builder() - Constructor for class com.linkedin.venice.utils.InMemoryLogAppender.Builder
Builder() - Constructor for class com.linkedin.venice.utils.SslUtils.VeniceTlsConfiguration.Builder
Builder(EstimateDataRecoveryTimeCommand.Params) - Constructor for class com.linkedin.venice.datarecovery.EstimateDataRecoveryTimeCommand.Params.Builder
Builder(MonitorCommand.Params) - Constructor for class com.linkedin.venice.datarecovery.MonitorCommand.Params.Builder
Builder(StoreRepushCommand.Params) - Constructor for class com.linkedin.venice.datarecovery.StoreRepushCommand.Params.Builder
Builder(String) - Constructor for class com.linkedin.venice.writer.VeniceWriterOptions.Builder
Builder(String, ControllerClient, String, Optional<SSLFactory>) - Constructor for class com.linkedin.venice.datarecovery.EstimateDataRecoveryTimeCommand.Params.Builder
Builder(String, ControllerClient, String, Optional<SSLFactory>, LocalDateTime) - Constructor for class com.linkedin.venice.datarecovery.MonitorCommand.Params.Builder
Builder(String, String, String, String, LocalDateTime, ControllerClient, String, Optional<SSLFactory>, boolean) - Constructor for class com.linkedin.venice.datarecovery.StoreRepushCommand.Params.Builder
builderOf(Class<? extends Http2PipelineInitializer>) - Static method in class com.linkedin.alpini.netty4.http2.Http2PipelineInitializer
buildErrorResponse(BHS, HRS, String, Throwable, Map<String, String>) - Method in class com.linkedin.alpini.router.ScatterGatherRequestHandlerImpl
buildErrorResponse(BasicFullHttpRequest, HttpResponseStatus, String, Throwable, Map<String, String>) - Method in class com.linkedin.alpini.router.ScatterGatherRequestHandler4
buildErrorResponse(HttpRequest, Throwable) - Method in class com.linkedin.alpini.netty4.handlers.AsyncFullHttpRequestHandler
buildErrorResponse(HttpRequest, Throwable, HttpResponseStatus) - Method in class com.linkedin.alpini.netty4.handlers.AsyncFullHttpRequestHandler
buildExceptionResponse(BHS, Throwable) - Method in class com.linkedin.alpini.router.ScatterGatherRequestHandlerImpl
buildHttpResponse(HttpResponseStatus, byte[]) - Static method in class com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils
buildHttpResponse(HttpResponseStatus, ByteBuf) - Static method in class com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils
buildHttpResponse(HttpResponseStatus, String) - Static method in class com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils
buildPartial() - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder
buildPartial() - Method in class com.linkedin.venice.protocols.VeniceServerResponse.Builder
buildPlainTextResponse(HttpResponseStatus, ByteBuf) - Method in class com.linkedin.venice.router.api.VeniceDispatcher
buildQueue(QOSPolicy.StaticConfig) - Method in enum com.linkedin.alpini.base.queuing.QOSPolicy
buildResponse(BASIC_HTTP_REQUEST, Metrics, List<HTTP_RESPONSE>) - Method in interface com.linkedin.alpini.router.api.ResponseAggregatorFactory
buildResponse(BHS, Metrics, List<HR>) - Method in class com.linkedin.alpini.router.ScatterGatherRequestHandlerImpl
buildResponse(BasicFullHttpRequest, Metrics, List<FullHttpResponse>) - Method in class com.linkedin.alpini.router.ScatterGatherRequestHandler4
buildResponse(BasicFullHttpRequest, Metrics, List<FullHttpResponse>) - Method in class com.linkedin.venice.router.api.VeniceResponseAggregator
buildResponse(VenicePath, PortableHttpResponse) - Method in class com.linkedin.venice.router.api.VeniceDispatcher
buildSensorStatSummary(String, String...) - Method in class com.linkedin.venice.fastclient.stats.FastClientStats: This method is a utility method to build concise summaries useful in tests and for logging.
buildStoreViewWriters(Store, int, Schema) - Method in class com.linkedin.davinci.store.view.VeniceViewWriterFactory
buildTasks(Set<String>, Command.Params) - Method in class com.linkedin.venice.datarecovery.DataRecoveryEstimator
buildTasks(Set<String>, Command.Params) - Method in class com.linkedin.venice.datarecovery.DataRecoveryExecutor
buildTasks(Set<String>, Command.Params) - Method in class com.linkedin.venice.datarecovery.DataRecoveryMonitor
BUILT_IN - com.linkedin.venice.meta.IngestionMode: Isolation ingestion is not enabled.
busyCallTracker() - Method in interface com.linkedin.alpini.netty4.pool.ChannelPoolManager.Stats: Call tracker which tracks busy (checked out) channels
BYTE_WRAPPER - Static variable in class com.linkedin.venice.schema.vson.VsonAvroSchemaAdapter: Deprecated.
ByteArray - Class in com.linkedin.venice.utils
ByteArray(byte...) - Constructor for class com.linkedin.venice.utils.ByteArray
ByteArrayKey - Class in com.linkedin.davinci.utils: A low overhead immutable container of byte[] suitable for use as a map key.
ByteArrayKey(byte[]) - Constructor for class com.linkedin.davinci.utils.ByteArrayKey
byteAt(int) - Method in class com.linkedin.alpini.base.misc.ByteBufAsciiString
ByteBufAsciiString - Class in com.linkedin.alpini.base.misc: A string implementation, similar to AsciiString, which is backed by a ByteBuf instead of a byte[] array.
ByteBufAsciiString(byte[], int, int, boolean) - Constructor for class com.linkedin.alpini.base.misc.ByteBufAsciiString
ByteBufAsciiString(ByteBufAllocator, byte[]) - Constructor for class com.linkedin.alpini.base.misc.ByteBufAsciiString
ByteBufAsciiString(ByteBufAllocator, char[]) - Constructor for class com.linkedin.alpini.base.misc.ByteBufAsciiString: Create a copy of value into this instance assuming ASCII encoding.
ByteBufAsciiString(ByteBufAllocator, char[], int, int) - Constructor for class com.linkedin.alpini.base.misc.ByteBufAsciiString: Create a copy of value into this instance assuming ASCII encoding.
ByteBufAsciiString(ByteBufAllocator, char[], Charset) - Constructor for class com.linkedin.alpini.base.misc.ByteBufAsciiString: Create a copy of value into this instance using the encoding type of charset.
ByteBufAsciiString(ByteBufAllocator, char[], Charset, int, int) - Constructor for class com.linkedin.alpini.base.misc.ByteBufAsciiString: Create a copy of value into a this instance using the encoding type of charset.
ByteBufAsciiString(ByteBufAllocator, CharSequence) - Constructor for class com.linkedin.alpini.base.misc.ByteBufAsciiString
ByteBufAsciiString(ByteBufAllocator, CharSequence, int, int) - Constructor for class com.linkedin.alpini.base.misc.ByteBufAsciiString: Create a copy of value into this instance assuming ASCII encoding.
ByteBufAsciiString(ByteBufAllocator, CharSequence, Charset) - Constructor for class com.linkedin.alpini.base.misc.ByteBufAsciiString: Create a copy of value into this instance using the encoding type of charset.
ByteBufAsciiString(ByteBufAllocator, CharSequence, Charset, int, int) - Constructor for class com.linkedin.alpini.base.misc.ByteBufAsciiString: Create a copy of value into this instance using the encoding type of charset.
ByteBufferOptimizedBinaryDecoder - Class in org.apache.avro.io: This class is a wrapper of BinaryDecoder with the following optimization: When deserializing byte array field, instead of copying the bytes into a new ByteBuffer, this class will create a ByteBuffer, which is wrapping the original array.
ByteBufferOptimizedBinaryDecoder(byte[]) - Constructor for class org.apache.avro.io.ByteBufferOptimizedBinaryDecoder
ByteBufferOptimizedBinaryDecoder(byte[], int, int) - Constructor for class org.apache.avro.io.ByteBufferOptimizedBinaryDecoder
ByteBufferToHexFormatJsonEncoder - Class in org.apache.avro.io: This class overrides JsonEncoder.writeBytes(byte[], int, int), in order to convert all bytes schema data to hexadecimal strings in the output stream, since hexadecimal strings are more readable.
ByteBufferToHexFormatJsonEncoder(Schema, OutputStream) - Constructor for class org.apache.avro.io.ByteBufferToHexFormatJsonEncoder
ByteBufHashMap<K,V> - Class in com.linkedin.alpini.base.cache
ByteBufHashMap(ByteBufHashMap.SerDes<V>) - Constructor for class com.linkedin.alpini.base.cache.ByteBufHashMap: Equivalent to calling ByteBufHashMap(SerDes, int) with ByteBufHashMap.DEFAULT_ALLOCATOR
ByteBufHashMap(ByteBufHashMap.SerDes<V>, int) - Constructor for class com.linkedin.alpini.base.cache.ByteBufHashMap: Equivalent to calling ByteBufHashMap(SerDes, int, IntFunction) with {#link #DEFAULT_ALLOCATOR}
ByteBufHashMap(ByteBufHashMap.SerDes<V>, int, IntFunction<ByteBuf>) - Constructor for class com.linkedin.alpini.base.cache.ByteBufHashMap: Construct an instance of a ByteBuf backed hash map.
ByteBufHashMap(ByteBufHashMap.SerDes<V>, int, IntFunction<ByteBuf>, int, float) - Constructor for class com.linkedin.alpini.base.cache.ByteBufHashMap: Construct an instance of a ByteBuf backed hash map.
ByteBufHashMap(ByteBufHashMap.SerDes<V>, IntFunction<ByteBuf>) - Constructor for class com.linkedin.alpini.base.cache.ByteBufHashMap: Equivalent to calling ByteBufHashMap(SerDes, int, IntFunction) with ByteBufHashMap.DEFAULT_BLOCK_SIZE
ByteBufHashMap.SerDes<V> - Interface in com.linkedin.alpini.base.cache: Serialization/Deserialization interface.
ByteCount(T, K, MemoryPressureIndexMonitor<T, K, S>) - Constructor for class com.linkedin.alpini.base.misc.MemoryPressureIndexMonitor.ByteCount
BYTES - com.linkedin.venice.schema.vson.VsonTypes: Deprecated.
BYTES_CONSUMED_METRIC_NAME - Static variable in class com.linkedin.davinci.stats.IngestionStats
BYTES_PER_GB - Static variable in class com.linkedin.venice.utils.ByteUtils
BYTES_PER_KB - Static variable in class com.linkedin.venice.utils.ByteUtils
BYTES_PER_MB - Static variable in class com.linkedin.venice.utils.ByteUtils
BytesStreamingCallback - Class in com.linkedin.davinci.callback
BytesStreamingCallback() - Constructor for class com.linkedin.davinci.callback.BytesStreamingCallback
bytesToAvro(byte[]) - Method in class com.linkedin.venice.schema.vson.VsonAvroSerializer: Deprecated.
bytesToAvro(byte[], int, int) - Method in class com.linkedin.venice.schema.vson.VsonAvroSerializer: Deprecated.
ByteUtils - Class in com.linkedin.venice.utils: Utility functions for munging on bytes N.B.: Most functions taken from Voldemort's ByteUtils class.
ByteUtils() - Constructor for class com.linkedin.venice.utils.ByteUtils

C

c - Variable in class com.linkedin.venice.serializer.SerializerDeserializerFactory.SchemaPairAndClassContainer
c2b(char) - Static method in class com.linkedin.alpini.base.misc.ByteBufAsciiString
c2b0(char) - Static method in class com.linkedin.alpini.base.misc.ByteBufAsciiString
CACHE - com.linkedin.venice.meta.PersistenceType: Similar to IN_MEMORY but with different retention rules of data (that is, data is evicted under certain circumstances)
CACHED_SQUARED_L2_NORM_KEY - Static variable in class com.linkedin.venice.compute.ComputeUtils
CachedCallable<T> - Class in com.linkedin.venice.utils: CachedCallable is useful when referring to expensive resources.
CachedCallable(Callable<T>, long) - Constructor for class com.linkedin.venice.utils.CachedCallable
CachedCallable(Callable<T>, long, Time) - Constructor for class com.linkedin.venice.utils.CachedCallable
CachedDnsResolver - Class in com.linkedin.venice.httpclient: CachedDnsResolver caches the dns entries for hosts, which matches the specified host pattern.
CachedDnsResolver(String, long, DnsLookupStats) - Constructor for class com.linkedin.venice.httpclient.CachedDnsResolver
cachedPubSubMetadataGetter - Variable in class com.linkedin.davinci.kafka.consumer.StoreIngestionTask
CachedReadOnlyStoreRepository - Class in com.linkedin.venice.helix
CachedReadOnlyStoreRepository(ZkClient, String, HelixAdapterSerializer, ClusterLockManager) - Constructor for class com.linkedin.venice.helix.CachedReadOnlyStoreRepository
CachedResourceZkStateListener - Class in com.linkedin.venice.helix: Listener used to monitor zk connection state change and refresh venice resource once zk connection is reconnected.
CachedResourceZkStateListener(VeniceResource) - Constructor for class com.linkedin.venice.helix.CachedResourceZkStateListener
CachedResourceZkStateListener(VeniceResource, int, long) - Constructor for class com.linkedin.venice.helix.CachedResourceZkStateListener
cacheFastAvroGenericDeserializer(Schema, Schema, long) - Static method in class com.linkedin.venice.serializer.FastSerializerDeserializerFactory
CachingDaVinciClientFactory - Class in com.linkedin.davinci.client.factory
CachingDaVinciClientFactory(D2Client, MetricsRepository, VeniceProperties) - Constructor for class com.linkedin.davinci.client.factory.CachingDaVinciClientFactory: Deprecated.
CachingDaVinciClientFactory(D2Client, MetricsRepository, VeniceProperties, Optional<Set<String>>) - Constructor for class com.linkedin.davinci.client.factory.CachingDaVinciClientFactory: Deprecated.
CachingDaVinciClientFactory(D2Client, MetricsRepository, VeniceProperties, Optional<Set<String>>, ICProvider) - Constructor for class com.linkedin.davinci.client.factory.CachingDaVinciClientFactory: Deprecated.
CachingDaVinciClientFactory(D2Client, String, MetricsRepository, VeniceProperties) - Constructor for class com.linkedin.davinci.client.factory.CachingDaVinciClientFactory
CachingDaVinciClientFactory(D2Client, String, MetricsRepository, VeniceProperties, Optional<Set<String>>) - Constructor for class com.linkedin.davinci.client.factory.CachingDaVinciClientFactory
CachingDaVinciClientFactory(D2Client, String, MetricsRepository, VeniceProperties, Optional<Set<String>>, ICProvider) - Constructor for class com.linkedin.davinci.client.factory.CachingDaVinciClientFactory
CachingDaVinciClientFactory.DaVinciClientConstructor - Interface in com.linkedin.davinci.client.factory
CachingVeniceStoreClientFactory - Class in com.linkedin.venice.client.factory
CachingVeniceStoreClientFactory(ClientConfig) - Constructor for class com.linkedin.venice.client.factory.CachingVeniceStoreClientFactory
CachingVeniceStoreClientFactory(ClientConfig, VeniceStoreClientGlobalConfig) - Constructor for class com.linkedin.venice.client.factory.CachingVeniceStoreClientFactory
CaffeineVeniceStoreCache - Class in com.linkedin.davinci.store.cache.caffeine
CaffeineVeniceStoreCache(ObjectCacheConfig, AsyncCacheLoader) - Constructor for class com.linkedin.davinci.store.cache.caffeine.CaffeineVeniceStoreCache
calculateDurationMs(Time, long) - Static method in class com.linkedin.venice.utils.Utils
calculateHashCode(F, S) - Static method in class com.linkedin.venice.utils.Pair: Deprecated.
calculateIdealTotalQuotaPerRouter() - Method in class com.linkedin.venice.router.throttle.ReadRequestThrottler
calculateNumberOfPartitions(String, String) - Method in interface com.linkedin.venice.controller.Admin: Calculate how many partitions are needed for the given store.
calculateNumberOfPartitions(String, String) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin: Calculate number of partition for given store.
calculateNumberOfPartitions(String, String) - Method in class com.linkedin.venice.controller.VeniceParentHelixAdmin
calculatePartitionCount(String, long, int, long, int, int, boolean, int) - Static method in class com.linkedin.venice.utils.PartitionUtils: Calculate partition count for new version.
calculateStoreQuotaPerRouter(long) - Method in class com.linkedin.venice.router.throttle.ReadRequestThrottler
call() - Method in class com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask
call() - Method in class com.linkedin.venice.utils.CachedCallable
call(String, Callable<T>) - Method in interface com.linkedin.venice.service.ICProvider
callable(Runnable) - Static method in enum com.linkedin.alpini.base.concurrency.Executors: Returns a Callable object that, when called, runs the given task and returns null.
callable(Runnable, T) - Static method in enum com.linkedin.alpini.base.concurrency.Executors: Returns a Callable object that, when called, runs the given task and returns the given result.
callable(PrivilegedAction<?>) - Static method in enum com.linkedin.alpini.base.concurrency.Executors: Returns a Callable object that, when called, runs the given privileged action and returns its result.
callable(PrivilegedExceptionAction<?>) - Static method in enum com.linkedin.alpini.base.concurrency.Executors: Returns a Callable object that, when called, runs the given privileged exception action and returns its result.
callback - Variable in class com.linkedin.venice.hadoop.VeniceReducer: Visible for testing purpose IMPORTANT: Noticed that this callback is reused in different messages, do not put information that is coupled with each message inside this callback.
Callback(TrackingStreamingCallback<K, V>) - Constructor for class com.linkedin.venice.client.store.streaming.ClientComputeRecordStreamDecoder.Callback
callClose(long, long) - Method in interface com.linkedin.alpini.netty4.pool.Http2PingCallListener
callClose(long, long) - Method in class com.linkedin.alpini.netty4.pool.Http2PingHelper
callCloseWithError(long, long) - Method in interface com.linkedin.alpini.netty4.pool.Http2PingCallListener
callCloseWithError(long, long) - Method in class com.linkedin.alpini.netty4.pool.Http2PingHelper
CallCompletion - Interface in com.linkedin.alpini.base.monitoring
callConstructor(Class<T>, Class<?>[], Object[]) - Static method in class com.linkedin.venice.utils.ReflectUtils: Call the class constructor with the given arguments
callStart(long, long) - Method in interface com.linkedin.alpini.netty4.pool.Http2PingCallListener
callStart(long, long) - Method in class com.linkedin.alpini.netty4.pool.Http2PingHelper
CallTracker - Interface in com.linkedin.alpini.base.monitoring
CallTracker.CallStats - Interface in com.linkedin.alpini.base.monitoring
CallTrackerImpl - Class in com.linkedin.alpini.base.monitoring: Tracker for "load average" of a call.
CallTrackerImpl() - Constructor for class com.linkedin.alpini.base.monitoring.CallTrackerImpl
CallTrackerImpl(int) - Constructor for class com.linkedin.alpini.base.monitoring.CallTrackerImpl
CallTrackerImpl(int, ConcurrentAccumulator.Mode) - Constructor for class com.linkedin.alpini.base.monitoring.CallTrackerImpl
CallTrackerImpl.Mode - Enum in com.linkedin.alpini.base.monitoring
CAN_ALWAYS_CREATE_STREAMS - Static variable in class io.netty.handler.codec.http2.EspressoHttp2FrameCodecBuilder
canAccess(Method, Resource, Principal) - Method in interface com.linkedin.venice.authorization.AuthorizerService: Check if the principal has the permission to perform the method on the resource.
canAccess(Method, Resource, Principal) - Method in class com.linkedin.venice.controller.MockVeniceAuthorizer
canAccess(Method, Resource, X509Certificate) - Method in interface com.linkedin.venice.authorization.AuthorizerService: Check if the principal has the permission to perform the method on the resource.
canAccess(Method, Resource, X509Certificate) - Method in class com.linkedin.venice.controller.MockVeniceAuthorizer
cancel() - Method in class com.linkedin.alpini.base.concurrency.TimeoutProcessor.TimeoutFuture: Cancels a pending scheduled runnable
cancel() - Method in interface com.linkedin.alpini.router.api.RouterTimeoutProcessor.TimeoutFuture
cancel() - Method in class com.linkedin.venice.hadoop.VenicePushJob: A cancel method for graceful cancellation of the running Job to be invoked as a result of user actions.
cancel(boolean) - Method in class com.linkedin.alpini.base.concurrency.CompletableFutureTask
cancel(boolean) - Method in class com.linkedin.alpini.base.concurrency.impl.DefaultAsyncFuture
cancel(boolean) - Method in class com.linkedin.alpini.base.concurrency.impl.DefaultAsyncFutureTask
cancel(boolean) - Method in class com.linkedin.alpini.base.concurrency.impl.FailedAsyncFuture: Attempts to cancel execution of this task.
cancel(boolean) - Method in class com.linkedin.alpini.base.concurrency.impl.SuccessAsyncFuture: Attempts to cancel execution of this task.
cancel(boolean) - Method in class com.linkedin.alpini.base.misc.PromiseDelegate
CANCELLATION_EXCEPTION - com.linkedin.alpini.base.concurrency.AsyncFuture.Status
cancelled() - Static method in interface com.linkedin.alpini.base.concurrency.AsyncFuture: Obtain an instance of an AsyncFuture which is in the Cancelled state.
CancelledAsyncFuture<T> - Class in com.linkedin.alpini.base.concurrency.impl
CancelledAsyncFuture() - Constructor for class com.linkedin.alpini.base.concurrency.impl.CancelledAsyncFuture
canCreateStream(Channel) - Method in class com.linkedin.alpini.netty4.http2.Http2PipelineInitializer
canCreateStreams(Predicate<Channel>) - Method in class io.netty.handler.codec.http2.EspressoHttp2FrameCodecBuilder
canDelete(VersionStatus) - Static method in enum com.linkedin.venice.meta.VersionStatus: check if a status can be deleted immediately.
canEqual(Object) - Method in class com.linkedin.venice.pulsar.sink.VenicePulsarSinkConfig
canOpenLocalStream(Channel) - Static method in class com.linkedin.alpini.netty4.misc.Http2Utils: Checks if the local HTTP/2 endpoint can open a new stream.
canPassThroughResponse(CompressionStrategy) - Method in class com.linkedin.venice.router.api.VeniceResponseDecompressor
canRequestStorageNode(String) - Method in class com.linkedin.venice.router.api.path.VenicePath: This function is used to check whether Router could send retry request to the specified storage node.
canUseBackedArray(ByteBuffer) - Static method in class com.linkedin.venice.utils.ByteUtils
CAPPED_PREFIX_EXTRACTOR_LENGTH - Static variable in class com.linkedin.davinci.store.rocksdb.RocksDBServerConfig: Length of the capped prefix extractor used with RocksDB Plain Table.
castKey(Object) - Method in class com.linkedin.alpini.base.cache.ByteBufHashMap
castKey(Object) - Method in class com.linkedin.alpini.base.cache.PhantomHashMap
CATCH_UP_BASE_TOPIC_OFFSET_LAG - com.linkedin.venice.pushmonitor.ExecutionStatus
CATCH_UP_BASE_TOPIC_OFFSET_LAG - com.linkedin.venice.pushmonitor.SubPartitionStatus
catching(Throwable) - Method in class com.linkedin.alpini.log.FastLogger
catching(Level, Throwable) - Method in class com.linkedin.alpini.log.FastLogger
catchUpVersionTopicOffsetLag(String, int) - Method in class com.linkedin.davinci.notifier.LogNotifier
catchUpVersionTopicOffsetLag(String, int) - Method in interface com.linkedin.davinci.notifier.VeniceNotifier
cause() - Method in class com.linkedin.alpini.base.misc.PromiseDelegate
cause(Throwable, Class<E>) - Static method in enum com.linkedin.alpini.base.misc.ExceptionUtil: Return the specific cause of the given Throwable if the cause is one of the classes provided; otherwise return null.
CHANGE_CAPTURE_TOPIC_SUFFIX - Static variable in class com.linkedin.venice.views.ChangeCaptureView
CHANGE_CAPTURE_VIEW_WRITER_CLASS_NAME - Static variable in class com.linkedin.venice.views.ChangeCaptureView
ChangeCaptureView - Class in com.linkedin.venice.views
ChangeCaptureView(Properties, Store, Map<String, String>) - Constructor for class com.linkedin.venice.views.ChangeCaptureView
ChangeCaptureViewWriter - Class in com.linkedin.davinci.store.view
ChangeCaptureViewWriter(VeniceConfigLoader, Store, Schema, Map<String, String>) - Constructor for class com.linkedin.davinci.store.view.ChangeCaptureViewWriter
ChangeEvent<T> - Class in com.linkedin.davinci.consumer
ChangeEvent(T, T) - Constructor for class com.linkedin.davinci.consumer.ChangeEvent
changeLiveRouterCount(int) - Method in class com.linkedin.venice.helix.ZkRoutersClusterManager
changelogClientConfig - Variable in class com.linkedin.davinci.consumer.VeniceChangelogConsumerImpl
ChangelogClientConfig<T extends org.apache.avro.specific.SpecificRecord> - Class in com.linkedin.davinci.consumer
ChangelogClientConfig() - Constructor for class com.linkedin.davinci.consumer.ChangelogClientConfig
ChangelogClientConfig(String) - Constructor for class com.linkedin.davinci.consumer.ChangelogClientConfig
channel() - Method in class io.netty.bootstrap.PendingConnectFuturePromise
channel() - Method in class io.netty.bootstrap.PendingConnectPromise
CHANNEL_HANDLER_CONTEXT_ATTRIBUTE_KEY - Static variable in class com.linkedin.venice.router.streaming.VeniceChunkedWriteHandler
channelActive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.ClientConnectionTracker
channelActive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.ConnectionControlHandler
channelActive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.ConnectionLimitHandler: Calls ChannelHandlerContext.fireChannelActive() to forward to the next ChannelInboundHandler in the ChannelPipeline.
channelActive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.Log4J2LoggingHandler
channelActive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.ReverseHandler
channelAvailableForReuse(Http2StreamChannel) - Static method in class com.linkedin.alpini.netty4.misc.Http2Utils: Checks if a stream channel is currently available for reuse.
channelInactive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.BasicHttpContentEncoder
channelInactive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.ClientConnectionTracker
channelInactive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.ConnectionControlHandler
channelInactive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.ConnectionLimitHandler: Calls ChannelHandlerContext.fireChannelInactive() to forward to the next ChannelInboundHandler in the ChannelPipeline.
channelInactive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.HttpClientResponseHandler
channelInactive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.HttpServerConcurrencyObserver
channelInactive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.InboundContentDebugHandler
channelInactive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.Log4J2LoggingHandler
channelInactive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.ReverseHandler
channelInactive(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.http2.Http2ClientResponseHandler
channelInactive(ChannelHandlerContext) - Method in class com.linkedin.venice.router.streaming.NettyChunkedWriteHandler
channelInactive(ChannelHandlerContext) - Method in class io.netty.handler.codec.EspressoMessageAggregator
channelInactive(ChannelHandlerContext) - Method in class io.netty.handler.codec.http2.EspressoHttp2MultiplexHandler
ChannelInitializer<C extends io.netty.channel.Channel> - Class in com.linkedin.alpini.netty4.handlers: A special ChannelInboundHandler which offers an easy way to initialize a Channel once it was registered to its EventLoop.
ChannelInitializer() - Constructor for class com.linkedin.alpini.netty4.handlers.ChannelInitializer
ChannelPoolFactory - Interface in com.linkedin.alpini.netty4.pool: An interface to construct ManagedChannelPool instances for the ChannelPoolManager.
ChannelPoolManager - Interface in com.linkedin.alpini.netty4.pool: The interface which describes the public methods of a channel pool manager.
ChannelPoolManager.PoolStats - Interface in com.linkedin.alpini.netty4.pool
ChannelPoolManager.QueueStats - Interface in com.linkedin.alpini.netty4.pool
ChannelPoolManager.Stats - Interface in com.linkedin.alpini.netty4.pool
ChannelPoolManager.ThreadPoolStats - Interface in com.linkedin.alpini.netty4.pool: Represents IoWorker stats
ChannelPoolManagerImpl - Class in com.linkedin.alpini.netty4.pool: An implementation of a ChannelPoolManager.
ChannelPoolManagerImpl(E, ChannelPoolFactory, ChannelPoolResolver, int) - Constructor for class com.linkedin.alpini.netty4.pool.ChannelPoolManagerImpl
ChannelPoolManagerImpl(E, ChannelPoolFactory, ChannelPoolResolver, int, boolean, boolean, boolean) - Constructor for class com.linkedin.alpini.netty4.pool.ChannelPoolManagerImpl
ChannelPoolManagerImpl(E, ChannelPoolFactory, ChannelPoolResolver, int, boolean, boolean, boolean, int) - Constructor for class com.linkedin.alpini.netty4.pool.ChannelPoolManagerImpl
ChannelPoolResolver - Interface in com.linkedin.alpini.netty4.pool: A simple interface for an asynchronous InetSocketAddress resolver.
ChannelPoolWithStats - Interface in com.linkedin.alpini.netty4.pool: A simple interface which extends ChannelPool to expose various stats.
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.handlers.BasicHttpNonMultiPartAggregator
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.handlers.ClientConnectionTracker
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.handlers.ElideDuplicateHeadersHandler
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.handlers.Http2PingSendHandler
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.handlers.HttpClientResponseHandler
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.handlers.HttpObjectToBasicHttpObjectAdapter
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.handlers.HttpServerConcurrencyObserver
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.handlers.HttpVersionFilter
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.handlers.InboundContentDebugHandler
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.handlers.InboundContentDebugHandler.HttpDecodeResult
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.handlers.Log4J2LoggingHandler
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.handlers.MemoryPressureIndexHandler
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.handlers.ReverseHandler
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.handlers.StaleConnectionHandler
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.http2.CompactHeaderHandler
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.alpini.netty4.http2.Http2ClientResponseHandler
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.venice.listener.ErrorCatchingHandler
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.venice.listener.StatsHandler
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.venice.listener.StorageReadRequestHandler
channelRead(ChannelHandlerContext, Object) - Method in class com.linkedin.venice.router.streaming.VeniceChunkedWriteHandler
channelRead(ChannelHandlerContext, Object) - Method in class io.netty.handler.codec.EspressoMessageToMessageDecoder
channelRead(ChannelHandlerContext, Object) - Method in class io.netty.handler.codec.http2.EspressoHttp2MultiplexHandler
channelRead0(ChannelHandlerContext, RouterRequest) - Method in class com.linkedin.venice.listener.ReadQuotaEnforcementHandler
channelRead0(ChannelHandlerContext, FullHttpRequest) - Method in class com.linkedin.davinci.ingestion.isolated.IsolatedIngestionServerHandler
channelRead0(ChannelHandlerContext, FullHttpRequest) - Method in class com.linkedin.davinci.ingestion.main.MainIngestionReportHandler
channelRead0(ChannelHandlerContext, FullHttpRequest) - Method in class com.linkedin.venice.listener.RouterRequestHttpHandler
channelRead0(ChannelHandlerContext, HttpRequest) - Method in class com.linkedin.davinci.ingestion.isolated.IsolatedIngestionServerAclHandler
channelRead0(ChannelHandlerContext, HttpRequest) - Method in class com.linkedin.venice.acl.handler.StoreAclHandler: Verify if client has permission to access.
channelRead0(ChannelHandlerContext, HttpRequest) - Method in class com.linkedin.venice.listener.ServerAclHandler: Verify if client has permission to access one particular resource.
channelRead0(ChannelHandlerContext, HttpRequest) - Method in class com.linkedin.venice.listener.ServerStoreAclHandler
channelRead0(ChannelHandlerContext, HttpRequest) - Method in class com.linkedin.venice.listener.VerifySslHandler: If the SSL handler is not in the channel pipeline, then return 403 otherwise pass the request along the stack.
channelRead0(ChannelHandlerContext, HttpRequest) - Method in class com.linkedin.venice.router.AdminOperationsHandler
channelRead0(ChannelHandlerContext, HttpRequest) - Method in class com.linkedin.venice.router.HealthCheckHandler
channelRead0(ChannelHandlerContext, HttpRequest) - Method in class com.linkedin.venice.router.MetaDataHandler
channelRead0(ChannelHandlerContext, HttpRequest) - Method in class com.linkedin.venice.router.RouterSslVerificationHandler: If the SSL handler is not in the channel pipeline, then return 403 otherwise pass the request along the stack.
channelRead0(ChannelHandlerContext, HttpRequest) - Method in class com.linkedin.venice.router.RouterThrottleHandler
channelRead0(ChannelHandlerContext, Http2PingFrame) - Method in class com.linkedin.alpini.netty4.handlers.Http2PingResponseHandler
channelReadComplete(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.Log4J2LoggingHandler
channelReadComplete(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.ReverseHandler
channelReadComplete(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.http2.Http2ClientResponseHandler
channelReadComplete(ChannelHandlerContext) - Method in class com.linkedin.davinci.ingestion.isolated.IsolatedIngestionServerHandler
channelReadComplete(ChannelHandlerContext) - Method in class com.linkedin.davinci.ingestion.main.MainIngestionReportHandler
channelReadComplete(ChannelHandlerContext) - Method in class com.linkedin.venice.listener.RouterRequestHttpHandler
channelReadComplete(ChannelHandlerContext) - Method in class io.netty.handler.codec.EspressoMessageAggregator
channelReadComplete(ChannelHandlerContext) - Method in class io.netty.handler.codec.http2.EspressoHttp2MultiplexHandler: Notifies any child streams of the read completion.
channelReadDataFrame(ChannelHandlerContext, Http2ClientResponseHandler.State, Http2DataFrame) - Method in class com.linkedin.alpini.netty4.http2.Http2ClientResponseHandler
channelRegistered(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.ChannelInitializer
channelRegistered(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.Log4J2LoggingHandler
channelRegistered(ChannelHandlerContext) - Method in class com.linkedin.venice.listener.ServerConnectionStatsHandler
ChannelTaskSerializer - Class in com.linkedin.alpini.netty4.misc: The purpose of this class is to execute tasks in series without overlap, even if the ChannelTaskSerializer.executeTask(Consumer, ChannelFutureListener) method is called before the completion if the previous tasks.
ChannelTaskSerializer(ChannelHandlerContext) - Constructor for class com.linkedin.alpini.netty4.misc.ChannelTaskSerializer
channelUnregistered(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.Log4J2LoggingHandler
channelUnregistered(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.ReverseHandler
channelUnregistered(ChannelHandlerContext) - Method in class com.linkedin.venice.listener.ServerConnectionStatsHandler
channelWritabilityChanged(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.Log4J2LoggingHandler
channelWritabilityChanged(ChannelHandlerContext) - Method in class com.linkedin.venice.router.streaming.NettyChunkedWriteHandler
channelWritabilityChanged(ChannelHandlerContext) - Method in class io.netty.handler.codec.http2.EspressoHttp2MultiplexHandler
charAt(int) - Method in class com.linkedin.alpini.base.misc.ByteBufAsciiString
charAt(int) - Method in class com.linkedin.alpini.base.misc.LowerCaseAsciiCharSequence
CHECK_FABRIC_BUILDOUT_STATUS - com.linkedin.venice.Command
CHECK_RESOURCE_CLEANUP_FOR_STORE_CREATION - com.linkedin.venice.controllerapi.ControllerRoute
CHECK_SUM_TYPE - Static variable in class com.linkedin.venice.writer.VeniceWriter
checkAllPartitionsQuota() - Method in class com.linkedin.davinci.kafka.consumer.StorageUtilizationManager: Enforce partition level quota for the map.
checkAndHandleUpstreamOffsetRewind(PartitionConsumptionState, OffsetRecord, PubSubMessage<KafkaKey, KafkaMessageEnvelope, Long>, long, long) - Method in class com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask
checkAndUpdateStatusForRemoteFabric(String, ControllerClient) - Method in class com.linkedin.venice.controllerapi.AdminCommandExecution
checkClusterSetup(HelixAdmin, String, int, int) - Static method in class com.linkedin.venice.utils.HelixUtils: Before this participant/spectator joining the Helix cluster, we need to make sure the cluster has been setup by controller.
checkComputeFieldValidity(String, String, Set<String>, ComputeOperationType) - Method in class com.linkedin.venice.client.store.AbstractAvroComputeRequestBuilder
checkConnectionLimit(ChannelHandlerContext) - Method in class com.linkedin.alpini.netty4.handlers.ClientConnectionTracker
checkDatabaseIntegrity(int, Map<String, String>, StoragePartitionConfig) - Method in class com.linkedin.davinci.store.AbstractStorageEngine: checks whether the current state of the database is valid during the start of ingestion.
checkDatabaseIntegrity(Map<String, String>) - Method in class com.linkedin.davinci.store.AbstractStoragePartition: checks whether the current state of the database is valid during the start of ingestion.
checkDatabaseIntegrity(Map<String, String>) - Method in class com.linkedin.davinci.store.rocksdb.ReplicationMetadataRocksDBStoragePartition
checkDatabaseIntegrity(Map<String, String>) - Method in class com.linkedin.davinci.store.rocksdb.RocksDBStoragePartition
checkDeadLock() - Method in class io.netty.bootstrap.PendingConnectFuturePromise
checkDeadLock() - Method in class io.netty.bootstrap.PendingConnectPromise
checkDisableStoreWrite(String, int) - Method in class com.linkedin.venice.meta.AbstractStore
checkDisableStoreWrite(String, int) - Method in class com.linkedin.venice.meta.ReadOnlyStore
checkDisableStoreWrite(String, int) - Method in interface com.linkedin.venice.meta.Store
checkException(Callable<T>, String) - Static method in enum com.linkedin.alpini.base.misc.ExceptionUtil: Utility method to catch checked exceptions from a Callable and to rethrow as a RuntimeException.
checkExecutionStatus(long) - Method in class com.linkedin.venice.controller.AdminCommandExecutionTracker: Check the latest status of execution in remote fabrics.
checkHttpVersion(HttpVersion) - Method in class com.linkedin.alpini.netty4.handlers.HttpVersionFilter
checkIngestionProgress(Store) - Method in class com.linkedin.davinci.kafka.consumer.StoreIngestionTask
checkInitAndQuotaEnabledToSkipQuotaEnforcement(ChannelHandlerContext, RouterRequest, Store, boolean) - Method in class com.linkedin.venice.listener.ReadQuotaEnforcementHandler
checkIsAllowListUser(Request, ControllerResponse, BooleanSupplier) - Method in class com.linkedin.venice.controller.server.VeniceRouteHandler
checkLastModificationTimeAndLogError(Exception, String) - Method in class com.linkedin.venice.hadoop.ValidateSchemaAndBuildDictMapper
checkLastModificationTimeAndLogError(Exception, String, Reporter) - Method in class com.linkedin.venice.hadoop.ValidateSchemaAndBuildDictMapper
checkLastModificationTimeAndLogError(String, Reporter) - Method in class com.linkedin.venice.hadoop.ValidateSchemaAndBuildDictMapper
checkLastResponse(HttpResponse) - Method in class com.linkedin.alpini.netty4.handlers.BasicHttpResponseDecoder
checkLongRunningTaskState() - Method in class com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask: The following function will be executed after processing all the quick actions in the consumer action queues, so that the long running actions doesn't block other partition's consumer actions.
checkLongRunningTaskState() - Method in class com.linkedin.davinci.kafka.consumer.StoreIngestionTask
checkMissingFieldInAvroRecord(GenericRecord, String) - Static method in class com.linkedin.venice.utils.TestUtils
checkMissingMessage(PubSubMessage<KafkaKey, KafkaMessageEnvelope, Long>, Optional<PartitionTracker.DIVErrorMetricCallback>) - Method in class com.linkedin.davinci.validation.KafkaDataIntegrityValidator: Only check for missing sequence number; segment starting from a positive sequence number is acceptable considering real-time buffer replay would start in the middle of a segment; checksum is also ignored for the same reason.
checkMissingMessage(PubSubMessage<KafkaKey, KafkaMessageEnvelope, Long>, Optional<PartitionTracker.DIVErrorMetricCallback>, long) - Method in class com.linkedin.davinci.validation.PartitionTracker
checkout(CompletableFuture<T>, CallCompletion) - Method in class com.linkedin.alpini.base.pool.impl.AsyncPoolImpl
checkOutputSpecs(FileSystem, JobConf) - Method in class com.linkedin.venice.hadoop.ValidateSchemaAndBuildDictOutputFormat
checkPreConditionForCreateStore(String, String, String, String, boolean, boolean) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin: Check whether Controller should block the incoming store creation.
checkPushStatus(OfflinePushStatus, PartitionAssignment, DisableReplicaCallback) - Method in class com.linkedin.venice.pushmonitor.AbstractPushMonitor
checkPushStatus(OfflinePushStatus, PartitionAssignment, DisableReplicaCallback) - Method in class com.linkedin.venice.pushmonitor.PartitionStatusBasedPushMonitor: Checking push status based on Venice offlinePush status
checkPushStatusAndDetailsByPartitionsStatus(OfflinePushStatus, PartitionAssignment, DisableReplicaCallback) - Method in class com.linkedin.venice.pushmonitor.PushStatusDecider: Check the current status based on PartitionStatus
checkReaderWriterCompatibility(Schema, Schema) - Static method in class com.linkedin.venice.schema.avro.SchemaCompatibility: Validates that the provided reader schema can be used to decode avro data written with the provided writer schema.
checkResourceCleanupBeforeStoreCreation(String, String) - Method in interface com.linkedin.venice.controller.Admin: Check whether there are any resource left for the store creation in cluster: {@param clusterName} If there is any, this function should throw Exception.
checkResourceCleanupBeforeStoreCreation(String, String) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin
checkResourceCleanupBeforeStoreCreation(String, String) - Method in class com.linkedin.venice.controller.VeniceParentHelixAdmin: This function will check whether there are still resources left for the requested store in the requested cluster.
checkResourceCleanupForStoreCreation(Admin) - Method in class com.linkedin.venice.controller.server.CreateStore
checkResourceCleanupForStoreCreation(String) - Method in class com.linkedin.venice.controllerapi.ControllerClient
checkResultSchema(Schema, Schema, List<ComputeOperation>) - Static method in class com.linkedin.venice.compute.ComputeUtils
checkSchema(Schema) - Method in class com.linkedin.venice.partitioner.InvalidKeySchemaPartitioner
checkSchema(Schema) - Method in class com.linkedin.venice.partitioner.VenicePartitioner: Implementors of this class can optionally provide an implementation of this function, which can perform validation of schemas to be certain that they are compatible with the partitioner implementation.
checkState(boolean) - Static method in enum com.linkedin.alpini.base.misc.Preconditions
checkState(boolean, String) - Static method in enum com.linkedin.alpini.base.misc.Preconditions
checkStoreNull(ChannelHandlerContext, RouterRequest, GrpcRequestContext, boolean, Store) - Method in class com.linkedin.venice.listener.ReadQuotaEnforcementHandler
CheckSum - Class in com.linkedin.venice.kafka.validation.checksum: Parent class for various running checksum implementations.
CheckSum() - Constructor for class com.linkedin.venice.kafka.validation.checksum.CheckSum
checksumState - Variable in class com.linkedin.venice.kafka.protocol.state.ProducerPartitionState: The value of the checksum computed since the last StartOfSegment ControlMessage.
checksumType - Variable in class com.linkedin.venice.kafka.protocol.StartOfSegment: Using int because Avro Enums are not evolvable.
checksumType - Variable in class com.linkedin.venice.kafka.protocol.state.ProducerPartitionState: The current mapping is the following: 0 => None, 1 => MD5, 2 => Adler32, 3 => CRC32.
CheckSumType - Enum in com.linkedin.venice.kafka.validation.checksum: Types of checksum algorithms supported by Venice's Data Ingest Validation.
checksumValue - Variable in class com.linkedin.venice.kafka.protocol.EndOfSegment: The value of the checksum computed since the last StartOfSegment ControlMessage.
checkTopicExists(String) - Method in class com.linkedin.davinci.kafka.consumer.MetadataRepoBasedTopicExistingCheckerImpl
checkTopicExists(String) - Method in interface com.linkedin.davinci.kafka.consumer.TopicExistenceChecker
checkUnwrapBoundary(Channel, String) - Method in class com.linkedin.alpini.netty4.handlers.HttpMultiPartContentCodec
checkUnwrapBoundary(Channel, String) - Method in class com.linkedin.alpini.netty4.handlers.HttpMultiPartContentDecoder
checkVersionSRTopic(String, boolean) - Static method in interface com.linkedin.venice.meta.Version
checkWhetherAccessHasAlreadyApproved(Metadata) - Static method in class com.linkedin.venice.listener.ServerStoreAclHandler
checkWhetherAccessHasAlreadyApproved(ChannelHandlerContext) - Static method in class com.linkedin.venice.listener.ServerStoreAclHandler
checkWhetherToStartBufferReplayForHybrid(OfflinePushStatus) - Method in class com.linkedin.venice.pushmonitor.AbstractPushMonitor
CHILD_CLUSTER_ALLOWLIST - Static variable in class com.linkedin.venice.ConfigKeys: Only required when controller.parent.mode=true This is a comma-separated allowlist of cluster names used in the keys with the child.cluster.url prefix.
CHILD_CLUSTER_D2_PREFIX - Static variable in class com.linkedin.venice.ConfigKeys: Similar to ConfigKeys.CHILD_CLUSTER_URL_PREFIX but with D2 ZK url.
CHILD_CLUSTER_D2_SERVICE_NAME - Static variable in class com.linkedin.venice.ConfigKeys: D2 Service name for the child controllers in local datacenter
CHILD_CLUSTER_URL_PREFIX - Static variable in class com.linkedin.venice.ConfigKeys: Only required when controller.parent.mode=true This prefix specifies the location of every child cluster that is being fed by this parent cluster.
CHILD_CLUSTER_WHITELIST - Static variable in class com.linkedin.venice.ConfigKeys: Deprecated.
CHILD_CONTROLLER_ADMIN_TOPIC_CONSUMPTION_ENABLED - com.linkedin.venice.Arg
CHILD_CONTROLLER_ADMIN_TOPIC_CONSUMPTION_ENABLED - Static variable in class com.linkedin.venice.ConfigKeys: This following config defines whether admin consumption should be enabled or not, and this config will only control the behavior in Child Controller.
CHILD_CONTROLLER_ADMIN_TOPIC_CONSUMPTION_ENABLED - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants: Whether admin consumption should be enabled.
CHILD_DATA_CENTER_KAFKA_URL_PREFIX - Static variable in class com.linkedin.venice.ConfigKeys: Config prefix for Kafka bootstrap url in all child fabrics; parent controllers need to know the Kafka url in all fabrics for native replication.
ChildAwareResponse - Class in com.linkedin.venice.controllerapi
ChildAwareResponse() - Constructor for class com.linkedin.venice.controllerapi.ChildAwareResponse
CHUNK - com.linkedin.venice.serialization.avro.AvroProtocolDefinition: Single chunk of a large multi-chunk value.
ChunkAssembler - Class in com.linkedin.venice.hadoop.input.kafka.chunk: This class accumulates all mapper values and assemble them to provide assembled complete large values or regular message.
ChunkAssembler(boolean) - Constructor for class com.linkedin.venice.hadoop.input.kafka.chunk.ChunkAssembler
ChunkAssembler.ValueBytesAndSchemaId - Class in com.linkedin.venice.hadoop.input.kafka.chunk
ChunkAwareCallback - Interface in com.linkedin.venice.writer: The VeniceWriter, upon detecting an instance of this class being passed to it, will always call ChunkAwareCallback.setChunkingInfo(byte[], ByteBuffer[], ChunkedValueManifest, ByteBuffer[], ChunkedValueManifest, ChunkedValueManifest, ChunkedValueManifest) whenever processing a MessageType.PUT, whether it is chunked or not.
chunked - Variable in class com.linkedin.venice.kafka.protocol.StartOfPush: Whether the messages inside the current push are encoded with chunking support.
chunked - Variable in class com.linkedin.venice.kafka.protocol.state.StoreVersionState: Whether the messages inside current store-version are encoded with chunking support.
CHUNKED_KEY_SUFFIX - com.linkedin.venice.serialization.avro.AvroProtocolDefinition: Suffix appended to the end of all keys in a store-version where chunking is enabled.
CHUNKED_VALUE_MANIFEST - com.linkedin.venice.serialization.avro.AvroProtocolDefinition: Used to encode the manifest of a multi-chunk large value.
CHUNKED_VALUE_MANIFEST_SERIALIZER - Static variable in class com.linkedin.davinci.kafka.consumer.LeaderProducerCallback
CHUNKED_WRITE_HANDLER_ATTRIBUTE_KEY - Static variable in class com.linkedin.venice.router.streaming.VeniceChunkedWriteHandler
ChunkedHttpResponse - Interface in com.linkedin.alpini.netty4.misc
chunkedKeySuffix - Variable in class com.linkedin.venice.hadoop.input.kafka.avro.KafkaInputMapperValue: Serialized chunked key suffix and this field is not null only when this value is a chunk of a large value
ChunkedKeySuffix - Class in com.linkedin.venice.storage.protocol: This record is appended to the end of keys in a store-version where chunking is enabled.
ChunkedKeySuffix() - Constructor for class com.linkedin.venice.storage.protocol.ChunkedKeySuffix: Default constructor.
ChunkedKeySuffix(ChunkId, Boolean) - Constructor for class com.linkedin.venice.storage.protocol.ChunkedKeySuffix: All-args constructor.
ChunkedKeySuffixSerializer - Class in com.linkedin.venice.serialization.avro
ChunkedKeySuffixSerializer() - Constructor for class com.linkedin.venice.serialization.avro.ChunkedKeySuffixSerializer
ChunkedPayloadAndManifest - Class in com.linkedin.venice.writer: This class contains both chunked results and manifest for a specific payload.
ChunkedPayloadAndManifest(ByteBuffer[], ChunkedValueManifest) - Constructor for class com.linkedin.venice.writer.ChunkedPayloadAndManifest
ChunkedResponseHandler - Class in com.linkedin.alpini.netty4.handlers
ChunkedResponseHandler() - Constructor for class com.linkedin.alpini.netty4.handlers.ChunkedResponseHandler
ChunkedResponseLimiter - Class in com.linkedin.alpini.netty4.handlers: Deprecated.
broken. use the content chunking in HttpMultiPartContentEncoder
ChunkedResponseLimiter() - Constructor for class com.linkedin.alpini.netty4.handlers.ChunkedResponseLimiter: Deprecated.
ChunkedResponseLimiter(int, int) - Constructor for class com.linkedin.alpini.netty4.handlers.ChunkedResponseLimiter: Deprecated.
chunkedRmdManifest - Variable in class com.linkedin.davinci.kafka.consumer.LeaderProducerCallback
ChunkedValueInputStream - Class in com.linkedin.davinci.storage.chunking: This InputStream implementation allows us to pass a value made up of many chunks into the Avro decoder without stitching it up into a single big byte array.
ChunkedValueInputStream(int) - Constructor for class com.linkedin.davinci.storage.chunking.ChunkedValueInputStream
ChunkedValueManifest - Class in com.linkedin.venice.storage.protocol: This record maintains chunking information in order to re-assemble a value value that was split in many chunks.
ChunkedValueManifest() - Constructor for class com.linkedin.venice.storage.protocol.ChunkedValueManifest: Default constructor.
ChunkedValueManifest(List<ByteBuffer>, Integer, Integer) - Constructor for class com.linkedin.venice.storage.protocol.ChunkedValueManifest: All-args constructor.
ChunkedValueManifestContainer - Class in com.linkedin.davinci.storage.chunking
ChunkedValueManifestContainer() - Constructor for class com.linkedin.davinci.storage.chunking.ChunkedValueManifestContainer
ChunkedValueManifestSerializer - Class in com.linkedin.venice.serialization.avro
ChunkedValueManifestSerializer(boolean) - Constructor for class com.linkedin.venice.serialization.avro.ChunkedValueManifestSerializer
chunkId - Variable in class com.linkedin.venice.storage.protocol.ChunkedKeySuffix: This is an optional record which, if null, means that the value associated to this key does not correspond to a chunk (i.e.: it is associated to a normal non-chunked fully self-contained value, or to a ChunkedValueManifest).
ChunkId - Class in com.linkedin.venice.storage.protocol: This record contains chunking information to uniquely identify each chunk.
ChunkId() - Constructor for class com.linkedin.venice.storage.protocol.ChunkId: Default constructor.
ChunkId(GUID, Integer, Integer, Integer) - Constructor for class com.linkedin.venice.storage.protocol.ChunkId: All-args constructor.
chunkIndex - Variable in class com.linkedin.venice.storage.protocol.ChunkId: The index of the current chunk.
CHUNKING_ENABLED - com.linkedin.venice.Arg
CHUNKING_ENABLED - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
ChunkingAdapter<CHUNKS_CONTAINER,VALUE> - Interface in com.linkedin.davinci.storage.chunking: This interface allows each code path which needs to interact with chunked values to optimize the way the re-assembly is handled so that the final form in which the is consumed is generated as efficiently as possible, via the use of a temporary ChunkingAdapter.
chunkingAndPartitionCountsCombination() - Static method in class com.linkedin.venice.utils.DataProviderUtils
chunkingEnabled - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore
chunkingEnabled - Variable in class com.linkedin.venice.meta.systemstore.schemas.StoreProperties
chunkingEnabled - Variable in class com.linkedin.venice.meta.systemstore.schemas.StoreVersionState
chunkingEnabled - Variable in class com.linkedin.venice.status.protocol.PushJobDetails
chunkingEnabled - Variable in class com.linkedin.venice.systemstore.schemas.StoreProperties: Whether current store supports large value (typically more than 1MB).
chunkingEnabled - Variable in class com.linkedin.venice.systemstore.schemas.StoreVersion: Whether or not large values are supported (via chunking).
ChunkingUtils - Class in com.linkedin.davinci.storage.chunking: This class and the rest of this package encapsulate the complexity of assembling chunked values from the storage engine.
ChunkingUtils() - Constructor for class com.linkedin.davinci.storage.chunking.ChunkingUtils
ChunkKeyValueTransformer - Interface in com.linkedin.venice.chunking: This interface provides methods to split a key into raw key/value byte array and ChunkedKeySuffix.
ChunkKeyValueTransformer.KeyType - Enum in com.linkedin.venice.chunking
ChunkKeyValueTransformerImpl - Class in com.linkedin.venice.chunking
ChunkKeyValueTransformerImpl(Schema) - Constructor for class com.linkedin.venice.chunking.ChunkKeyValueTransformerImpl
chunkPayloadAndSend(byte[], byte[], boolean, int, int, boolean, Supplier<String>, int, KeyWithChunkingSuffixSerializer, BiConsumer<VeniceWriter.KeyProvider, Put>) - Static method in class com.linkedin.venice.writer.WriterChunkingHelper: This method chunks payload and send each chunk out.
CIPHER_SUITE_ALLOWLIST - Static variable in class com.linkedin.alpini.netty4.ssl.SSLEngineFactoryImpl
CIPHERS - Static variable in class com.linkedin.alpini.netty4.http2.SSLContextBuilder
ClassUtil - Class in com.linkedin.alpini.base.misc: Utilities for Classes / reflection.
cleanHeaderValue(CharSequence) - Static method in enum com.linkedin.alpini.base.misc.HeaderUtils: Checks to ensure that a provided header value may be used as-is or returns a new string which has been appropiately filtered.
cleanStatusMessage(CharSequence) - Static method in enum com.linkedin.alpini.base.misc.HeaderUtils: Cleans the status message and if no cleanup is required, returns the same String object.
CLEANUP_INSTANCE_CUSTOMIZED_STATES - com.linkedin.venice.Command
CLEANUP_INSTANCE_CUSTOMIZED_STATES - com.linkedin.venice.controllerapi.ControllerRoute
cleanupAllStores(VeniceConfigLoader) - Method in class com.linkedin.davinci.storage.StorageService
cleanupBackupVersion(Store, String) - Method in class com.linkedin.venice.controller.StoreBackupVersionCleanupService: Using a separate function for store cleanup is to make it easy for testing.
cleanUpHDFSPath(String, boolean) - Static method in class com.linkedin.venice.hadoop.utils.HadoopUtils: Silently clean up the given path on HDFS.
cleanupInstanceCustomizedStates() - Method in class com.linkedin.venice.controllerapi.ControllerClient
cleanupInstanceCustomizedStates(Admin) - Method in class com.linkedin.venice.controller.server.ClusterRoutes: Endpoint intended to be called via the admin tool manually to trigger cleanup for any lingering ZNodes produced from bugs/errors for instance level customized states.
cleanupInstanceCustomizedStates(String) - Method in interface com.linkedin.venice.controller.Admin: Scan through instance level customized states and remove any lingering ZNodes that are no longer relevant.
cleanupInstanceCustomizedStates(String) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin
cleanupInstanceCustomizedStates(String) - Method in class com.linkedin.venice.controller.VeniceParentHelixAdmin
cleanupReplicaStatusesFromMetaSystemStore(PubSubTopic) - Method in class com.linkedin.venice.controller.kafka.TopicCleanupService: Clean up staled replica status from meta system store if necessary.
cleanupStoreStatus(String) - Method in class com.linkedin.venice.pushmonitor.AbstractPushMonitor
cleanupStoreStatus(String) - Method in interface com.linkedin.venice.pushmonitor.PushMonitor: Clean up all push statuses related to a store including all error pushes.
cleanupStoreStatus(String) - Method in class com.linkedin.venice.pushmonitor.PushMonitorDelegator
cleanupTopicPartitionState(String, int) - Method in class com.linkedin.davinci.ingestion.isolated.IsolatedIngestionServer
cleanupTopicPartitionState(String, int) - Method in class com.linkedin.davinci.ingestion.main.MainIngestionMonitorService
cleanupTopicState(String) - Method in class com.linkedin.davinci.ingestion.isolated.IsolatedIngestionServer
cleanupTopicState(String) - Method in class com.linkedin.davinci.ingestion.main.MainIngestionMonitorService
cleanupVeniceTopics() - Method in class com.linkedin.venice.controller.kafka.TopicCleanupServiceForParentController
clear() - Method in class com.linkedin.alpini.base.cache.PhantomHashCache: Remove all entries from the map.
clear() - Method in class com.linkedin.alpini.base.cache.PhantomHashMap
clear() - Method in class com.linkedin.alpini.base.concurrency.ArraySortedSet
clear() - Method in class com.linkedin.alpini.base.concurrency.ConcurrentLinkedBlockingQueue
clear() - Method in class com.linkedin.alpini.netty4.handlers.AllChannelsHandler
clear() - Method in class com.linkedin.alpini.netty4.http2.Http1Headers
clear() - Method in class com.linkedin.davinci.consumer.RecordChangeEventReadOnlySchemaRepository
clear() - Method in class com.linkedin.davinci.kafka.consumer.MemoryBoundBlockingQueue
clear() - Method in class com.linkedin.davinci.repository.DaVinciClientMetaStoreBasedRepository: Deprecated.
clear() - Method in class com.linkedin.davinci.repository.NativeMetadataRepository: TODO: we may need to rename this function to be 'close' since this resource should not used any more after calling this function.
clear() - Method in class com.linkedin.davinci.repository.ThinClientMetaStoreBasedRepository
clear() - Method in class com.linkedin.davinci.store.cache.caffeine.CaffeineVeniceStoreCache
clear() - Method in interface com.linkedin.davinci.store.cache.VeniceStoreCache: Discards all entries in the cache.
clear() - Method in class com.linkedin.davinci.utils.IndexedHashMap: Removes all of the mappings from this map.
clear() - Method in class com.linkedin.venice.controller.helix.SharedHelixReadOnlyZKSharedSchemaRepository
clear() - Method in class com.linkedin.venice.controller.helix.SharedHelixReadOnlyZKSharedSystemStoreRepository
clear() - Method in class com.linkedin.venice.controller.HelixVeniceClusterResources
clear() - Method in class com.linkedin.venice.helix.CachedReadOnlyStoreRepository
clear() - Method in class com.linkedin.venice.helix.HelixBaseRoutingRepository
clear() - Method in class com.linkedin.venice.helix.HelixCustomizedViewOfflinePushRepository
clear() - Method in class com.linkedin.venice.helix.HelixExternalViewRepository
clear() - Method in class com.linkedin.venice.helix.HelixHybridStoreQuotaRepository
clear() - Method in class com.linkedin.venice.helix.HelixInstanceConfigRepository
clear() - Method in class com.linkedin.venice.helix.HelixLiveInstanceMonitor
clear() - Method in class com.linkedin.venice.helix.HelixReadOnlyLiveClusterConfigRepository
clear() - Method in class com.linkedin.venice.helix.HelixReadOnlySchemaRepository: Clear local cache and watches
clear() - Method in class com.linkedin.venice.helix.HelixReadOnlySchemaRepositoryAdapter
clear() - Method in class com.linkedin.venice.helix.HelixReadOnlyStoreConfigRepository
clear() - Method in class com.linkedin.venice.helix.HelixReadOnlyStoreRepository
clear() - Method in class com.linkedin.venice.helix.HelixReadOnlyStoreRepositoryAdapter
clear() - Method in class com.linkedin.venice.helix.HelixReadOnlyZKSharedSystemStoreRepository
clear() - Method in class com.linkedin.venice.helix.HelixReadWriteSchemaRepository
clear() - Method in class com.linkedin.venice.helix.HelixReadWriteSchemaRepositoryAdapter
clear() - Method in class com.linkedin.venice.helix.ZkRoutersClusterManager
clear() - Method in class com.linkedin.venice.listener.StoreValueSchemasCacheService
clear() - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder
clear() - Method in class com.linkedin.venice.protocols.VeniceServerResponse.Builder
clear() - Method in class com.linkedin.venice.pushmonitor.PushStatusCollector
clear() - Method in class com.linkedin.venice.serializer.ArrayBasedPrimitiveIntegerSet: Removes all of the elements from this set (optional operation).
clear() - Method in class com.linkedin.venice.utils.collections.ArrayCollection
clear() - Method in class com.linkedin.venice.utils.ComplementSet
clear() - Method in class com.linkedin.venice.utils.ConcurrentRef
clear() - Method in class com.linkedin.venice.utils.locks.ClusterLockManager
clear() - Method in class com.linkedin.venice.utils.SparseConcurrentList
clear() - Method in interface com.linkedin.venice.VeniceResource
CLEAR_OFFSET_RECORD - com.linkedin.venice.meta.IngestionMetadataUpdateType
CLEAR_STORE_VERSION_STATE - com.linkedin.venice.meta.IngestionMetadataUpdateType
clearAclCounter - Variable in class com.linkedin.venice.controller.MockVeniceAuthorizer
clearAcls(Resource) - Method in interface com.linkedin.venice.authorization.AuthorizerService: This will clear the existing AceEntries for a resource.
clearAcls(Resource) - Method in class com.linkedin.venice.controller.MockVeniceAuthorizer
clearAllOffsetState() - Method in class com.linkedin.venice.pubsub.adapter.kafka.TopicPartitionsOffsetsTracker: Clear all tracked offsets state
clearBitSet() - Method in class com.linkedin.venice.utils.RedundantExceptionFilter
clearBuffer(Channel) - Static method in class com.linkedin.alpini.netty4.handlers.InboundContentDebugHandler
clearCachedPartitions(Version) - Method in class com.linkedin.davinci.store.cache.backend.ObjectCacheBackend
clearCompressionStrategy() - Method in class com.linkedin.venice.protocols.VeniceServerResponse.Builder: uint32 compressionStrategy = 3;
clearData() - Method in class com.linkedin.venice.protocols.VeniceServerResponse.Builder: bytes data = 2;
clearErrorCode() - Method in class com.linkedin.venice.protocols.VeniceServerResponse.Builder: uint32 errorCode = 6;
clearErrorMessage() - Method in class com.linkedin.venice.protocols.VeniceServerResponse.Builder: string errorMessage = 7;
clearField(Descriptors.FieldDescriptor) - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder
clearField(Descriptors.FieldDescriptor) - Method in class com.linkedin.venice.protocols.VeniceServerResponse.Builder
clearInstanceMonitor(String) - Method in interface com.linkedin.venice.controller.Admin
clearInstanceMonitor(String) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin
clearIsBatchRequest() - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder: bool isBatchRequest = 9;
clearIsRetryRequest() - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder: bool isRetryRequest = 8;
clearIsStreamingRequest() - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder: bool isStreamingRequest = 7;
clearIsStreamingResponse() - Method in class com.linkedin.venice.protocols.VeniceServerResponse.Builder: bool isStreamingResponse = 5;
clearKeyBytes() - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder: used for batch get
clearKeyString() - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder: used for single get
clearMethod() - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder: string method = 10;
clearOffset(String, int) - Method in class com.linkedin.davinci.ingestion.main.MainIngestionStorageMetadataService
clearOffset(String, int) - Method in class com.linkedin.davinci.storage.StorageEngineMetadataService
clearOffset(String, int) - Method in class com.linkedin.venice.offsets.DeepCopyOffsetManager
clearOffset(String, int) - Method in class com.linkedin.venice.offsets.InMemoryOffsetManager
clearOffset(String, int) - Method in interface com.linkedin.venice.offsets.OffsetManager
clearOneof(Descriptors.OneofDescriptor) - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder
clearOneof(Descriptors.OneofDescriptor) - Method in class com.linkedin.venice.protocols.VeniceServerResponse.Builder
clearPartition() - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder: uint32 partition = 1;
clearPartition(int) - Method in class com.linkedin.davinci.validation.KafkaDataIntegrityValidator: In some cases, such as when resetting offsets or unsubscribing from a partition, the PartitionTracker should forget about the state that it accumulated for a given partition.
clearPartitionOffset(int) - Method in class com.linkedin.davinci.store.AbstractStorageEngine: Clear the offset associated with the partitionId in the metadata partition.
clearRecord(GenericRecord) - Static method in class com.linkedin.venice.utils.AvroRecordUtils
clearResource(Resource) - Method in interface com.linkedin.venice.authorization.AuthorizerService: This may perform any finalization steps that may be necessary after all ACL's for a resource is deleted and the resource will not be used later.
clearResourceName() - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder: string resourceName = 5;
clearResponseRCU() - Method in class com.linkedin.venice.protocols.VeniceServerResponse.Builder: uint32 responseRCU = 4;
clearSchemaId() - Method in class com.linkedin.venice.protocols.VeniceServerResponse.Builder: sint32 schemaId = 1;
clearStoreVersionState() - Method in class com.linkedin.davinci.store.AbstractStorageEngine: Clear the store version state in the metadata partition.
clearStoreVersionState(String) - Method in class com.linkedin.davinci.ingestion.main.MainIngestionStorageMetadataService
clearStoreVersionState(String) - Method in class com.linkedin.davinci.storage.StorageEngineMetadataService
clearStoreVersionState(String) - Method in interface com.linkedin.davinci.storage.StorageMetadataService: This will clear all metadata, including store-version state and partition states, tied to {@param topicName}.
clearStoreVersionState(String) - Method in class com.linkedin.venice.offsets.DeepCopyStorageMetadataService: This will clear all metadata, including store-version state and partition states, tied to {@param topicName}.
clearStoreVersionState(String) - Method in class com.linkedin.venice.offsets.InMemoryStorageMetadataService
CLIArgument - Annotation Type in com.linkedin.alpini.cli: Annotation for a command line option with an argument, like "--file ".
CLIArgumentParser<T> - Class in com.linkedin.alpini.cli: Utility class to handle typical command line argument parsing and log initialization.
CLIArgumentParser(String, Class<T>) - Constructor for class com.linkedin.alpini.cli.CLIArgumentParser: Create a new parser for the given application and argument class.
CLIENT_CERTIFICATE_ATTRIBUTE_KEY - Static variable in class com.linkedin.alpini.netty4.ssl.SecureClientHandler
CLIENT_CONNECTION_COUNT_GAUGE - Static variable in class com.linkedin.venice.stats.ServerConnectionStats
CLIENT_DECOMPRESSION_ENABLED - com.linkedin.venice.Arg
CLIENT_DECOMPRESSION_ENABLED - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
CLIENT_PRODUCER_SCHEMA_REFRESH_INTERVAL_SECONDS - Static variable in class com.linkedin.venice.ConfigKeys: The refresh interval for online producer to refresh value schemas and update schemas that rely on periodic polling.
CLIENT_PRODUCER_THREAD_NUM - Static variable in class com.linkedin.venice.ConfigKeys: Number of threads for online Venice producer controlling the number of concurrent write operations.
CLIENT_SYSTEM_STORE_REPOSITORY_REFRESH_INTERVAL_SECONDS - Static variable in class com.linkedin.venice.ConfigKeys: The refresh interval for system store repositories that rely on periodic polling.
CLIENT_USE_DA_VINCI_BASED_SYSTEM_STORE_REPOSITORY - Static variable in class com.linkedin.venice.ConfigKeys: This config controls whether to use da-vinci based implementation of the system store repository when CLIENT_USE_SYSTEM_STORE_REPOSITORY is set to true.
CLIENT_USE_SYSTEM_STORE_REPOSITORY - Static variable in class com.linkedin.venice.ConfigKeys: A config for Da-Vinci clients to use system store based repositories or Zk based repositories.
clientCertificateValidation(ChannelHandlerContext, X509Certificate) - Method in class com.linkedin.alpini.netty4.ssl.SslClientInitializer
ClientComputeRecordStreamDecoder<K,V> - Class in com.linkedin.venice.client.store.streaming
ClientComputeRecordStreamDecoder(List<K>, ClientComputeRecordStreamDecoder.Callback<K, V>, Executor, RecordDeserializer<StreamingFooterRecordV1>, Supplier<RecordDeserializer<V>>, Function<Integer, RecordDeserializer<V>>, BiFunction<CompressionStrategy, ByteBuffer, ByteBuffer>) - Constructor for class com.linkedin.venice.client.store.streaming.ClientComputeRecordStreamDecoder
ClientComputeRecordStreamDecoder.Callback<K,V> - Class in com.linkedin.venice.client.store.streaming
clientConfig - Variable in class com.linkedin.davinci.repository.NativeMetadataRepository
clientConfig - Variable in class com.linkedin.venice.client.store.deserialization.BatchDeserializer
ClientConfig<T extends org.apache.avro.specific.SpecificRecord> - Class in com.linkedin.venice.client.store
ClientConfig<K,V,T extends org.apache.avro.specific.SpecificRecord> - Class in com.linkedin.venice.fastclient
ClientConfig() - Constructor for class com.linkedin.venice.client.store.ClientConfig
ClientConfig(String) - Constructor for class com.linkedin.venice.client.store.ClientConfig
ClientConfig.ClientConfigBuilder<K,V,T extends org.apache.avro.specific.SpecificRecord> - Class in com.linkedin.venice.fastclient
ClientConfigBuilder() - Constructor for class com.linkedin.venice.fastclient.ClientConfig.ClientConfigBuilder
ClientConnectionTracker - Class in com.linkedin.alpini.netty4.handlers: A connectionTracker that tracks the connection count for each client.
ClientConnectionTracker(int, int) - Constructor for class com.linkedin.alpini.netty4.handlers.ClientConnectionTracker
ClientConnectionTracker.ConnectionStats - Class in com.linkedin.alpini.netty4.handlers
clientDecompressionEnabled - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore
clientDecompressionEnabled - Variable in class com.linkedin.venice.meta.systemstore.schemas.StoreProperties
clientDecompressionEnabled - Variable in class com.linkedin.venice.systemstore.schemas.StoreProperties: le/Disable client-side record decompression (default: true)
ClientFactory - Class in com.linkedin.venice.client.store
ClientFactory - Class in com.linkedin.venice.fastclient.factory: Every call in this factory will create its own ThinClientBasedMetadata.
ClientFactory() - Constructor for class com.linkedin.venice.client.store.ClientFactory
ClientFactory() - Constructor for class com.linkedin.venice.fastclient.factory.ClientFactory
ClientFactoryTestUtils - Class in com.linkedin.venice.client.store
ClientFactoryTestUtils() - Constructor for class com.linkedin.venice.client.store.ClientFactoryTestUtils
ClientRoutingStrategy - Interface in com.linkedin.venice.fastclient.meta
ClientRoutingStrategyType - Enum in com.linkedin.venice.fastclient.meta: Different routing strategy types for client side routing: 1.
ClientStats - Class in com.linkedin.venice.client.stats
ClientStats(MetricsRepository, String, RequestType) - Constructor for class com.linkedin.venice.client.stats.ClientStats
ClientTestUtils - Class in com.linkedin.venice.fastclient.utils
ClientTestUtils() - Constructor for class com.linkedin.venice.fastclient.utils.ClientTestUtils
ClientTestUtils.FastClientHTTPVariant - Enum in com.linkedin.venice.fastclient.utils
CLIFlag - Annotation Type in com.linkedin.alpini.cli: Annotation for a boolean command line option without an argument, like "--exit-on-error".
CLIFooter - Annotation Type in com.linkedin.alpini.cli: Annotation for text to display as the footer of the "--help" output.
CLIHeader - Annotation Type in com.linkedin.alpini.cli: Annotation for text to display as the header of the "--help" output.
clipAndFilterNamespace(String) - Method in class com.linkedin.venice.utils.VeniceProperties: This method looks for all properties that begins with the given namespace.
CLIParser<T> - Interface in com.linkedin.alpini.cli
CLIUnknown - Annotation Type in com.linkedin.alpini.cli: Annotation for a String[] property which will receive all the command line elements which were not processed by the command line parser.
CLOCK - com.linkedin.davinci.store.rocksdb.RocksDBBlockCacheImplementations: ClockCache implements the CLOCK algorithm.
clone() - Method in class com.linkedin.alpini.base.concurrency.ArraySortedSet
clone() - Method in class com.linkedin.alpini.base.misc.TimeValue
clone() - Method in class com.linkedin.alpini.base.statistics.AbstractQuantileEstimation.AbstractSample
clone() - Method in class com.linkedin.alpini.netty4.misc.BasicFullHttpRequest
clone() - Method in class com.linkedin.alpini.netty4.misc.BasicHttpRequest
clone() - Method in class com.linkedin.davinci.client.DaVinciConfig
clone() - Method in class com.linkedin.venice.fastclient.ClientConfig.ClientConfigBuilder
clone() - Method in interface com.linkedin.venice.meta.DataRecoveryVersionConfig
clone() - Method in class com.linkedin.venice.meta.DataRecoveryVersionConfigImpl
clone() - Method in interface com.linkedin.venice.meta.ETLStoreConfig
clone() - Method in class com.linkedin.venice.meta.ETLStoreConfigImpl
clone() - Method in interface com.linkedin.venice.meta.HybridStoreConfig
clone() - Method in class com.linkedin.venice.meta.HybridStoreConfigImpl
clone() - Method in interface com.linkedin.venice.meta.PartitionerConfig
clone() - Method in class com.linkedin.venice.meta.PartitionerConfigImpl
clone() - Method in class com.linkedin.venice.meta.ReadOnlyViewConfig
clone() - Method in interface com.linkedin.venice.meta.SystemStoreAttributes
clone() - Method in class com.linkedin.venice.meta.SystemStoreAttributesImpl
clone() - Method in class com.linkedin.venice.protocols.VeniceClientRequest.Builder
clone() - Method in class com.linkedin.venice.protocols.VeniceServerResponse.Builder
clone() - Method in class com.linkedin.venice.schema.SchemaEntry
clone() - Method in class io.netty.bootstrap.InstrumentedBootstrap
clone(EventLoopGroup) - Method in class io.netty.bootstrap.InstrumentedBootstrap
clone(EventLoopGroup) - Method in class io.netty.bootstrap.ResolveAllBootstrap
cloneConfig(ChangelogClientConfig<V>) - Static method in class com.linkedin.davinci.consumer.ChangelogClientConfig
cloneConfig(ClientConfig<V>) - Static method in class com.linkedin.venice.client.store.ClientConfig
cloneConfig(String, UpdateStoreQueryParams) - Method in class com.linkedin.venice.controllerapi.UpdateStoreQueryParams
cloneProducerStates(int, KafkaDataIntegrityValidator) - Method in class com.linkedin.davinci.kafka.consumer.StoreIngestionTask: We should only allow StoreIngestionTask to access StoreIngestionTask.kafkaDataIntegrityValidator; other components like leaders in LeaderFollowerStoreIngestionTask should never access the DIV validator in drainer, because messages consumption in leader is ahead of drainer, leaders and drainers are processing messages at different paces.
cloneProducerStates(int, KafkaDataIntegrityValidator) - Method in class com.linkedin.davinci.validation.KafkaDataIntegrityValidator
cloneProducerStates(PartitionTracker) - Method in class com.linkedin.davinci.validation.PartitionTracker
clonePushStatus() - Method in class com.linkedin.venice.pushmonitor.OfflinePushStatus
cloneRoutesClusterConfig() - Method in class com.linkedin.venice.meta.RoutersClusterConfig
cloneSortedSet(SortedSet<LongQuantileEstimation.Sample>) - Method in class com.linkedin.alpini.base.statistics.LongQuantileArrayEstimation
cloneSortedSet(SortedSet<LongQuantileEstimation.Sample>) - Method in class com.linkedin.alpini.base.statistics.LongStatsArrayAggregator
cloneSortedSet(SortedSet<SAMPLE>) - Method in class com.linkedin.alpini.base.statistics.AbstractQuantileEstimation
cloneStore() - Method in class com.linkedin.venice.meta.ReadOnlyStore
cloneStore() - Method in interface com.linkedin.venice.meta.Store
cloneStore() - Method in class com.linkedin.venice.meta.SystemStore
cloneStore() - Method in class com.linkedin.venice.meta.ZKStore: Cloned a new store based on current data in this store.
cloneStoreConfig() - Method in class com.linkedin.venice.meta.StoreConfig
cloneUpstreamOffsetMap(Map<String, Long>) - Method in class com.linkedin.venice.offsets.OffsetRecord: Clone the checkpoint upstream offset map to another map provided as the input.
cloneVersion() - Method in class com.linkedin.venice.meta.ReadOnlyStore.ReadOnlyVersion
cloneVersion() - Method in interface com.linkedin.venice.meta.Version
cloneVersion() - Method in class com.linkedin.venice.meta.VersionImpl: Clone a new version based on current data in this version.
ClosableHttpAsyncClientWithConnManager(CloseableHttpAsyncClient, PoolingNHttpClientConnectionManager) - Constructor for class com.linkedin.venice.httpclient.HttpClientUtils.ClosableHttpAsyncClientWithConnManager
close() - Method in interface com.linkedin.alpini.base.monitoring.CallCompletion
close() - Method in class com.linkedin.alpini.io.CompressOutputStream: Closes this output stream and releases any system resources associated with the stream.
close() - Method in class com.linkedin.alpini.io.PigzOutputStream: Closes this output stream and releases any system resources associated with the stream.
close() - Method in class com.linkedin.alpini.netty4.pool.EspressoFixedChannelPool
close() - Method in class com.linkedin.alpini.netty4.pool.EspressoSimpleChannelPool
close() - Method in class com.linkedin.alpini.netty4.pool.FastFixedChannelPool
close() - Method in class com.linkedin.alpini.netty4.pool.FastSimpleChannelPool
close() - Method in class com.linkedin.alpini.netty4.pool.FixedChannelPoolImpl
close() - Method in class com.linkedin.alpini.netty4.pool.FixedFastChannelPoolImpl
close() - Method in class com.linkedin.alpini.netty4.pool.Http2AwareChannelPool
close() - Method in class com.linkedin.davinci.client.AvroGenericDaVinciClient
close() - Method in class com.linkedin.davinci.client.DelegatingAvroGenericDaVinciClient
close() - Method in class com.linkedin.davinci.client.factory.CachingDaVinciClientFactory
close() - Method in interface com.linkedin.davinci.consumer.VeniceChangelogConsumer: Release the internal resources.
close() - Method in class com.linkedin.davinci.consumer.VeniceChangelogConsumerImpl
close() - Method in class com.linkedin.davinci.DaVinciBackend
close() - Method in class com.linkedin.davinci.ingestion.DefaultIngestionBackend
close() - Method in class com.linkedin.davinci.ingestion.HttpClientTransport
close() - Method in class com.linkedin.davinci.ingestion.isolated.IsolatedIngestionRequestClient
close() - Method in class com.linkedin.davinci.ingestion.IsolatedIngestionBackend
close() - Method in class com.linkedin.davinci.ingestion.main.MainIngestionRequestClient
close() - Method in class com.linkedin.davinci.kafka.consumer.ParticipantStoreConsumptionTask
close() - Method in class com.linkedin.davinci.kafka.consumer.StoreIngestionTask: Stops the consumer task.
close() - Method in class com.linkedin.davinci.notifier.LogNotifier
close() - Method in class com.linkedin.davinci.notifier.PartitionPushStatusNotifier
close() - Method in class com.linkedin.davinci.notifier.PushMonitorNotifier
close() - Method in interface com.linkedin.davinci.notifier.VeniceNotifier: The Process is shutting down and clean up the resources associated with the Notifier.
close() - Method in class com.linkedin.davinci.storage.StorageEngineRepository
close() - Method in class com.linkedin.davinci.store.AbstractStorageEngine
close() - Method in class com.linkedin.davinci.store.AbstractStoragePartition: Close the specific partition
close() - Method in class com.linkedin.davinci.store.blackhole.BlackHoleStorageEngineFactory
close() - Method in class com.linkedin.davinci.store.blackhole.BlackHoleStorageEnginePartition
close() - Method in class com.linkedin.davinci.store.cache.backend.ObjectCacheBackend
close() - Method in class com.linkedin.davinci.store.cache.caffeine.CaffeineVeniceStoreCache
close() - Method in interface com.linkedin.davinci.store.cache.VeniceStoreCache: Performs any pending maintenance operations needed by the cache.
close() - Method in class com.linkedin.davinci.store.cache.VeniceStoreCacheStoragePartition
close() - Method in class com.linkedin.davinci.store.memory.InMemoryStorageEngineFactory
close() - Method in class com.linkedin.davinci.store.memory.InMemoryStoragePartition
close() - Method in class com.linkedin.davinci.store.rocksdb.ReplicationMetadataRocksDBStoragePartition
close() - Method in class com.linkedin.davinci.store.rocksdb.RocksDBSstFileWriter
close() - Method in class com.linkedin.davinci.store.rocksdb.RocksDBStorageEngineFactory
close() - Method in class com.linkedin.davinci.store.rocksdb.RocksDBStoragePartition
close() - Method in class com.linkedin.davinci.store.StorageEngineFactory: Close the storage configuration
close() - Method in class com.linkedin.davinci.store.view.ChangeCaptureViewWriter
close() - Method in class com.linkedin.venice.client.factory.CachingVeniceStoreClientFactory
close() - Method in interface com.linkedin.venice.client.factory.VeniceStoreClientFactory
close() - Method in class com.linkedin.venice.client.schema.RouterBackedSchemaReader
close() - Method in class com.linkedin.venice.client.schema.RouterBasedStoreSchemaFetcher
close() - Method in class com.linkedin.venice.client.store.AbstractAvroStoreClient: The behavior of READ apis will be non-deterministic after `close` function is called.
close() - Method in interface com.linkedin.venice.client.store.AvroGenericStoreClient: Release the internal resources.
close() - Method in class com.linkedin.venice.client.store.DelegatingStoreClient
close() - Method in class com.linkedin.venice.client.store.transport.D2TransportClient
close() - Method in class com.linkedin.venice.client.store.transport.HttpTransportClient
close() - Method in class com.linkedin.venice.compression.CompressorFactory
close() - Method in class com.linkedin.venice.compression.GzipCompressor
close() - Method in class com.linkedin.venice.compression.VeniceCompressor
close() - Method in class com.linkedin.venice.compression.ZstdWithDictCompressor
close() - Method in interface com.linkedin.venice.controller.Admin
close() - Method in class com.linkedin.venice.controller.authorization.SystemStoreAclSynchronizationTask
close() - Method in class com.linkedin.venice.controller.datarecovery.DataRecoveryManager: Cause all Venice avro client to close.
close() - Method in class com.linkedin.venice.controller.ErrorPartitionResetTask: Cause ErrorPartitionResetTask to stop executing.
close() - Method in class com.linkedin.venice.controller.helix.SharedHelixReadOnlyZKSharedSchemaRepository
close() - Method in class com.linkedin.venice.controller.helix.SharedHelixReadOnlyZKSharedSystemStoreRepository
close() - Method in interface com.linkedin.venice.controller.HelixAdminClient: Release resources.
close() - Method in class com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask
close() - Method in class com.linkedin.venice.controller.TerminalStateTopicCheckerForParentController: Causes TerminalStateTopicCheckerForParentController task to stop executing.
close() - Method in class com.linkedin.venice.controller.VeniceHelixAdmin: Cause VeniceHelixAdmin and its associated services to stop executing.
close() - Method in class com.linkedin.venice.controller.VeniceParentHelixAdmin: Cause VeniceParentHelixAdmin and its associated services to stop executing.
close() - Method in class com.linkedin.venice.controller.ZkHelixAdminClient
close() - Method in class com.linkedin.venice.controllerapi.ControllerClient
close() - Method in class com.linkedin.venice.controllerapi.ControllerTransport
close() - Method in class com.linkedin.venice.controllerapi.D2ControllerClient
close() - Method in class com.linkedin.venice.fastclient.DelegatingAvroStoreClient
close() - Method in class com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient
close() - Method in class com.linkedin.venice.fastclient.meta.AbstractStoreMetadata
close() - Method in class com.linkedin.venice.fastclient.meta.InstanceHealthMonitor
close() - Method in class com.linkedin.venice.fastclient.meta.RequestBasedMetadata
close() - Method in class com.linkedin.venice.fastclient.meta.VeniceClientBasedMetadata
close() - Method in class com.linkedin.venice.fastclient.transport.GrpcTransportClient
close() - Method in class com.linkedin.venice.fastclient.transport.R2TransportClient
close() - Method in class com.linkedin.venice.hadoop.AbstractVeniceMapper
close() - Method in class com.linkedin.venice.hadoop.DefaultInputDataInfoProvider
close() - Method in class com.linkedin.venice.hadoop.FilterChain
close() - Method in class com.linkedin.venice.hadoop.input.kafka.KafkaInputFormatCombiner
close() - Method in class com.linkedin.venice.hadoop.input.kafka.KafkaInputRecordReader
close() - Method in class com.linkedin.venice.hadoop.input.kafka.ttl.VeniceRmdTTLFilter
close() - Method in class com.linkedin.venice.hadoop.input.kafka.VeniceKafkaInputReducer
close() - Method in class com.linkedin.venice.hadoop.schema.HDFSRmdSchemaSource
close() - Method in class com.linkedin.venice.hadoop.ValidateSchemaAndBuildDictMapper
close() - Method in class com.linkedin.venice.hadoop.ValidateSchemaAndBuildDictMapperOutputReader
close() - Method in class com.linkedin.venice.hadoop.VeniceAvroRecordReader
close() - Method in class com.linkedin.venice.hadoop.VenicePushJob
close() - Method in class com.linkedin.venice.hadoop.VeniceReducer
close() - Method in class com.linkedin.venice.hadoop.VeniceReducer.DuplicateKeyPrinter
close() - Method in class com.linkedin.venice.hadoop.VeniceVsonRecordReader
close() - Method in class com.linkedin.venice.helix.ZkAllowlistAccessor
close() - Method in class com.linkedin.venice.httpclient.CachedDnsResolver
close() - Method in class com.linkedin.venice.kafka.partitionoffset.InstrumentedPartitionOffsetFetcher
close() - Method in interface com.linkedin.venice.kafka.partitionoffset.PartitionOffsetFetcher
close() - Method in class com.linkedin.venice.kafka.partitionoffset.PartitionOffsetFetcherImpl
close() - Method in class com.linkedin.venice.kafka.TopicManager
close() - Method in class com.linkedin.venice.kafka.TopicManagerRepository
close() - Method in class com.linkedin.venice.KafkaTopicDumper
close() - Method in class com.linkedin.venice.producer.AbstractVeniceProducer
close() - Method in class com.linkedin.venice.producer.online.OnlineVeniceProducer
close() - Method in class com.linkedin.venice.pubsub.adapter.kafka.admin.ApacheKafkaAdminAdapter
close() - Method in class com.linkedin.venice.pubsub.adapter.kafka.admin.ApacheKafkaAdminAdapterFactory
close() - Method in class com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerAdapter
close() - Method in class com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerAdapterFactory
close() - Method in class com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerAdapterFactory
close() - Method in class com.linkedin.venice.pubsub.adapter.PubSubSharedProducerFactory
close() - Method in interface com.linkedin.venice.pubsub.api.PubSubConsumerAdapter
close() - Method in class com.linkedin.venice.pubsub.api.PubSubInstrumentedAdminAdapter
close() - Method in class com.linkedin.venice.pulsar.sink.VenicePulsarSink
close() - Method in class com.linkedin.venice.pushmonitor.RouterBasedHybridStoreQuotaMonitor
close() - Method in class com.linkedin.venice.pushmonitor.RouterBasedPushMonitor
close() - Method in class com.linkedin.venice.pushstatushelper.PushStatusStoreReader
close() - Method in class com.linkedin.venice.pushstatushelper.PushStatusStoreRecordDeleter
close() - Method in class com.linkedin.venice.pushstatushelper.PushStatusStoreVeniceWriterCache
close() - Method in class com.linkedin.venice.pushstatushelper.PushStatusStoreWriter
close() - Method in class com.linkedin.venice.router.httpclient.ApacheHttpAsyncStorageNodeClient
close() - Method in class com.linkedin.venice.router.httpclient.HttpClient5StorageNodeClient
close() - Method in interface com.linkedin.venice.router.httpclient.StorageNodeClient: Close the client and release all resources held by the client
close() - Method in class com.linkedin.venice.samza.VeniceSystemProducer
close() - Method in class com.linkedin.venice.schema.SchemaRepoBackedSchemaReader
close() - Method in class com.linkedin.venice.serialization.avro.InternalAvroSpecificSerializer: Close this serializer.
close() - Method in class com.linkedin.venice.serialization.avro.VeniceAvroKafkaSerializer: Close this serializer.
close() - Method in class com.linkedin.venice.serialization.DefaultSerializer
close() - Method in class com.linkedin.venice.serialization.KafkaKeySerializer
close() - Method in class com.linkedin.venice.serialization.StringSerializer: Close this serializer.
close() - Method in interface com.linkedin.venice.serialization.VeniceKafkaSerializer: Close this serializer.
close() - Method in class com.linkedin.venice.service.AbstractVeniceService
close() - Method in class com.linkedin.venice.store.StoreStateReader
close() - Method in class com.linkedin.venice.system.store.ControllerClientBackedSystemSchemaInitializer
close() - Method in class com.linkedin.venice.system.store.MetaStoreReader
close() - Method in class com.linkedin.venice.system.store.MetaStoreWriter
close() - Method in class com.linkedin.venice.tehuti.MockTehutiReporter
close() - Method in class com.linkedin.venice.unit.kafka.consumer.MockInMemoryConsumer
close() - Method in class com.linkedin.venice.unit.kafka.MockInMemoryAdminAdapter
close() - Method in class com.linkedin.venice.utils.concurrent.CloseableThreadLocal: Clean up the resources held by this object.
close() - Method in class com.linkedin.venice.utils.locks.AutoCloseableLock: N.B.
close() - Method in class com.linkedin.venice.utils.ReferenceCounted
close() - Method in interface com.linkedin.venice.utils.Timer
close() - Method in class com.linkedin.venice.views.VeniceView
close() - Method in class com.linkedin.venice.writer.VeniceWriter
close(boolean) - Method in class com.linkedin.venice.writer.AbstractVeniceWriter
close(boolean) - Method in class com.linkedin.venice.writer.VeniceWriter: Close the VeniceWriter
close(int, boolean) - Method in class com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerAdapter
close(int, boolean) - Method in class com.linkedin.venice.pubsub.adapter.PubSubSharedProducerAdapter
close(int, boolean) - Method in interface com.linkedin.venice.pubsub.api.PubSubProducerAdapter
close(int, boolean) - Method in class com.linkedin.venice.unit.kafka.producer.MockInMemoryProducerAdapter
close(int, boolean) - Method in class com.linkedin.venice.unit.kafka.producer.TransformingProducerAdapter
close(long) - Method in interface com.linkedin.alpini.base.monitoring.CallCompletion
close(ChannelHandlerContext, ChannelPromise) - Method in class com.linkedin.alpini.netty4.handlers.Log4J2LoggingHandler
close(ChannelHandlerContext, ChannelPromise) - Method in class com.linkedin.alpini.netty4.handlers.ReverseHandler
close(String) - Method in interface com.linkedin.alpini.netty4.pool.ChannelPoolManager: Close the connection pool to the specified host and port.
close(String) - Method in class com.linkedin.alpini.netty4.pool.ChannelPoolManagerImpl
close(String) - Method in class com.linkedin.alpini.netty4.pool.SimpleChannelPoolManagerImpl
close(String, int) - Method in class com.linkedin.venice.pubsub.adapter.PubSubSharedProducerAdapter
close(String, int) - Method in interface com.linkedin.venice.pubsub.api.PubSubProducerAdapter
close(String, int, boolean) - Method in class com.linkedin.venice.pubsub.adapter.PubSubSharedProducerAdapter
close(String, int, boolean) - Method in interface com.linkedin.venice.pubsub.api.PubSubProducerAdapter
CLOSE - com.linkedin.venice.stats.PubSubAdminWrapperStats.OCCURRENCE_LATENCY_SENSOR_TYPE
CLOSE_TIMEOUT_MS - Static variable in class com.linkedin.venice.writer.VeniceWriter
CloseableThreadLocal<T extends java.lang.AutoCloseable> - Class in com.linkedin.venice.utils.concurrent: A wrapper of ThreadLocal for AutoCloseable objects.
CloseableThreadLocal(Supplier<T>) - Constructor for class com.linkedin.venice.utils.concurrent.CloseableThreadLocal: Creates a closeable thread local.
closeAfterContinueResponse(Object) - Method in class com.linkedin.alpini.netty4.handlers.HttpMultiPartContentAggregator
closeAfterContinueResponse(Object) - Method in class io.netty.handler.codec.EspressoMessageAggregator: Determine if the channel should be closed after the result of EspressoMessageAggregator.newContinueResponse(Object, int, ChannelPipeline) is written.
closeAfterContinueResponse(Object) - Method in class io.netty.handler.codec.http.EspressoHttpObjectAggregator
closeAll() - Method in interface com.linkedin.alpini.netty4.pool.ChannelPoolManager: Close all open connections.
closeAll() - Method in class com.linkedin.alpini.netty4.pool.ChannelPoolManagerImpl
closeAll() - Method in class com.linkedin.alpini.netty4.pool.SimpleChannelPoolManagerImpl
closeAllStorageEngines() - Method in class com.linkedin.davinci.storage.StorageService
closeAsync() - Method in class com.linkedin.alpini.netty4.pool.EspressoFixedChannelPool: Closes the pool in an async manner.
closeAsync() - Method in class com.linkedin.alpini.netty4.pool.FastFixedChannelPool: Closes the pool in an async manner.
closeBadCount() - Method in interface com.linkedin.alpini.netty4.pool.ChannelPoolManager.PoolStats
closeChannel(Channel) - Static method in class com.linkedin.alpini.netty4.pool.FastSimpleChannelPool
closeCompletion(long, T, Throwable) - Method in interface com.linkedin.alpini.base.monitoring.CallCompletion
closeCompletion(T, Throwable) - Method in interface com.linkedin.alpini.base.monitoring.CallCompletion
closeCount() - Method in interface com.linkedin.alpini.netty4.pool.ChannelPoolManager.PoolStats
closed - Variable in class com.linkedin.davinci.client.factory.CachingDaVinciClientFactory
closeErrorCount() - Method in interface com.linkedin.alpini.netty4.pool.ChannelPoolManager.PoolStats
closeFuture() - Method in class com.linkedin.alpini.netty4.pool.FixedChannelPoolImpl
closeFuture() - Method in class com.linkedin.alpini.netty4.pool.FixedFastChannelPoolImpl
closeFuture() - Method in class com.linkedin.alpini.netty4.pool.Http2AwareChannelPool
closeFuture() - Method in interface com.linkedin.alpini.netty4.pool.ManagedChannelPool
closeMetadataPartition() - Method in class com.linkedin.davinci.store.AbstractStorageEngine
closePartition(int) - Method in class com.linkedin.davinci.store.AbstractStorageEngine
closePartition(int) - Method in class com.linkedin.venice.writer.VeniceWriter: Close a single partition from this writer.
closeQuietly(Closeable) - Static method in enum com.linkedin.alpini.io.IOUtils
closeQuietly(Connection) - Static method in enum com.linkedin.alpini.base.misc.JDBCUtils
closeQuietly(ResultSet) - Static method in enum com.linkedin.alpini.base.misc.JDBCUtils
closeQuietly(Statement) - Static method in enum com.linkedin.alpini.base.misc.JDBCUtils
closeQuietlyWithErrorLogged(Closeable...) - Static method in class com.linkedin.venice.utils.Utils
closeStorageEngine(AbstractStorageEngine) - Method in class com.linkedin.davinci.store.blackhole.BlackHoleStorageEngineFactory
closeStorageEngine(AbstractStorageEngine) - Method in class com.linkedin.davinci.store.memory.InMemoryStorageEngineFactory
closeStorageEngine(AbstractStorageEngine) - Method in class com.linkedin.davinci.store.rocksdb.RocksDBStorageEngineFactory
closeStorageEngine(AbstractStorageEngine) - Method in class com.linkedin.davinci.store.StorageEngineFactory: Close the storage engine from the underlying storage configuration
closeStorageEngine(String) - Method in class com.linkedin.davinci.storage.StorageService
closeStorePartition(VeniceStoreVersionConfig, int) - Method in class com.linkedin.davinci.storage.StorageService
closeStreamChannel(Http2StreamChannel) - Static method in class com.linkedin.alpini.netty4.misc.Http2Utils
closeVeniceViewWriters() - Method in class com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask
closeVeniceViewWriters() - Method in class com.linkedin.davinci.kafka.consumer.StoreIngestionTask
closeVeniceWriters(boolean) - Method in class com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask
closeVeniceWriters(boolean) - Method in class com.linkedin.davinci.kafka.consumer.StoreIngestionTask
closeWithError() - Method in interface com.linkedin.alpini.base.monitoring.CallCompletion
closeWithError(long) - Method in interface com.linkedin.alpini.base.monitoring.CallCompletion
closeWithError(long, Throwable) - Method in interface com.linkedin.alpini.base.monitoring.CallCompletion
closeWithError(Throwable) - Method in interface com.linkedin.alpini.base.monitoring.CallCompletion
cluster - Variable in class com.linkedin.venice.systemstore.schemas.StoreClusterConfig: The Venice cluster of the store.
CLUSTER - com.linkedin.venice.Arg
CLUSTER - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
CLUSTER_DEST - com.linkedin.venice.Arg
CLUSTER_DEST - Static variable in class com.linkedin.venice.controllerapi.ControllerApiConstants
CLUSTER_DISCOVERY - com.linkedin.venice.controllerapi.ControllerRoute
CLUSTER_DISCOVERY_D2_SERVICE - Static variable in class com.linkedin.venice.ConfigKeys: D2 Service name for cluster discovery
ClUSTER_HEALTH_INSTANCES - com.linkedin.venice.controllerapi.ControllerRoute
CLUSTER_HEALTH_INSTANCES - com.linkedin.venice.Command
CLUSTER_HEALTH_STORES - com.linkedin.venice.Command
CLUSTER_HEALTH_STORES - com.linkedin.venice.controllerapi.ControllerRoute
CLUSTER_NAME - Static variable in class com.linkedin.venice.ConfigKeys
CLUSTER_PROPERTIES_FILE - Static variable in class com.linkedin.davinci.config.VeniceConfigLoader
CLUSTER_SRC - com.linkedin.venice.Arg
CLUSTER_TO_D2 - Static variable in class com.linkedin.venice.ConfigKeys
CLUSTER_TO_SERVER_D2 - Static variable in class com.linkedin.venice.ConfigKeys
clusterConfigZkPath - Variable in class com.linkedin.venice.helix.HelixReadOnlyLiveClusterConfigRepository
ClusterDiscovery - Class in com.linkedin.venice.controller.server
ClusterDiscovery() - Constructor for class com.linkedin.venice.controller.server.ClusterDiscovery
ClusterInfoProvider - Interface in com.linkedin.venice.meta
ClusterLeaderInitializationManager - Class in com.linkedin.venice.controller.init: Takes care of executing each routine once per cluster.
ClusterLeaderInitializationManager(List<ClusterLeaderInitializationRoutine>, boolean) - Constructor for class com.linkedin.venice.controller.init.ClusterLeaderInitializationManager
ClusterLeaderInitializationRoutine - Interface in com.linkedin.venice.controller.init: This class encapsulates business logic which needs to be executed once per cluster the first time a controller becomes leader of that cluster.
clusterLockManager - Variable in class com.linkedin.venice.helix.CachedReadOnlyStoreRepository
ClusterLockManager - Class in com.linkedin.venice.utils.locks: A centralized place to control the locking behavior, such as lock order and lock granularity.
ClusterLockManager(String) - Constructor for class com.linkedin.venice.utils.locks.ClusterLockManager
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.AddVersion
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.ConfigureActiveActiveReplicationForCluster
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.ConfigureIncrementalPushForCluster
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.ConfigureNativeReplicationForCluster
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.CreateStoragePersona
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.DeleteAllVersions
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.DeleteOldVersion
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.DeleteStoragePersona
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.DeleteStore
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.DerivedSchemaCreation
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.DisableStoreRead
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.EnableStoreRead
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.KillOfflinePushJob
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.MetadataSchemaCreation
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.MetaSystemStoreAutoCreationValidation
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.PauseStore
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.PushStatusSystemStoreAutoCreationValidation
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.ResumeStore
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.SetStoreCurrentVersion
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.SetStoreOwner
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.SetStorePartitionCount
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.StoreCreation
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.SupersetSchemaCreation
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.UpdateStoragePersona
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.UpdateStore
clusterName - Variable in class com.linkedin.venice.controller.kafka.protocol.admin.ValueSchemaCreation
clusterName - Variable in class com.linkedin.venice.helix.CachedReadOnlyStoreRepository
clusterName - Variable in class com.linkedin.venice.status.protocol.PushJobDetails
ClusterRoutes - Class in com.linkedin.venice.controller.server
ClusterRoutes(boolean, Optional<DynamicAccessController>) - Constructor for class com.linkedin.venice.controller.server.ClusterRoutes
ClusterStaleDataAuditResponse - Class in com.linkedin.venice.controllerapi
ClusterStaleDataAuditResponse() - Constructor for class com.linkedin.venice.controllerapi.ClusterStaleDataAuditResponse
ClusterStats - Class in com.linkedin.venice.fastclient.stats: This class includes the metrics in the cluster-level.
ClusterStats(MetricsRepository, String) - Constructor for class com.linkedin.venice.fastclient.stats.ClusterStats
clusterStoreRepositoryPath - Variable in class com.linkedin.venice.helix.CachedReadOnlyStoreRepository
code - Variable in enum com.linkedin.venice.stats.StatsErrorCode
code() - Method in exception com.linkedin.alpini.base.misc.ExceptionWithStatus
collect(List<AsyncFuture<List<T>>>, boolean) - Static method in interface com.linkedin.alpini.base.concurrency.AsyncFuture
COLLECTION_TS_ARRAY_SCHEMA - Static variable in class com.linkedin.venice.schema.rmd.v1.CollectionRmdTimestamp
CollectionFieldOperationHandler - Class in com.linkedin.davinci.schema.merge: This class handles all operations on a collection field with replication metadata.
CollectionFieldOperationHandler(AvroCollectionElementComparator) - Constructor for class com.linkedin.davinci.schema.merge.CollectionFieldOperationHandler
CollectionRmdTimestamp<DELETED_ELEMENT_TYPE> - Class in com.linkedin.venice.schema.rmd.v1: This class centralizes the logic of creating a collection replication metadata schema and providing a POJO representation upon a collection replication metadata generic record.
CollectionRmdTimestamp(CollectionRmdTimestamp) - Constructor for class com.linkedin.venice.schema.rmd.v1.CollectionRmdTimestamp
CollectionRmdTimestamp(GenericRecord) - Constructor for class com.linkedin.venice.schema.rmd.v1.CollectionRmdTimestamp
CollectionTimestampMergeRecordHelper - Class in com.linkedin.davinci.schema.merge: This class handles merges with replication metadata with collection metadata timestamp CollectionRmdTimestamp for collection field.
CollectionTimestampMergeRecordHelper() - Constructor for class com.linkedin.davinci.schema.merge.CollectionTimestampMergeRecordHelper
CollectionUtil - Enum in com.linkedin.alpini.base.misc
CollectionUtil.ListBuilder<T> - Class in com.linkedin.alpini.base.misc
CollectionUtil.MapBuilder<K,V> - Class in com.linkedin.alpini.base.misc
CollectionUtil.SetBuilder<T> - Class in com.linkedin.alpini.base.misc
CollectionUtils - Class in com.linkedin.venice.utils
CollectionUtils() - Constructor for class com.linkedin.venice.utils.CollectionUtils
collector() - Method in class com.linkedin.alpini.base.statistics.AbstractQuantileEstimation
COLLECTOR - Static variable in class com.linkedin.alpini.base.statistics.Welfords.DoubleWelford
COLLECTOR - Static variable in class com.linkedin.alpini.base.statistics.Welfords.LongWelford
coloStatus - Variable in class com.linkedin.venice.status.protocol.PushJobDetails
columnFamilyDescriptors - Variable in class com.linkedin.davinci.store.rocksdb.RocksDBStoragePartition
columnFamilyHandleList - Variable in class com.linkedin.davinci.store.rocksdb.RocksDBStoragePartition: Column Family is the concept in RocksDB to create isolation between different value for the same key.
com.linkedin.alpini.base.cache - package com.linkedin.alpini.base.cache
com.linkedin.alpini.base.concurrency - package com.linkedin.alpini.base.concurrency
com.linkedin.alpini.base.concurrency.impl - package com.linkedin.alpini.base.concurrency.impl
com.linkedin.alpini.base.hash - package com.linkedin.alpini.base.hash
com.linkedin.alpini.base.misc - package com.linkedin.alpini.base.misc
com.linkedin.alpini.base.monitoring - package com.linkedin.alpini.base.monitoring
com.linkedin.alpini.base.pool - package com.linkedin.alpini.base.pool
com.linkedin.alpini.base.pool.impl - package com.linkedin.alpini.base.pool.impl
com.linkedin.alpini.base.queuing - package com.linkedin.alpini.base.queuing
com.linkedin.alpini.base.registry - package com.linkedin.alpini.base.registry
com.linkedin.alpini.base.registry.impl - package com.linkedin.alpini.base.registry.impl
com.linkedin.alpini.base.safealloc - package com.linkedin.alpini.base.safealloc
com.linkedin.alpini.base.ssl - package com.linkedin.alpini.base.ssl
com.linkedin.alpini.base.statistics - package com.linkedin.alpini.base.statistics
com.linkedin.alpini.base.test - package com.linkedin.alpini.base.test
com.linkedin.alpini.cli - package com.linkedin.alpini.cli
com.linkedin.alpini.consts - package com.linkedin.alpini.consts: Package exclusively for constants and enums.
com.linkedin.alpini.consts.config - package com.linkedin.alpini.consts.config
com.linkedin.alpini.io - package com.linkedin.alpini.io
com.linkedin.alpini.io.ssl - package com.linkedin.alpini.io.ssl
com.linkedin.alpini.jna - package com.linkedin.alpini.jna
com.linkedin.alpini.log - package com.linkedin.alpini.log
com.linkedin.alpini.netty4.compression - package com.linkedin.alpini.netty4.compression
com.linkedin.alpini.netty4.handlers - package com.linkedin.alpini.netty4.handlers
com.linkedin.alpini.netty4.http2 - package com.linkedin.alpini.netty4.http2
com.linkedin.alpini.netty4.misc - package com.linkedin.alpini.netty4.misc
com.linkedin.alpini.netty4.pool - package com.linkedin.alpini.netty4.pool
com.linkedin.alpini.netty4.ssl - package com.linkedin.alpini.netty4.ssl
com.linkedin.alpini.router - package com.linkedin.alpini.router
com.linkedin.alpini.router.api - package com.linkedin.alpini.router.api
com.linkedin.alpini.router.impl - package com.linkedin.alpini.router.impl
com.linkedin.alpini.router.impl.netty4 - package com.linkedin.alpini.router.impl.netty4
com.linkedin.alpini.router.monitoring - package com.linkedin.alpini.router.monitoring
com.linkedin.avro.fastserde - package com.linkedin.avro.fastserde
com.linkedin.davinci - package com.linkedin.davinci
com.linkedin.davinci.callback - package com.linkedin.davinci.callback
com.linkedin.davinci.client - package com.linkedin.davinci.client
com.linkedin.davinci.client.factory - package com.linkedin.davinci.client.factory
com.linkedin.davinci.compression - package com.linkedin.davinci.compression
com.linkedin.davinci.config - package com.linkedin.davinci.config
com.linkedin.davinci.consumer - package com.linkedin.davinci.consumer
com.linkedin.davinci.helix - package com.linkedin.davinci.helix
com.linkedin.davinci.ingestion - package com.linkedin.davinci.ingestion
com.linkedin.davinci.ingestion.consumption - package com.linkedin.davinci.ingestion.consumption
com.linkedin.davinci.ingestion.consumption.kafka - package com.linkedin.davinci.ingestion.consumption.kafka
com.linkedin.davinci.ingestion.isolated - package com.linkedin.davinci.ingestion.isolated
com.linkedin.davinci.ingestion.main - package com.linkedin.davinci.ingestion.main
com.linkedin.davinci.ingestion.utils - package com.linkedin.davinci.ingestion.utils
com.linkedin.davinci.kafka.consumer - package com.linkedin.davinci.kafka.consumer
com.linkedin.davinci.listener.response - package com.linkedin.davinci.listener.response
com.linkedin.davinci.notifier - package com.linkedin.davinci.notifier
com.linkedin.davinci.replication - package com.linkedin.davinci.replication
com.linkedin.davinci.replication.merge - package com.linkedin.davinci.replication.merge
com.linkedin.davinci.repository - package com.linkedin.davinci.repository
com.linkedin.davinci.schema - package com.linkedin.davinci.schema
com.linkedin.davinci.schema.merge - package com.linkedin.davinci.schema.merge
com.linkedin.davinci.schema.writecompute - package com.linkedin.davinci.schema.writecompute
com.linkedin.davinci.serializer.avro - package com.linkedin.davinci.serializer.avro
com.linkedin.davinci.stats - package com.linkedin.davinci.stats
com.linkedin.davinci.storage - package com.linkedin.davinci.storage
com.linkedin.davinci.storage.chunking - package com.linkedin.davinci.storage.chunking
com.linkedin.davinci.store - package com.linkedin.davinci.store
com.linkedin.davinci.store.blackhole - package com.linkedin.davinci.store.blackhole
com.linkedin.davinci.store.cache - package com.linkedin.davinci.store.cache
com.linkedin.davinci.store.cache.backend - package com.linkedin.davinci.store.cache.backend
com.linkedin.davinci.store.cache.caffeine - package com.linkedin.davinci.store.cache.caffeine
com.linkedin.davinci.store.memory - package com.linkedin.davinci.store.memory
com.linkedin.davinci.store.record - package com.linkedin.davinci.store.record
com.linkedin.davinci.store.rocksdb - package com.linkedin.davinci.store.rocksdb
com.linkedin.davinci.store.view - package com.linkedin.davinci.store.view
com.linkedin.davinci.utils - package com.linkedin.davinci.utils
com.linkedin.davinci.validation - package com.linkedin.davinci.validation
com.linkedin.venice - package com.linkedin.venice
com.linkedin.venice.acl - package com.linkedin.venice.acl
com.linkedin.venice.acl.handler - package com.linkedin.venice.acl.handler
com.linkedin.venice.admin - package com.linkedin.venice.admin
com.linkedin.venice.admin.protocol.response - package com.linkedin.venice.admin.protocol.response
com.linkedin.venice.annotation - package com.linkedin.venice.annotation
com.linkedin.venice.authorization - package com.linkedin.venice.authorization
com.linkedin.venice.chunking - package com.linkedin.venice.chunking
com.linkedin.venice.cleaner - package com.linkedin.venice.cleaner
com.linkedin.venice.client - package com.linkedin.venice.client
com.linkedin.venice.client.change.capture.protocol - package com.linkedin.venice.client.change.capture.protocol
com.linkedin.venice.client.exceptions - package com.linkedin.venice.client.exceptions
com.linkedin.venice.client.factory - package com.linkedin.venice.client.factory
com.linkedin.venice.client.schema - package com.linkedin.venice.client.schema
com.linkedin.venice.client.stats - package com.linkedin.venice.client.stats
com.linkedin.venice.client.store - package com.linkedin.venice.client.store
com.linkedin.venice.client.store.deserialization - package com.linkedin.venice.client.store.deserialization
com.linkedin.venice.client.store.predicate - package com.linkedin.venice.client.store.predicate
com.linkedin.venice.client.store.schemas - package com.linkedin.venice.client.store.schemas
com.linkedin.venice.client.store.streaming - package com.linkedin.venice.client.store.streaming
com.linkedin.venice.client.store.transport - package com.linkedin.venice.client.store.transport
com.linkedin.venice.client.utils - package com.linkedin.venice.client.utils
com.linkedin.venice.common - package com.linkedin.venice.common
com.linkedin.venice.compression - package com.linkedin.venice.compression
com.linkedin.venice.compression.protocol - package com.linkedin.venice.compression.protocol
com.linkedin.venice.compute - package com.linkedin.venice.compute
com.linkedin.venice.compute.protocol.request - package com.linkedin.venice.compute.protocol.request
com.linkedin.venice.compute.protocol.request.enums - package com.linkedin.venice.compute.protocol.request.enums
com.linkedin.venice.compute.protocol.request.router - package com.linkedin.venice.compute.protocol.request.router
com.linkedin.venice.compute.protocol.response - package com.linkedin.venice.compute.protocol.response
com.linkedin.venice.controller - package com.linkedin.venice.controller
com.linkedin.venice.controller.authorization - package com.linkedin.venice.controller.authorization
com.linkedin.venice.controller.datarecovery - package com.linkedin.venice.controller.datarecovery
com.linkedin.venice.controller.exception - package com.linkedin.venice.controller.exception
com.linkedin.venice.controller.helix - package com.linkedin.venice.controller.helix
com.linkedin.venice.controller.init - package com.linkedin.venice.controller.init
com.linkedin.venice.controller.kafka - package com.linkedin.venice.controller.kafka
com.linkedin.venice.controller.kafka.consumer - package com.linkedin.venice.controller.kafka.consumer
com.linkedin.venice.controller.kafka.protocol.admin - package com.linkedin.venice.controller.kafka.protocol.admin
com.linkedin.venice.controller.kafka.protocol.enums - package com.linkedin.venice.controller.kafka.protocol.enums
com.linkedin.venice.controller.kafka.protocol.serializer - package com.linkedin.venice.controller.kafka.protocol.serializer
com.linkedin.venice.controller.lingeringjob - package com.linkedin.venice.controller.lingeringjob
com.linkedin.venice.controller.migration - package com.linkedin.venice.controller.migration
com.linkedin.venice.controller.server - package com.linkedin.venice.controller.server
com.linkedin.venice.controller.spark - package com.linkedin.venice.controller.spark
com.linkedin.venice.controller.stats - package com.linkedin.venice.controller.stats
com.linkedin.venice.controller.supersetschema - package com.linkedin.venice.controller.supersetschema
com.linkedin.venice.controller.systemstore - package com.linkedin.venice.controller.systemstore
com.linkedin.venice.controllerapi - package com.linkedin.venice.controllerapi
com.linkedin.venice.controllerapi.routes - package com.linkedin.venice.controllerapi.routes
com.linkedin.venice.d2 - package com.linkedin.venice.d2
com.linkedin.venice.D2 - package com.linkedin.venice.D2
com.linkedin.venice.datarecovery - package com.linkedin.venice.datarecovery
com.linkedin.venice.datarecovery.meta - package com.linkedin.venice.datarecovery.meta
com.linkedin.venice.etl - package com.linkedin.venice.etl
com.linkedin.venice.exceptions - package com.linkedin.venice.exceptions
com.linkedin.venice.exceptions.validation - package com.linkedin.venice.exceptions.validation
com.linkedin.venice.fastclient - package com.linkedin.venice.fastclient
com.linkedin.venice.fastclient.factory - package com.linkedin.venice.fastclient.factory
com.linkedin.venice.fastclient.meta - package com.linkedin.venice.fastclient.meta
com.linkedin.venice.fastclient.stats - package com.linkedin.venice.fastclient.stats
com.linkedin.venice.fastclient.transport - package com.linkedin.venice.fastclient.transport
com.linkedin.venice.fastclient.utils - package com.linkedin.venice.fastclient.utils
com.linkedin.venice.grpc - package com.linkedin.venice.grpc
com.linkedin.venice.guid - package com.linkedin.venice.guid
com.linkedin.venice.hadoop - package com.linkedin.venice.hadoop
com.linkedin.venice.hadoop.exceptions - package com.linkedin.venice.hadoop.exceptions
com.linkedin.venice.hadoop.heartbeat - package com.linkedin.venice.hadoop.heartbeat
com.linkedin.venice.hadoop.input.kafka - package com.linkedin.venice.hadoop.input.kafka
com.linkedin.venice.hadoop.input.kafka.avro - package com.linkedin.venice.hadoop.input.kafka.avro
com.linkedin.venice.hadoop.input.kafka.chunk - package com.linkedin.venice.hadoop.input.kafka.chunk
com.linkedin.venice.hadoop.input.kafka.ttl - package com.linkedin.venice.hadoop.input.kafka.ttl
com.linkedin.venice.hadoop.output.avro - package com.linkedin.venice.hadoop.output.avro
com.linkedin.venice.hadoop.schema - package com.linkedin.venice.hadoop.schema
com.linkedin.venice.hadoop.ssl - package com.linkedin.venice.hadoop.ssl
com.linkedin.venice.hadoop.utils - package com.linkedin.venice.hadoop.utils
com.linkedin.venice.hadoop.validation - package com.linkedin.venice.hadoop.validation
com.linkedin.venice.helix - package com.linkedin.venice.helix
com.linkedin.venice.httpclient - package com.linkedin.venice.httpclient
com.linkedin.venice.httpclient5 - package com.linkedin.venice.httpclient5
com.linkedin.venice.ingestion.control - package com.linkedin.venice.ingestion.control
com.linkedin.venice.ingestion.protocol - package com.linkedin.venice.ingestion.protocol
com.linkedin.venice.ingestion.protocol.enums - package com.linkedin.venice.ingestion.protocol.enums
com.linkedin.venice.io - package com.linkedin.venice.io
com.linkedin.venice.kafka - package com.linkedin.venice.kafka
com.linkedin.venice.kafka.partitionoffset - package com.linkedin.venice.kafka.partitionoffset
com.linkedin.venice.kafka.protocol - package com.linkedin.venice.kafka.protocol
com.linkedin.venice.kafka.protocol.enums - package com.linkedin.venice.kafka.protocol.enums
com.linkedin.venice.kafka.protocol.state - package com.linkedin.venice.kafka.protocol.state
com.linkedin.venice.kafka.validation - package com.linkedin.venice.kafka.validation
com.linkedin.venice.kafka.validation.checksum - package com.linkedin.venice.kafka.validation.checksum
com.linkedin.venice.listener - package com.linkedin.venice.listener
com.linkedin.venice.listener.grpc - package com.linkedin.venice.listener.grpc
com.linkedin.venice.listener.grpc.handlers - package com.linkedin.venice.listener.grpc.handlers
com.linkedin.venice.listener.request - package com.linkedin.venice.listener.request
com.linkedin.venice.listener.response - package com.linkedin.venice.listener.response
com.linkedin.venice.message - package com.linkedin.venice.message
com.linkedin.venice.meta - package com.linkedin.venice.meta
com.linkedin.venice.meta.systemstore.schemas - package com.linkedin.venice.meta.systemstore.schemas
com.linkedin.venice.metadata.response - package com.linkedin.venice.metadata.response
com.linkedin.venice.migration - package com.linkedin.venice.migration
com.linkedin.venice.offsets - package com.linkedin.venice.offsets
com.linkedin.venice.participant.protocol - package com.linkedin.venice.participant.protocol
com.linkedin.venice.participant.protocol.enums - package com.linkedin.venice.participant.protocol.enums
com.linkedin.venice.partitioner - package com.linkedin.venice.partitioner
com.linkedin.venice.persona - package com.linkedin.venice.persona
com.linkedin.venice.producer - package com.linkedin.venice.producer
com.linkedin.venice.producer.online - package com.linkedin.venice.producer.online
com.linkedin.venice.protocols - package com.linkedin.venice.protocols
com.linkedin.venice.pubsub - package com.linkedin.venice.pubsub
com.linkedin.venice.pubsub.adapter - package com.linkedin.venice.pubsub.adapter
com.linkedin.venice.pubsub.adapter.kafka - package com.linkedin.venice.pubsub.adapter.kafka
com.linkedin.venice.pubsub.adapter.kafka.admin - package com.linkedin.venice.pubsub.adapter.kafka.admin
com.linkedin.venice.pubsub.adapter.kafka.consumer - package com.linkedin.venice.pubsub.adapter.kafka.consumer
com.linkedin.venice.pubsub.adapter.kafka.producer - package com.linkedin.venice.pubsub.adapter.kafka.producer
com.linkedin.venice.pubsub.api - package com.linkedin.venice.pubsub.api
com.linkedin.venice.pubsub.api.exceptions - package com.linkedin.venice.pubsub.api.exceptions
com.linkedin.venice.pulsar.sink - package com.linkedin.venice.pulsar.sink
com.linkedin.venice.pushmonitor - package com.linkedin.venice.pushmonitor
com.linkedin.venice.pushstatus - package com.linkedin.venice.pushstatus
com.linkedin.venice.pushstatushelper - package com.linkedin.venice.pushstatushelper
com.linkedin.venice.read - package com.linkedin.venice.read
com.linkedin.venice.read.protocol.request.router - package com.linkedin.venice.read.protocol.request.router
com.linkedin.venice.read.protocol.response - package com.linkedin.venice.read.protocol.response
com.linkedin.venice.read.protocol.response.streaming - package com.linkedin.venice.read.protocol.response.streaming
com.linkedin.venice.request - package com.linkedin.venice.request
com.linkedin.venice.router - package com.linkedin.venice.router
com.linkedin.venice.router.api - package com.linkedin.venice.router.api
com.linkedin.venice.router.api.path - package com.linkedin.venice.router.api.path
com.linkedin.venice.router.api.routing.helix - package com.linkedin.venice.router.api.routing.helix
com.linkedin.venice.router.exception - package com.linkedin.venice.router.exception
com.linkedin.venice.router.httpclient - package com.linkedin.venice.router.httpclient
com.linkedin.venice.router.stats - package com.linkedin.venice.router.stats
com.linkedin.venice.router.streaming - package com.linkedin.venice.router.streaming
com.linkedin.venice.router.throttle - package com.linkedin.venice.router.throttle
com.linkedin.venice.router.utils - package com.linkedin.venice.router.utils
com.linkedin.venice.routerapi - package com.linkedin.venice.routerapi
com.linkedin.venice.samza - package com.linkedin.venice.samza
com.linkedin.venice.schema - package com.linkedin.venice.schema
com.linkedin.venice.schema.avro - package com.linkedin.venice.schema.avro
com.linkedin.venice.schema.rmd - package com.linkedin.venice.schema.rmd
com.linkedin.venice.schema.rmd.v1 - package com.linkedin.venice.schema.rmd.v1
com.linkedin.venice.schema.vson - package com.linkedin.venice.schema.vson
com.linkedin.venice.schema.writecompute - package com.linkedin.venice.schema.writecompute
com.linkedin.venice.security - package com.linkedin.venice.security
com.linkedin.venice.serialization - package com.linkedin.venice.serialization
com.linkedin.venice.serialization.avro - package com.linkedin.venice.serialization.avro
com.linkedin.venice.serializer - package com.linkedin.venice.serializer
com.linkedin.venice.server - package com.linkedin.venice.server
com.linkedin.venice.service - package com.linkedin.venice.service
com.linkedin.venice.servicediscovery - package com.linkedin.venice.servicediscovery
com.linkedin.venice.standalone - package com.linkedin.venice.standalone
com.linkedin.venice.stats - package com.linkedin.venice.stats
com.linkedin.venice.status - package com.linkedin.venice.status
com.linkedin.venice.status.protocol - package com.linkedin.venice.status.protocol
com.linkedin.venice.status.protocol.enums - package com.linkedin.venice.status.protocol.enums
com.linkedin.venice.storage.protocol - package com.linkedin.venice.storage.protocol
com.linkedin.venice.store - package com.linkedin.venice.store
com.linkedin.venice.store.exception - package com.linkedin.venice.store.exception
com.linkedin.venice.store.rocksdb - package com.linkedin.venice.store.rocksdb
com.linkedin.venice.streaming - package com.linkedin.venice.streaming
com.linkedin.venice.system.store - package com.linkedin.venice.system.store
com.linkedin.venice.systemstore.schemas - package com.linkedin.venice.systemstore.schemas
com.linkedin.venice.tehuti - package com.linkedin.venice.tehuti
com.linkedin.venice.testng - package com.linkedin.venice.testng
com.linkedin.venice.throttle - package com.linkedin.venice.throttle
com.linkedin.venice.unit.kafka - package com.linkedin.venice.unit.kafka
com.linkedin.venice.unit.kafka.consumer - package com.linkedin.venice.unit.kafka.consumer
com.linkedin.venice.unit.kafka.consumer.poll - package com.linkedin.venice.unit.kafka.consumer.poll
com.linkedin.venice.unit.kafka.producer - package com.linkedin.venice.unit.kafka.producer
com.linkedin.venice.unit.matchers - package com.linkedin.venice.unit.matchers
com.linkedin.venice.utils - package com.linkedin.venice.utils
com.linkedin.venice.utils.collections - package com.linkedin.venice.utils.collections
com.linkedin.venice.utils.concurrent - package com.linkedin.venice.utils.concurrent
com.linkedin.venice.utils.lazy - package com.linkedin.venice.utils.lazy
com.linkedin.venice.utils.locks - package com.linkedin.venice.utils.locks
com.linkedin.venice.utils.pools - package com.linkedin.venice.utils.pools
com.linkedin.venice.views - package com.linkedin.venice.views
com.linkedin.venice.writer - package com.linkedin.venice.writer
com.linkedin.venice.writer.update - package com.linkedin.venice.writer.update
combine(CallCompletion...) - Static method in interface com.linkedin.alpini.base.monitoring.CallCompletion
combine(AbstractQuantileEstimation.Data) - Method in class com.linkedin.alpini.base.statistics.LongStatsAggregator.LongData
command() - Method in class com.linkedin.alpini.io.SubprocessBuilder
command(String...) - Method in class com.linkedin.alpini.io.SubprocessBuilder
command(List<String>) - Method in class com.linkedin.alpini.io.SubprocessBuilder
Command - Class in com.linkedin.venice.datarecovery
Command - Enum in com.linkedin.venice: TODO: Merge this with ControllerRoute
Command() - Constructor for class com.linkedin.venice.datarecovery.Command
COMMAND - com.linkedin.venice.ingestion.protocol.enums.IngestionAction
Command.Params - Class in com.linkedin.venice.datarecovery
Command.Result - Class in com.linkedin.venice.datarecovery
commandComparator - Static variable in enum com.linkedin.venice.Command
commandType - Variable in class com.linkedin.venice.ingestion.protocol.IngestionTaskCommand: 0 => StartConsumption, 1 => StopConsumption, 2 => KillConsumption, 3 => ResetConsumption, 4 => IsPartitionConsuming, 5 => RemoveStorageEngine, 6 => RemovePartition, 7 => OpenStorageEngine, 8 => PromoteToLeader, 9 => DemoteToStandby
CommonConfigKeys - Class in com.linkedin.venice: Common config keys shared by venice-backend and venice-thin-client.
CommonConfigKeys() - Constructor for class com.linkedin.venice.CommonConfigKeys
commonValidityCheck() - Method in class com.linkedin.venice.client.store.AbstractAvroComputeRequestBuilder: Compute operation validity check for projections, dot-product and cosine-similarity.
COMPACT_HEADER - Static variable in class com.linkedin.alpini.netty4.http2.CompactHeaderHandler
compactExceptionDescription(Throwable) - Static method in class com.linkedin.venice.utils.ExceptionUtils
compactExceptionDescription(Throwable, String) - Static method in class com.linkedin.venice.utils.ExceptionUtils
CompactHeaderHandler - Class in com.linkedin.alpini.netty4.http2: Handler for compacting Espresso headers to a single header entry.
CompactHeaderHandler(Class<?>, boolean) - Constructor for class com.linkedin.alpini.netty4.http2.CompactHeaderHandler: Constructor.
comparator() - Method in class com.linkedin.alpini.base.concurrency.ArraySortedSet
COMPARATOR - Static variable in interface org.apache.avro.generic.DeterministicMapOrderDatumWriter
compare(byte[], byte[]) - Static method in class com.linkedin.venice.utils.ByteUtils: A comparator for byte arrays.
compare(byte[], int, int, byte[], int, int) - Method in class com.linkedin.venice.hadoop.input.kafka.KafkaInputKeyComparator
compare(DoubleQuantileEstimation.Sample, DoubleQuantileEstimation.Sample) - Method in class com.linkedin.alpini.base.statistics.DoubleQuantileEstimation
compare(GenericQuantileEstimation.Sample<T>, GenericQuantileEstimation.Sample<T>) - Method in class com.linkedin.alpini.base.statistics.GenericQuantileEstimation
compare(LongQuantileEstimation.Sample, LongQuantileEstimation.Sample) - Method in class com.linkedin.alpini.base.statistics.LongQuantileEstimation
compare(KafkaInputMapperKey, KafkaInputMapperKey) - Method in class com.linkedin.venice.hadoop.input.kafka.KafkaInputKeyComparator
compare(KafkaInputMapperKey, KafkaInputMapperKey) - Method in class com.linkedin.venice.hadoop.input.kafka.KafkaInputValueGroupingComparator
compare(Object, Object) - Static method in class com.linkedin.venice.utils.AvroCompatibilityUtils: Backport compareTo() method from SpecificRecordBase.
compare(Object, Object, Schema) - Method in class com.linkedin.davinci.schema.merge.AvroCollectionElementComparator: This function compares two objects using the provided schema.
compare(BytesWritable, BytesWritable) - Method in class com.linkedin.venice.hadoop.input.kafka.KafkaInputKeyComparator
compare(SAMPLE, SAMPLE) - Method in class com.linkedin.alpini.base.statistics.AbstractQuantileEstimation
compare(T, T) - Method in class com.linkedin.venice.utils.HashCodeComparator
COMPARE_STORE - com.linkedin.venice.Command
COMPARE_STORE - com.linkedin.venice.controllerapi.ControllerRoute
compareAndReturn(Object, Object) - Static method in class com.linkedin.davinci.replication.merge.MergeUtils
compareAndUpdate(ZkBaseDataAccessor<T>, String, int, DataUpdater<T>) - Static method in class com.linkedin.venice.utils.HelixUtils
compareAndUpdate(ZkBaseDataAccessor<T>, String, DataUpdater<T>) - Static method in class com.linkedin.venice.utils.HelixUtils
compareCacheConfig(Optional<ObjectCacheConfig>) - Method in class com.linkedin.davinci.DaVinciBackend
compareGenericData(Object, Object, Schema) - Static method in class com.linkedin.venice.utils.AvroCompatibilityUtils: Backport compare() method implementation from GenericData in avro v1.7
comparePosition(PubSubPosition) - Method in class com.linkedin.venice.pubsub.adapter.kafka.ApacheKafkaOffsetPosition
comparePosition(PubSubPosition) - Method in interface com.linkedin.venice.pubsub.api.PubSubPosition
compareSchema(Schema, Schema) - Method in class com.linkedin.venice.controller.supersetschema.DefaultSupersetSchemaGenerator
compareSchema(Schema, Schema) - Method in interface com.linkedin.venice.controller.supersetschema.SupersetSchemaGenerator: Compare whether two schemas are equal or not with the consideration of superset schema.
compareSchema(Schema, Schema) - Method in class com.linkedin.venice.controller.supersetschema.SupersetSchemaGeneratorWithCustomProp
compareSchemaIgnoreFieldOrder(Schema, Schema) - Static method in class com.linkedin.venice.utils.AvroSchemaUtils: Compares two schema with possible re-ordering of the fields.
compareSpecificData(Object, Object, Schema) - Static method in class com.linkedin.venice.utils.AvroCompatibilityUtils: Backport compare() method implementation from SpecificData in avro v1.7
compareStore(Admin) - Method in class com.linkedin.venice.controller.server.StoresRoutes
compareStore(String, String, String) - Method in class com.linkedin.venice.controllerapi.ControllerClient
compareStore(String, String, String, String) - Method in interface com.linkedin.venice.controller.Admin: Compare store metadata and version states between two fabrics.
compareStore(String, String, String, String) - Method in class com.linkedin.venice.controller.VeniceHelixAdmin
compareStore(String, String, String, String) - Method in class com.linkedin.venice.controller.VeniceParentHelixAdmin
compareTo(TimeValue) - Method in class com.linkedin.alpini.base.misc.TimeValue
compareTo(ConsumerAction) - Method in class com.linkedin.davinci.kafka.consumer.ConsumerAction
compareTo(Version) - Method in class com.linkedin.venice.meta.