ClientFactory (venice API)

java.lang.Object

com.linkedin.venice.client.store.ClientFactory

public class ClientFactory extends Object

Constructor Summary

Constructors

Constructor

Description

ClientFactory()
Method Summary

Modifier and Type

Method

Description

static StoreSchemaFetcher

createStoreSchemaFetcher(ClientConfig clientConfig)

static <K, V> AvroGenericStoreClient<K,V>

getAndStartAvroClient(ClientConfig clientConfig)

static <K, V> AvroGenericStoreClient<K,V>

getAndStartGenericAvroClient(ClientConfig clientConfig)

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

getAndStartSpecificAvroClient(ClientConfig<V> clientConfig)

static <K, V> AvroGenericStoreClient<K,V>

getGenericAvroClient(ClientConfig clientConfig)

static SchemaReader

getSchemaReader(ClientConfig clientConfig)

static SchemaReader

getSchemaReader(ClientConfig clientConfig, ICProvider icProvider)

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

getSpecificAvroClient(ClientConfig<V> clientConfig)

static TransportClient

getTransportClient(ClientConfig clientConfig)

static void

setTransportClientProvider(Function<ClientConfig,TransportClient> transportClientProvider)

static void

setUnitTestMode()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- ClientFactory
  
  public ClientFactory()
Method Details
- setUnitTestMode
  
  public static void setUnitTestMode()
- setTransportClientProvider
  
  public static void setTransportClientProvider(Function<ClientConfig,TransportClient> transportClientProvider)
- getAndStartGenericAvroClient
  
  public static <K, V> AvroGenericStoreClient<K,V> getAndStartGenericAvroClient(ClientConfig clientConfig)
- getGenericAvroClient
  
  public static <K, V> AvroGenericStoreClient<K,V> getGenericAvroClient(ClientConfig clientConfig)
- getAndStartSpecificAvroClient
  
  public static <K, V extends org.apache.avro.specific.SpecificRecord> AvroSpecificStoreClient<K,V> getAndStartSpecificAvroClient(ClientConfig<V> clientConfig)
- getSpecificAvroClient
  
  public static <K, V extends org.apache.avro.specific.SpecificRecord> AvroSpecificStoreClient<K,V> getSpecificAvroClient(ClientConfig<V> clientConfig)
- getAndStartAvroClient
  
  public static <K, V> AvroGenericStoreClient<K,V> getAndStartAvroClient(ClientConfig clientConfig)
- getSchemaReader
  
  public static SchemaReader getSchemaReader(ClientConfig clientConfig)
- getSchemaReader
  
  public static SchemaReader getSchemaReader(ClientConfig clientConfig, ICProvider icProvider)
- createStoreSchemaFetcher
  
  public static StoreSchemaFetcher createStoreSchemaFetcher(ClientConfig clientConfig)
- getTransportClient
  
  public static TransportClient getTransportClient(ClientConfig clientConfig)