Package com.linkedin.davinci.consumer

Class ChangelogClientConfig<T extends org.apache.avro.specific.SpecificRecord>

java.lang.Object

com.linkedin.davinci.consumer.ChangelogClientConfig<T>

public class ChangelogClientConfig<T extends org.apache.avro.specific.SpecificRecord>
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
ChangelogClientConfig()
ChangelogClientConfig(java.lang.String storeName)

Method Summary

Modifier and Type	Method	Description
static <V extends org.apache.avro.specific.SpecificRecord> ChangelogClientConfig<V>	cloneConfig(ChangelogClientConfig<V> config)
java.lang.String	getBootstrapFileSystemPath()
java.lang.String	getConsumerName()
java.util.Properties	getConsumerProperties()
java.lang.String	getControllerD2ServiceName()
int	getControllerRequestRetryCount()
com.linkedin.d2.balancer.D2Client	getD2Client()
D2ControllerClient	getD2ControllerClient()
java.lang.String	getD2ServiceName()
long	getDatabaseSyncBytesInterval()	Gets the databaseSyncBytesInterval.
ClientConfig<T>	getInnerClientConfig()
java.lang.String	getLocalD2ZkHosts()
long	getRocksDBBlockCacheSizeInBytes()
SchemaReader	getSchemaReader()
java.lang.String	getStoreName()
long	getVersionSwapDetectionIntervalTimeInMs()
java.lang.String	getViewName()
ChangelogClientConfig<T>	setBootstrapFileSystemPath(java.lang.String bootstrapFileSystemPath)
ChangelogClientConfig<T>	setConsumerName(java.lang.String consumerName)
ChangelogClientConfig<T>	setConsumerProperties(java.util.Properties consumerProperties)
ChangelogClientConfig<T>	setControllerD2ServiceName(java.lang.String controllerD2ServiceName)
ChangelogClientConfig<T>	setControllerRequestRetryCount(int controllerRequestRetryCount)
ChangelogClientConfig<T>	setD2Client(com.linkedin.d2.balancer.D2Client d2Client)
ChangelogClientConfig<T>	setD2ControllerClient(D2ControllerClient d2ControllerClient)
ChangelogClientConfig<T>	setD2ServiceName(java.lang.String d2ServiceName)
ChangelogClientConfig	setDatabaseSyncBytesInterval(long databaseSyncBytesInterval)	Sets the value for databaseSyncBytesInterval.
ChangelogClientConfig<T>	setLocalD2ZkHosts(java.lang.String localD2ZkHosts)
ChangelogClientConfig	setRocksDBBlockCacheSizeInBytes(long rocksDBBlockCacheSizeInBytes)
ChangelogClientConfig<T>	setSchemaReader(SchemaReader schemaReader)
ChangelogClientConfig<T>	setShouldCompactMessages(boolean compactMessages)
ChangelogClientConfig	setSpecificValue(java.lang.Class<T> specificValue)
ChangelogClientConfig<T>	setStoreName(java.lang.String storeName)
ChangelogClientConfig	setVersionSwapDetectionIntervalTimeInMs(long intervalTimeInMs)
ChangelogClientConfig<T>	setViewName(java.lang.String viewName)
boolean	shouldCompactMessages()

Methods inherited from class java.lang.Object

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

Constructor Detail

ChangelogClientConfig

public ChangelogClientConfig(java.lang.String storeName)

ChangelogClientConfig

public ChangelogClientConfig()

Method Detail

setStoreName

public ChangelogClientConfig<T> setStoreName(java.lang.String storeName)

getStoreName

public java.lang.String getStoreName()

setConsumerProperties

public ChangelogClientConfig<T> setConsumerProperties(java.util.Properties consumerProperties)

getConsumerProperties

public java.util.Properties getConsumerProperties()

setSchemaReader

public ChangelogClientConfig<T> setSchemaReader(SchemaReader schemaReader)

getSchemaReader

public SchemaReader getSchemaReader()

setViewName

public ChangelogClientConfig<T> setViewName(java.lang.String viewName)

setConsumerName

public ChangelogClientConfig<T> setConsumerName(java.lang.String consumerName)

setShouldCompactMessages

public ChangelogClientConfig<T> setShouldCompactMessages(boolean compactMessages)

getViewName

public java.lang.String getViewName()

getConsumerName

public java.lang.String getConsumerName()

shouldCompactMessages

public boolean shouldCompactMessages()

setControllerD2ServiceName

public ChangelogClientConfig<T> setControllerD2ServiceName(java.lang.String controllerD2ServiceName)

getControllerD2ServiceName

public java.lang.String getControllerD2ServiceName()

setD2ServiceName

public ChangelogClientConfig<T> setD2ServiceName(java.lang.String d2ServiceName)

getD2ServiceName

public java.lang.String getD2ServiceName()

setD2ControllerClient

public ChangelogClientConfig<T> setD2ControllerClient(D2ControllerClient d2ControllerClient)

getD2ControllerClient

public D2ControllerClient getD2ControllerClient()

setD2Client

public ChangelogClientConfig<T> setD2Client(com.linkedin.d2.balancer.D2Client d2Client)

getD2Client

public com.linkedin.d2.balancer.D2Client getD2Client()

setLocalD2ZkHosts

public ChangelogClientConfig<T> setLocalD2ZkHosts(java.lang.String localD2ZkHosts)

getLocalD2ZkHosts

public java.lang.String getLocalD2ZkHosts()

setControllerRequestRetryCount

public ChangelogClientConfig<T> setControllerRequestRetryCount(int controllerRequestRetryCount)

getControllerRequestRetryCount

public int getControllerRequestRetryCount()

getInnerClientConfig

public ClientConfig<T> getInnerClientConfig()

setBootstrapFileSystemPath

public ChangelogClientConfig<T> setBootstrapFileSystemPath(java.lang.String bootstrapFileSystemPath)

getBootstrapFileSystemPath

public java.lang.String getBootstrapFileSystemPath()

getVersionSwapDetectionIntervalTimeInMs

public long getVersionSwapDetectionIntervalTimeInMs()

setVersionSwapDetectionIntervalTimeInMs

public ChangelogClientConfig setVersionSwapDetectionIntervalTimeInMs(long intervalTimeInMs)

getDatabaseSyncBytesInterval

public long getDatabaseSyncBytesInterval()

Gets the databaseSyncBytesInterval.

setDatabaseSyncBytesInterval

public ChangelogClientConfig setDatabaseSyncBytesInterval(long databaseSyncBytesInterval)

Sets the value for databaseSyncBytesInterval.

getRocksDBBlockCacheSizeInBytes

public long getRocksDBBlockCacheSizeInBytes()

setRocksDBBlockCacheSizeInBytes

public ChangelogClientConfig setRocksDBBlockCacheSizeInBytes(long rocksDBBlockCacheSizeInBytes)

setSpecificValue

public ChangelogClientConfig setSpecificValue(java.lang.Class<T> specificValue)

cloneConfig

public static <V extends org.apache.avro.specific.SpecificRecord> ChangelogClientConfig<V> cloneConfig(ChangelogClientConfig<V> config)