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.EventWriterConfigBuilder
automaticallyNoteTime(boolean automaticallyNoteTime)
Automatically invokeEventStreamWriter.noteTime(long)
passingSystem.currentTimeMillis()
on a regular interval.EventWriterConfig.EventWriterConfigBuilder
backoffMultiple(int backoffMultiple)
EventWriterConfig
build()
EventWriterConfig.EventWriterConfigBuilder
enableConnectionPooling(boolean enableConnectionPooling)
EventWriterConfig.EventWriterConfigBuilder
initialBackoffMillis(int initialBackoffMillis)
EventWriterConfig.EventWriterConfigBuilder
maxBackoffMillis(int maxBackoffMillis)
EventWriterConfig.EventWriterConfigBuilder
retryAttempts(int retryAttempts)
java.lang.String
toString()
EventWriterConfig.EventWriterConfigBuilder
transactionTimeoutTime(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:
toString
in classjava.lang.Object
-
-