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	clearTags()
StreamConfiguration.StreamConfigurationBuilder	retentionPolicy(RetentionPolicy retentionPolicy)	API to return retention policy.
StreamConfiguration.StreamConfigurationBuilder	rolloverSizeBytes(long rolloverSizeBytes)	API to return segment rollover size.
StreamConfiguration.StreamConfigurationBuilder	scalingPolicy(ScalingPolicy scalingPolicy)	API to return scaling policy.
StreamConfiguration.StreamConfigurationBuilder	tag(java.lang.String tag)
StreamConfiguration.StreamConfigurationBuilder	tags(java.util.Collection<? extends java.lang.String> tags)
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

build

public StreamConfiguration build()

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.

tag

public StreamConfiguration.StreamConfigurationBuilder tag(java.lang.String tag)

tags

public StreamConfiguration.StreamConfigurationBuilder tags(java.util.Collection<? extends java.lang.String> tags)

clearTags

public StreamConfiguration.StreamConfigurationBuilder clearTags()

rolloverSizeBytes

public StreamConfiguration.StreamConfigurationBuilder rolloverSizeBytes(long rolloverSizeBytes)

API to return segment rollover size. The default value for this field is 0. If default value is passed down to the server, a non-zero value defined in the server will be used for the actual rollover size.

Parameters:

rolloverSizeBytes - The segment rollover size in this stream.

Returns:

this.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object