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) until which the writer would be considered for computing EventStreamReader.getCurrentTimeWindow(Stream) Meaning that after this long of not calling EventStreamWriter.noteTime(long) a writer's previously reported time would be ignored for computing the time window.
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) until which the writer would be considered for computing EventStreamReader.getCurrentTimeWindow(Stream) Meaning that after this long of not calling EventStreamWriter.noteTime(long) a writer's previously reported time would be ignored for computing the time window. However, after the timestampAggregationTimeout elapses the same writer may resume noting time at any time. If no writer have noted time within the timestampAggregationTimeout, 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) until which the writer would be considered active. to continue to consider the provided time.

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