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 SynchronizerConfig
build()
SynchronizerConfig.SynchronizerConfigBuilder
eventWriterConfig(EventWriterConfig eventWriterConfig)
This writer config is used by the segment writers in the StateSynchronizer.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.java.lang.String
toString()
-
-
-
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:
build
in interfaceio.pravega.common.ObjectBuilder<SynchronizerConfig>
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-