Deprecated API

Contents

• Classes
• Enums
• Fields
• Methods
• Constructors
• Enum Constants

Classes

Class	Description
com.linkedin.alpini.netty4.handlers.ChunkedResponseLimiter	broken. use the content chunking in HttpMultiPartContentEncoder
com.linkedin.alpini.netty4.handlers.MultipartResponseHandler	Use the HttpMultiPartContentEncoder
com.linkedin.davinci.repository.DaVinciClientMetaStoreBasedRepository
com.linkedin.venice.client.store.VsonGenericStoreClientImpl
com.linkedin.venice.controllerapi.D2ServiceDiscoveryResponseV2
com.linkedin.venice.fastclient.DispatchingVsonStoreClient
com.linkedin.venice.fastclient.meta.DaVinciClientBasedMetadata
com.linkedin.venice.schema.vson.AbstractVsonSchemaAdapter
com.linkedin.venice.schema.vson.VsonAvroDatumReader
com.linkedin.venice.schema.vson.VsonAvroDatumWriter
com.linkedin.venice.schema.vson.VsonAvroSchemaAdapter
com.linkedin.venice.schema.vson.VsonAvroSerializer
com.linkedin.venice.schema.vson.VsonReader
com.linkedin.venice.schema.vson.VsonSchema
com.linkedin.venice.schema.vson.VsonSchemaAdapter
com.linkedin.venice.stats.LambdaStat	, use Gauge instead. The reason to deprecate LambdaStat is that Gauge is a better name when appending the class name as the suffix of metric name here: AbstractVeniceStats.registerSensor(java.lang.String, io.tehuti.metrics.MeasurableStat...).
com.linkedin.venice.utils.Pair	Instead of this, please create a dedicated class with well-named, non-generic (potentially primitive) properties and getters.

Enums

Enum	Description
com.linkedin.venice.exceptions.ExceptionType	since v0.2.620 Previously, this enum didn't have the @JsonEnumDefaultValue annotation. This annotation helps Jackson deserialize arbitrary values to a default value instead of throwing an Exception. Without this annotation, the enum is essentially non-evolvable since there may be many clients that are already running older code. Use ErrorType instead.
com.linkedin.venice.schema.vson.VsonTypes
com.linkedin.venice.serializer.AvroGenericDeserializer.IterableImpl

Fields

Field	Description
com.linkedin.venice.ConfigKeys.CHILD_CLUSTER_WHITELIST
com.linkedin.venice.ConfigKeys.ENABLE_HYBRID_PUSH_SSL_WHITELIST
com.linkedin.venice.ConfigKeys.ENABLE_OFFLINE_PUSH_SSL_WHITELIST
com.linkedin.venice.ConfigKeys.NATIVE_REPLICATION_FABRIC_WHITELIST
com.linkedin.venice.ConfigKeys.PUSH_SSL_WHITELIST
com.linkedin.venice.ConfigKeys.SSL_TO_KAFKA_LEGACY	Use ConfigKeys.KAFKA_OVER_SSL
com.linkedin.venice.controllerapi.D2ServiceDiscoveryResponseV2.D2_SERVICE_DISCOVERY_RESPONSE_V2_ENABLED
com.linkedin.venice.hadoop.VenicePushJob.VSON_PUSH
com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerConfig.SSL_TO_KAFKA_LEGACY	Use ApacheKafkaProducerConfig.KAFKA_OVER_SSL instead
com.linkedin.venice.router.api.VenicePathParser.TYPE_LEADER_CONTROLLER_LEGACY
com.linkedin.venice.serialization.avro.InternalAvroSpecificSerializer.VENICE_SCHEMA_READER_CONFIG

Methods

Method	Description
com.linkedin.alpini.io.ssl.SSLContextBuilder.build(String, String)	Builds from key store file instead of raw key store data.
com.linkedin.alpini.netty4.handlers.BasicServerChannelInitializer.isUseCustomMultiplexHandler()
com.linkedin.alpini.netty4.handlers.BasicServerChannelInitializer.useCustomMultiplexHandler(boolean)
com.linkedin.alpini.netty4.misc.BalancedEventLoopGroup.register(Channel, ChannelPromise)
com.linkedin.alpini.netty4.misc.BalancedEventLoopGroup.shutdown()
com.linkedin.alpini.netty4.misc.Http2Utils.isHttp2Pipeline(ChannelPipeline)
com.linkedin.alpini.netty4.pool.ChannelPoolManager.executorCount()	due to confusing name. Use ChannelPoolManager.subpoolCount()
com.linkedin.alpini.netty4.pool.ChannelPoolManager.getQueueStats(String)
com.linkedin.alpini.netty4.pool.ChannelPoolManagerImpl.createQueueAcquireCallTracker(String)
com.linkedin.alpini.netty4.pool.ChannelPoolManagerImpl.createQueueBusyCallTracker(String)
com.linkedin.alpini.netty4.pool.ChannelPoolManagerImpl.executorCount()
com.linkedin.alpini.netty4.pool.Http2AwareChannelPool.isTooManyActiveStreamsError(Throwable)
com.linkedin.alpini.netty4.pool.Http2AwareChannelPoolFactory.createHttpClientCodec()	use Http2AwareChannelPoolFactory.createBasicHttpClientCodec()
com.linkedin.alpini.netty4.pool.SimpleChannelPoolManagerImpl.executorCount()
com.linkedin.alpini.router.api.ScatterGatherMode.scatter(Scatter<H, P, K>, String, String, PartitionFinder<K>, HostFinder<H, R>, HostHealthMonitor<H>, R, Metrics)
com.linkedin.venice.client.store.AvroGenericReadComputeStoreClient.compute(Optional<ClientStats>, Optional<ClientStats>, long)
com.linkedin.venice.client.store.AvroGenericStoreClient.getKeySchema()	This method is considered deprecated. Please use StoreSchemaFetcher.getKeySchema() to fetch key schema instead.
com.linkedin.venice.client.store.AvroGenericStoreClient.getLatestValueSchema()	This method is considered deprecated. Please use StoreSchemaFetcher.getLatestValueSchemaEntry() to fetch latest value schema instead.
com.linkedin.venice.client.store.ClientConfig.defaultVsonGenericClientConfig(String)
com.linkedin.venice.client.store.ClientConfig.isVsonClient()
com.linkedin.venice.client.store.ClientConfig.setAlwaysOnDeserializerNumberOfThreads(int)
com.linkedin.venice.client.store.ClientConfig.setAlwaysOnDeserializerQueueCapacity(int)
com.linkedin.venice.client.store.ClientConfig.setMultiGetEnvelopeIterableImpl(AvroGenericDeserializer.IterableImpl)
com.linkedin.venice.client.store.ClientConfig.setOnDemandDeserializerNumberOfRecordsPerThread(int)
com.linkedin.venice.client.store.ClientConfig.setVsonClient(boolean)
com.linkedin.venice.client.store.DelegatingStoreClient.getKeySchema()
com.linkedin.venice.client.store.DelegatingStoreClient.getLatestValueSchema()
com.linkedin.venice.controller.server.CreateVersion.uploadPushInfo(Admin)
com.linkedin.venice.controller.VeniceControllerClusterConfig.getMinActiveReplica()
com.linkedin.venice.controllerapi.ControllerClient.constructClusterControllerClient(String, String)	Use ControllerClientFactory.getControllerClient(java.lang.String, java.lang.String, java.util.Optional<com.linkedin.venice.security.SSLFactory>)
com.linkedin.venice.controllerapi.ControllerClient.discoverAndConstructControllerClient(String, String, Optional<SSLFactory>, int)	Use ControllerClientFactory.discoverAndConstructControllerClient(java.lang.String, java.lang.String, java.util.Optional<com.linkedin.venice.security.SSLFactory>, int)
com.linkedin.venice.controllerapi.ControllerClient.getStore(String, String, String)
com.linkedin.venice.controllerapi.ControllerResponse.getExceptionType()
com.linkedin.venice.controllerapi.D2ControllerClient.convertToSecureUrl(URL)
com.linkedin.venice.controllerapi.D2ControllerClient.discoverCluster(String, String, String, int)
com.linkedin.venice.controllerapi.JobStatusQueryResponse.getExtraDetails()	Only used for JSON serialization purposes. Use JobStatusQueryResponse.getOptionalExtraDetails() instead.
com.linkedin.venice.controllerapi.JobStatusQueryResponse.getStatusDetails()	Only used for JSON serialization purposes. Use JobStatusQueryResponse.getOptionalExtraDetails() instead.
com.linkedin.venice.fastclient.ClientConfig.ClientConfigBuilder.setVsonStore(boolean)
com.linkedin.venice.fastclient.ClientConfig.isVsonStore()
com.linkedin.venice.meta.Instance.getUrl()
com.linkedin.venice.meta.Store.setLeaderFollowerModelEnabled(boolean)
com.linkedin.venice.meta.Version.getTimestampMetadataVersionId()	Use Version.getRmdVersionId() instead
com.linkedin.venice.meta.Version.setLeaderFollowerModelEnabled(boolean)
com.linkedin.venice.meta.Version.setTimestampMetadataVersionId(int)	Use Version.setRmdVersionId(int) instead
com.linkedin.venice.meta.ZKStore.isAccessControlled()	The store level accessControlled flag is no longer valid to be used to skip ACL checks.
com.linkedin.venice.meta.ZKStore.setAccessControlled(boolean)	The store level accessControlled flag is no longer valid to be used to skip ACL checks.
com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerAdapter.getNumberOfPartitions(String)
com.linkedin.venice.pubsub.api.PubSubProducerAdapter.getNumberOfPartitions(String)
com.linkedin.venice.router.api.RouterExceptionAndTrackingUtils.newVeniceExceptionAndTracking(Optional<String>, Optional<RequestType>, HttpResponseStatus, String, RouterExceptionAndTrackingUtils.FailureType)
com.linkedin.venice.samza.VeniceSystemFactory.createSystemProducer(String, String, String, Version.PushType, String, String, Config, Optional<SSLFactory>, Optional<String>)	Left in to maintain backward compatibility
com.linkedin.venice.schema.writecompute.WriteComputeSchemaConverter.convert(String)
com.linkedin.venice.utils.TestUtils.getParticipant(String, String, String, int, String)	TODO: migrate to use ServiceFactory for generating a participant
com.linkedin.venice.writer.VeniceWriter.put(KafkaKey, KafkaMessageEnvelope, PubSubProducerCallback, int, LeaderMetadataWrapper)
io.netty.handler.codec.EspressoMessageAggregator.isHandlingOversizedMessage()	This method will be removed in future releases.
io.netty.handler.codec.http.EspressoHttpObjectEncoder.encodeAscii(String, ByteBuf)
io.netty.handler.codec.http2.EspressoHttp2StreamChannelBootstrap.open0(ChannelHandlerContext, Promise<Http2StreamChannel>, EventLoop)	should not be used directly. Use EspressoHttp2StreamChannelBootstrap.open() or

Constructors

Constructor	Description
com.linkedin.alpini.base.misc.QueryStringDecoder(String, String)	Use QueryStringDecoder(String, Charset) instead.
com.linkedin.alpini.netty4.handlers.StaleConnectionHandler(long, long, TimeUnit)
com.linkedin.alpini.netty4.http2.Http2PipelineInitializer(Http2Settings, ActiveStreamsCountHandler, Http2SettingsFrameLogger, Consumer<ChannelPipeline>, int, int, int, boolean, boolean)
com.linkedin.alpini.router.ScatterGatherRequestHandler4(ScatterGatherHelper<H, P, K, R, BasicFullHttpRequest, FullHttpResponse, HttpResponseStatus>, TimeoutProcessor, Executor)
com.linkedin.davinci.client.factory.CachingDaVinciClientFactory(D2Client, MetricsRepository, VeniceProperties)
com.linkedin.venice.controller.VeniceController(List<VeniceProperties>, MetricsRepository, List<ServiceDiscoveryAnnouncer>, Optional<DynamicAccessController>, Optional<AuthorizerService>, D2Client, Optional<ClientConfig>, Optional<ICProvider>, Optional<SupersetSchemaGenerator>)
com.linkedin.venice.meta.VersionImpl(String, int)
com.linkedin.venice.router.streaming.NettyChunkedWriteHandler(int)	use NettyChunkedWriteHandler()
com.linkedin.venice.samza.VeniceSystemProducer(String, String, String, Version.PushType, String, String, boolean, VeniceSystemFactory, Optional<SSLFactory>, Optional<String>)
com.linkedin.venice.server.VeniceServer(VeniceConfigLoader, MetricsRepository, Optional<SSLFactory>, Optional<StaticAccessController>, Optional<DynamicAccessController>, Optional<ClientConfig>, ICProvider, List<ServiceDiscoveryAnnouncer>)	Use VeniceServer(VeniceServerContext) instead. Constructor kept for maintaining the backward compatibility Allocates a new VeniceServer object.
com.linkedin.venice.utils.VeniceProperties()	Use VeniceProperties.empty()
com.linkedin.venice.writer.VeniceWriterFactory(Properties)

Enum Constants

Enum Constant	Description
com.linkedin.venice.client.store.deserialization.BatchDeserializerType.ALWAYS_ON_MULTI_THREADED_PIPELINE
com.linkedin.venice.client.store.deserialization.BatchDeserializerType.ONE_FUTURE_PER_RECORD
com.linkedin.venice.compression.CompressionStrategy.ZSTD
com.linkedin.venice.controller.kafka.protocol.enums.AdminMessageType.CONFIGURE_INCREMENTAL_PUSH_FOR_CLUSTER	We do not support incremental push policy anymore.
com.linkedin.venice.controllerapi.ControllerRoute.MASTER_CONTROLLER
com.linkedin.venice.fastclient.meta.StoreMetadataFetchMode.THIN_CLIENT_BASED_METADATA
com.linkedin.venice.ingestion.protocol.enums.IngestionReportType.START_OF_BUFFER_REPLAY_RECEIVED
com.linkedin.venice.kafka.protocol.enums.ControlMessageType.START_OF_BUFFER_REPLAY
com.linkedin.venice.kafka.validation.checksum.CheckSumType.ADLER32
com.linkedin.venice.kafka.validation.checksum.CheckSumType.CRC32
com.linkedin.venice.pushmonitor.ExecutionStatus.START_OF_BUFFER_REPLAY_RECEIVED
com.linkedin.venice.router.api.RouterResourceType.TYPE_LEADER_CONTROLLER_LEGACY
com.linkedin.venice.router.httpclient.StorageNodeClientType.APACHE_HTTP_ASYNC_CLIENT
com.linkedin.venice.serializer.AvroGenericDeserializer.IterableImpl.LAZY
com.linkedin.venice.serializer.AvroGenericDeserializer.IterableImpl.LAZY_WITH_REPLAY_SUPPORT
com.linkedin.venice.stats.PubSubAdminWrapperStats.OCCURRENCE_LATENCY_SENSOR_TYPE.IS_TOPIC_DELETION_UNDER_WAY