Package io.pravega.client.stream
Class EventWriterConfig
- java.lang.Object
-
- io.pravega.client.stream.EventWriterConfig
-
- All Implemented Interfaces:
java.io.Serializable
public class EventWriterConfig extends java.lang.Object implements java.io.Serializable
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
EventWriterConfig.EventWriterConfigBuilder
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static EventWriterConfig.EventWriterConfigBuilder
builder()
protected boolean
canEqual(java.lang.Object other)
boolean
equals(java.lang.Object o)
int
getBackoffMultiple()
int
getInitialBackoffMillis()
int
getMaxBackoffMillis()
int
getRetryAttempts()
long
getTransactionTimeoutTime()
int
hashCode()
boolean
isAutomaticallyNoteTime()
Automatically invokeEventStreamWriter.noteTime(long)
passingSystem.currentTimeMillis()
on a regular interval.boolean
isEnableConnectionPooling()
java.lang.String
toString()
-
-
-
Method Detail
-
builder
public static EventWriterConfig.EventWriterConfigBuilder builder()
-
getInitialBackoffMillis
public int getInitialBackoffMillis()
-
getMaxBackoffMillis
public int getMaxBackoffMillis()
-
getRetryAttempts
public int getRetryAttempts()
-
getBackoffMultiple
public int getBackoffMultiple()
-
isEnableConnectionPooling
public boolean isEnableConnectionPooling()
-
getTransactionTimeoutTime
public long getTransactionTimeoutTime()
-
isAutomaticallyNoteTime
public boolean isAutomaticallyNoteTime()
Automatically invokeEventStreamWriter.noteTime(long)
passingSystem.currentTimeMillis()
on a regular interval.- Returns:
- Interval to regularly invoke
EventStreamWriter.noteTime(long)
.
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
canEqual
protected boolean canEqual(java.lang.Object other)
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-