Package com.linkedin.davinci.client

Class AvroSpecificDaVinciClient<K,V extends org.apache.avro.specific.SpecificRecord>

java.lang.Object

com.linkedin.davinci.client.AvroGenericDaVinciClient<K,V>

com.linkedin.davinci.client.AvroSpecificDaVinciClient<K,V>

All Implemented Interfaces:

DaVinciClient<K,V>, AvroGenericReadComputeStoreClient<K,V>, AvroGenericStoreClient<K,V>, Closeable, AutoCloseable

public class AvroSpecificDaVinciClient<K,V extends org.apache.avro.specific.SpecificRecord>
extends AvroGenericDaVinciClient<K,V>

Field Summary

Fields inherited from class com.linkedin.davinci.client.AvroGenericDaVinciClient

DEFAULT_CHUNK_SPLIT_THRESHOLD, logger, READ_CHUNK_EXECUTOR

Constructor Summary

Constructors

Constructor	Description
AvroSpecificDaVinciClient(DaVinciConfig daVinciConfig, ClientConfig clientConfig, VeniceProperties backendConfig, Optional<Set<String>> managedClients, ICProvider icProvider, Executor readChunkExecutorForLargeRequest)

Method Summary

Methods inherited from class com.linkedin.davinci.client.AvroGenericDaVinciClient

batchGet, close, compute, compute, computeWithKeyPrefixFilter, discoverService, get, get, getAvroChunkingAdapter, getBackend, getGenericRecordChunkingAdapter, getKeySchema, getLatestValueSchema, getPartitionCount, getSchemaReader, getStoreName, initBackend, isPartitionReadyToServe, isPartitionSubscribed, isProjectionFieldValidationEnabled, isReady, split, start, streamingBatchGet, subscribe, subscribe, subscribeAll, throwIfNotReady, toString, unsubscribe, unsubscribe, unsubscribeAll

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.linkedin.venice.client.store.AvroGenericReadComputeStoreClient

compute, compute, compute

Methods inherited from interface com.linkedin.venice.client.store.AvroGenericStoreClient

streamingBatchGet

Constructor Details

AvroSpecificDaVinciClient

public AvroSpecificDaVinciClient(DaVinciConfig daVinciConfig,
 ClientConfig clientConfig,
 VeniceProperties backendConfig,
 Optional<Set<String>> managedClients,
 ICProvider icProvider,
 Executor readChunkExecutorForLargeRequest)