Package com.linkedin.davinci.client

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

java.lang.Object

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

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

All Implemented Interfaces:

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

public class AvroSpecificSeekableDaVinciClient<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, storeBackend, subscription

Constructor Summary

Constructors

Constructor	Description
AvroSpecificSeekableDaVinciClient(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

addPartitionsToSubscription, batchGet, close, compute, compute, computeWithKeyPrefixFilter, discoverService, get, get, getAvroChunkingAdapter, getBackend, getGenericRecordChunkingAdapter, getKeySchema, getLatestValueSchema, getPartitionCount, getSchemaReader, getStoreName, getStoreVersion, initBackend, isPartitionReadyToServe, isPartitionSubscribed, isProjectionFieldValidationEnabled, isReady, seekToCheckpoint, seekToTimestamps, seekToTimestamps, 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, computeAggregation

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

streamingBatchGet

Constructor Details

AvroSpecificSeekableDaVinciClient

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