Package io.pravega.client.state
Class SynchronizerConfig.SynchronizerConfigBuilder
- java.lang.Object
-
- io.pravega.client.state.SynchronizerConfig.SynchronizerConfigBuilder
-
- All Implemented Interfaces:
io.pravega.common.ObjectBuilder<SynchronizerConfig>
- Enclosing class:
- SynchronizerConfig
public static class SynchronizerConfig.SynchronizerConfigBuilder extends java.lang.Object implements io.pravega.common.ObjectBuilder<SynchronizerConfig>
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SynchronizerConfigbuild()SynchronizerConfig.SynchronizerConfigBuildereventWriterConfig(EventWriterConfig eventWriterConfig)This writer config is used by the segment writers in the StateSynchronizer.SynchronizerConfig.SynchronizerConfigBuilderreadBufferSize(int readBufferSize)This size is used to allocate buffer space for the bytes the reader in the StateSynchronizer reads from the segment.java.lang.StringtoString()
-
-
-
Method Detail
-
eventWriterConfig
public SynchronizerConfig.SynchronizerConfigBuilder eventWriterConfig(EventWriterConfig eventWriterConfig)
This writer config is used by the segment writers in the StateSynchronizer. The default values enable connection pooling and ensures the background connection retry attempts continue until the StateSynchronizer is closed.- Parameters:
eventWriterConfig- writer config used by the segment writers in the StateSynchronizer- Returns:
this.
-
readBufferSize
public SynchronizerConfig.SynchronizerConfigBuilder readBufferSize(int readBufferSize)
This size is used to allocate buffer space for the bytes the reader in the StateSynchronizer reads from the segment. The default buffer size is 256KB.- Parameters:
readBufferSize- Size used to allocate buffer space for the bytes the StateSynchronizer reader reads from the segment.- Returns:
this.
-
build
public SynchronizerConfig build()
- Specified by:
buildin interfaceio.pravega.common.ObjectBuilder<SynchronizerConfig>
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-