io.pravega.client.stream

Class RetentionPolicy

java.lang.Object

io.pravega.client.stream.RetentionPolicy

All Implemented Interfaces:

java.io.Serializable

public class RetentionPolicy
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RetentionPolicy.RetentionPolicyBuilder
static class	RetentionPolicy.RetentionType

Method Summary

Modifier and Type	Method and Description
static RetentionPolicy.RetentionPolicyBuilder	builder()
static RetentionPolicy	bySizeBytes(long size) Create a retention policy to configure a stream to truncate a stream according to the amount of data currently stored.
static RetentionPolicy	byTime(java.time.Duration duration) Create a retention policy to configure a stream to periodically truncated according to the specified duration.
protected boolean	canEqual(java.lang.Object other)
boolean	equals(java.lang.Object o)
long	getRetentionParam()
RetentionPolicy.RetentionType	getRetentionType()
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

byTime

public static RetentionPolicy byTime(java.time.Duration duration)

Create a retention policy to configure a stream to periodically truncated according to the specified duration.

Parameters:

duration - Period to retain data in a stream.

Returns:

Retention policy object.

bySizeBytes

public static RetentionPolicy bySizeBytes(long size)

Create a retention policy to configure a stream to truncate a stream according to the amount of data currently stored.

Parameters:

size - Amount of data to retain in a stream.

Returns:

Retention policy object.

builder

public static RetentionPolicy.RetentionPolicyBuilder builder()

getRetentionType

public RetentionPolicy.RetentionType getRetentionType()

getRetentionParam

public long getRetentionParam()

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

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object