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
All Methods Instance Methods Concrete Methods 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 toEventStreamWriter.noteTime(long)
which the timestamp should be considered valid before it is forgotten.java.lang.String
toString()
-
-
-
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 toEventStreamWriter.noteTime(long)
which the timestamp should be considered valid before it is forgotten. Meaning that after this long of not callingEventStreamWriter.noteTime(long)
the writer will be forgotten. If there are no known writers, readers that callEventStreamReader.getCurrentTimeWindow(Stream)
will receive a `null` when they are at the corresponding position in the stream.- Parameters:
timestampAggregationTimeout
- The duration after the last call toEventStreamWriter.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 classjava.lang.Object
-
-