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.RetentionType

Constructor Summary

Constructors

Constructor and Description
RetentionPolicy()

Method Summary

Modifier and Type	Method and Description
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RetentionPolicy

public RetentionPolicy()

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.