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>
,java.io.Closeable
,java.lang.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
-
-
Constructor Summary
Constructors Constructor Description AvroSpecificDaVinciClient(DaVinciConfig daVinciConfig, ClientConfig clientConfig, VeniceProperties backendConfig, java.util.Optional<java.util.Set<java.lang.String>> managedClients, ICProvider icProvider)
-
Method Summary
-
Methods inherited from class com.linkedin.davinci.client.AvroGenericDaVinciClient
batchGet, close, compute, compute, computeWithKeyPrefixFilter, get, get, getAvroChunkingAdapter, getBackend, getGenericRecordChunkingAdapter, getKeySchema, getLatestValueSchema, getPartitionCount, getStoreName, 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 Detail
-
AvroSpecificDaVinciClient
public AvroSpecificDaVinciClient(DaVinciConfig daVinciConfig, ClientConfig clientConfig, VeniceProperties backendConfig, java.util.Optional<java.util.Set<java.lang.String>> managedClients, ICProvider icProvider)
-
-