Package io.pravega.client.stream

Class StreamConfiguration.StreamConfigurationBuilder

java.lang.Object

io.pravega.client.stream.StreamConfiguration.StreamConfigurationBuilder

Enclosing class:

StreamConfiguration

public static final class StreamConfiguration.StreamConfigurationBuilder
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
StreamConfiguration	build()
StreamConfiguration.StreamConfigurationBuilder	retentionPolicy(RetentionPolicy retentionPolicy)	API to return retention policy.
StreamConfiguration.StreamConfigurationBuilder	scalingPolicy(ScalingPolicy scalingPolicy)	API to return scaling policy.
StreamConfiguration.StreamConfigurationBuilder	timestampAggregationTimeout(long timestampAggregationTimeout)	The duration after the last call to EventStreamWriter.noteTime(long) which the timestamp should be considered valid before it is forgotten.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

scalingPolicy

public StreamConfiguration.StreamConfigurationBuilder scalingPolicy(ScalingPolicy scalingPolicy)

API to return scaling policy.

Parameters:

scalingPolicy - The Stream Scaling policy.

Returns:

this.

retentionPolicy

public StreamConfiguration.StreamConfigurationBuilder retentionPolicy(RetentionPolicy retentionPolicy)

API to return retention policy. Also see: ReaderGroupConfig.StreamDataRetention

Parameters:

retentionPolicy - The Stream Retention policy.

Returns:

this.

timestampAggregationTimeout

public StreamConfiguration.StreamConfigurationBuilder timestampAggregationTimeout(long timestampAggregationTimeout)

The duration after the last call to EventStreamWriter.noteTime(long) which the timestamp should be considered valid before it is forgotten. Meaning that after this long of not calling EventStreamWriter.noteTime(long) the writer will be forgotten. If there are no known writers, readers that call EventStreamReader.getCurrentTimeWindow(Stream) will receive a `null` when they are at the corresponding position in the stream.

Parameters:

timestampAggregationTimeout - The duration after the last call to EventStreamWriter.noteTime(long) which the timestamp should be considered valid before it is forgotten. be considered valid before it is forgotten.

Returns:

this.

build

public StreamConfiguration build()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object