Package io.pravega.client.stream
Class EventWriterConfig.EventWriterConfigBuilder
- java.lang.Object
-
- io.pravega.client.stream.EventWriterConfig.EventWriterConfigBuilder
-
- Enclosing class:
- EventWriterConfig
public static final class EventWriterConfig.EventWriterConfigBuilder extends java.lang.Object
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description EventWriterConfig.EventWriterConfigBuilderautomaticallyNoteTime(boolean automaticallyNoteTime)Automatically invokeEventStreamWriter.noteTime(long)passingSystem.currentTimeMillis()on a regular interval.EventWriterConfig.EventWriterConfigBuilderbackoffMultiple(int backoffMultiple)EventWriterConfigbuild()EventWriterConfig.EventWriterConfigBuilderenableConnectionPooling(boolean enableConnectionPooling)EventWriterConfig.EventWriterConfigBuilderinitialBackoffMillis(int initialBackoffMillis)EventWriterConfig.EventWriterConfigBuildermaxBackoffMillis(int maxBackoffMillis)EventWriterConfig.EventWriterConfigBuilderretryAttempts(int retryAttempts)java.lang.StringtoString()EventWriterConfig.EventWriterConfigBuildertransactionTimeoutTime(long transactionTimeoutTime)
-
-
-
Method Detail
-
build
public EventWriterConfig build()
-
initialBackoffMillis
public EventWriterConfig.EventWriterConfigBuilder initialBackoffMillis(int initialBackoffMillis)
-
maxBackoffMillis
public EventWriterConfig.EventWriterConfigBuilder maxBackoffMillis(int maxBackoffMillis)
-
retryAttempts
public EventWriterConfig.EventWriterConfigBuilder retryAttempts(int retryAttempts)
-
backoffMultiple
public EventWriterConfig.EventWriterConfigBuilder backoffMultiple(int backoffMultiple)
-
enableConnectionPooling
public EventWriterConfig.EventWriterConfigBuilder enableConnectionPooling(boolean enableConnectionPooling)
-
transactionTimeoutTime
public EventWriterConfig.EventWriterConfigBuilder transactionTimeoutTime(long transactionTimeoutTime)
-
automaticallyNoteTime
public EventWriterConfig.EventWriterConfigBuilder automaticallyNoteTime(boolean automaticallyNoteTime)
Automatically invokeEventStreamWriter.noteTime(long)passingSystem.currentTimeMillis()on a regular interval.- Parameters:
automaticallyNoteTime- Interval to regularly invokeEventStreamWriter.noteTime(long).- Returns:
this.
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-