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 Object

  • Constructor Details

    • ChangelogClientConfig

      public ChangelogClientConfig(String storeName)

    • ChangelogClientConfig

      public ChangelogClientConfig()

  • Method Details

    • setStoreName

      public ChangelogClientConfig<T> setStoreName(String storeName)

    • getStoreName

      public String getStoreName()

    • setConsumerProperties

      public ChangelogClientConfig<T> setConsumerProperties(Properties consumerProperties)

    • getConsumerProperties

      public Properties getConsumerProperties()

    • setSchemaReader

      public ChangelogClientConfig<T> setSchemaReader(SchemaReader schemaReader)

    • getSchemaReader

      public SchemaReader getSchemaReader()

    • setViewName

      public ChangelogClientConfig<T> setViewName(String viewName)

    • setConsumerName

      public ChangelogClientConfig<T> setConsumerName(String consumerName)

    • setShouldCompactMessages

      public ChangelogClientConfig<T> setShouldCompactMessages(boolean compactMessages)

    • getViewName

      public String getViewName()

    • getConsumerName

      public String getConsumerName()

    • shouldCompactMessages

      public boolean shouldCompactMessages()

    • setControllerD2ServiceName

      public ChangelogClientConfig<T> setControllerD2ServiceName(String controllerD2ServiceName)

    • getControllerD2ServiceName

      public String getControllerD2ServiceName()

    • setD2ServiceName

      public ChangelogClientConfig<T> setD2ServiceName(String d2ServiceName)

    • getD2ServiceName

      public 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(String localD2ZkHosts)

    • getLocalD2ZkHosts

      public String getLocalD2ZkHosts()

    • setControllerRequestRetryCount

      public ChangelogClientConfig<T> setControllerRequestRetryCount(int controllerRequestRetryCount)

    • getControllerRequestRetryCount

      public int getControllerRequestRetryCount()

    • getInnerClientConfig

      public ClientConfig<T> getInnerClientConfig()

    • setBootstrapFileSystemPath

      public ChangelogClientConfig<T> setBootstrapFileSystemPath(String bootstrapFileSystemPath)

    • getBootstrapFileSystemPath

      public 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(Class<T> specificValue)

    • cloneConfig

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