VeniceStoreClientFactory (venice API)

All Known Implementing Classes:: CachingVeniceStoreClientFactory

public interface VeniceStoreClientFactory

Nested Class Summary

Nested Classes

Modifier and Type

Interface

Description

static interface

VeniceStoreClientFactory.ClientConfigUpdater
Method Summary

Modifier and Type

Method

Description

void

close()

<K, V> AvroGenericStoreClient<K,V>

getAndStartAvroGenericStoreClient(String storeName)

default <K, V> AvroGenericStoreClient<K,V>

getAndStartAvroGenericStoreClient(String storeName, VeniceStoreClientFactory.ClientConfigUpdater configUpdater)

create a generic client along with customized client configs.

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

getAndStartAvroSpecificStoreClient(String storeName, Class<V> specificRecordClass)

default <K, V extends org.apache.avro.specific.SpecificRecord> AvroSpecificStoreClient<K,V>

getAndStartAvroSpecificStoreClient(String storeName, Class<V> specificRecordClass, VeniceStoreClientFactory.ClientConfigUpdater configUpdater)

Method Details
- getAndStartAvroGenericStoreClient
  
  <K, V> AvroGenericStoreClient<K,V> getAndStartAvroGenericStoreClient(String storeName)
- getAndStartAvroGenericStoreClient
  
  default <K, V> AvroGenericStoreClient<K,V> getAndStartAvroGenericStoreClient(String storeName, VeniceStoreClientFactory.ClientConfigUpdater configUpdater)
  
  create a generic client along with customized client configs. This is only for sophisticated use cases. Do not use it if you are not familiar with these configs. e.g. client = veniceStoreClientFactory.getAndStartAvroGenericStoreClient(storeName, (config) -> config.setVsonClient(true));
  
  Returns:
- getAndStartAvroSpecificStoreClient
  
  <K, V extends org.apache.avro.specific.SpecificRecord> AvroSpecificStoreClient<K,V> getAndStartAvroSpecificStoreClient(String storeName, Class<V> specificRecordClass)
- getAndStartAvroSpecificStoreClient
  
  default <K, V extends org.apache.avro.specific.SpecificRecord> AvroSpecificStoreClient<K,V> getAndStartAvroSpecificStoreClient(String storeName, Class<V> specificRecordClass, VeniceStoreClientFactory.ClientConfigUpdater configUpdater)
- close
  
  void close()