Package io.pravega.client.stream
Class ReaderGroupConfig
- java.lang.Object
-
- io.pravega.client.stream.ReaderGroupConfig
-
- All Implemented Interfaces:
java.io.Serializable
public class ReaderGroupConfig extends java.lang.Object implements java.io.Serializable
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ReaderGroupConfig.ReaderGroupConfigBuilder
static class
ReaderGroupConfig.StreamDataRetention
If a Reader Group wants unconsumed data to be retained in a Stream, the retentionType inReaderGroupConfig
should be set to to 'MANUAL_RELEASE_AT_USER_STREAMCUT' or 'AUTOMATIC_RELEASE_AT_LAST_CHECKPOINT'.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ReaderGroupConfig.ReaderGroupConfigBuilder
builder()
protected boolean
canEqual(java.lang.Object other)
boolean
equals(java.lang.Object o)
static ReaderGroupConfig
fromBytes(java.nio.ByteBuffer buff)
long
getAutomaticCheckpointIntervalMillis()
java.util.Map<Stream,StreamCut>
getEndingStreamCuts()
long
getGeneration()
long
getGroupRefreshTimeMillis()
int
getMaxOutstandingCheckpointRequest()
java.util.UUID
getReaderGroupId()
ReaderGroupConfig.StreamDataRetention
getRetentionType()
java.util.Map<Stream,StreamCut>
getStartingStreamCuts()
int
hashCode()
ReaderGroupConfig.ReaderGroupConfigBuilder
toBuilder()
java.nio.ByteBuffer
toBytes()
java.lang.String
toString()
-
-
-
Method Detail
-
toBytes
public java.nio.ByteBuffer toBytes()
-
fromBytes
public static ReaderGroupConfig fromBytes(java.nio.ByteBuffer buff)
-
builder
public static ReaderGroupConfig.ReaderGroupConfigBuilder builder()
-
toBuilder
public ReaderGroupConfig.ReaderGroupConfigBuilder toBuilder()
-
getGroupRefreshTimeMillis
public long getGroupRefreshTimeMillis()
-
getMaxOutstandingCheckpointRequest
public int getMaxOutstandingCheckpointRequest()
-
getRetentionType
public ReaderGroupConfig.StreamDataRetention getRetentionType()
-
getGeneration
public long getGeneration()
-
getReaderGroupId
public java.util.UUID getReaderGroupId()
-
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
-
getAutomaticCheckpointIntervalMillis
public long getAutomaticCheckpointIntervalMillis()
-
-