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 in ReaderGroupConfig should be set to to 'MANUAL_RELEASE_AT_USER_STREAMCUT' or 'AUTOMATIC_RELEASE_AT_LAST_CHECKPOINT'.

Field Summary

Fields

Modifier and Type	Field	Description
static long	DEFAULT_GENERATION
static java.util.UUID	DEFAULT_UUID

Method Summary

Modifier and Type	Method	Description
static ReaderGroupConfig.ReaderGroupConfigBuilder	builder()
protected boolean	canEqual(java.lang.Object other)
static ReaderGroupConfig	cloneConfig(ReaderGroupConfig configToClone, java.util.UUID readerGroupId, long generation)
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()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

DEFAULT_UUID

public static final java.util.UUID DEFAULT_UUID

DEFAULT_GENERATION

public static final long DEFAULT_GENERATION

See Also:

Constant Field Values

Method Detail

cloneConfig

public static ReaderGroupConfig cloneConfig(ReaderGroupConfig configToClone,
                                            java.util.UUID readerGroupId,
                                            long generation)

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()

getStartingStreamCuts

public java.util.Map<Stream,StreamCut> getStartingStreamCuts()

getEndingStreamCuts

public java.util.Map<Stream,StreamCut> getEndingStreamCuts()

getMaxOutstandingCheckpointRequest

public int getMaxOutstandingCheckpointRequest()

getRetentionType

public ReaderGroupConfig.StreamDataRetention getRetentionType()

getGeneration

public long getGeneration()

getReaderGroupId

public java.util.UUID getReaderGroupId()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

canEqual

protected boolean canEqual(java.lang.Object other)

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

getAutomaticCheckpointIntervalMillis

public long getAutomaticCheckpointIntervalMillis()