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


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

      • ChangelogClientConfig

        public ChangelogClientConfig​(java.lang.String storeName)
      • ChangelogClientConfig

        public ChangelogClientConfig()
    • Method Detail

      • getStoreName

        public java.lang.String getStoreName()
      • setConsumerProperties

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

        public java.util.Properties getConsumerProperties()
      • getViewName

        public java.lang.String getViewName()
      • setControllerD2ServiceName

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

        public java.lang.String getControllerD2ServiceName()
      • getD2ServiceName

        public java.lang.String getD2ServiceName()
      • getD2Client

        public com.linkedin.d2.balancer.D2Client getD2Client()
      • 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)