Package io.pravega.client.stream
Class StreamConfiguration
- java.lang.Object
-
- io.pravega.client.stream.StreamConfiguration
-
- All Implemented Interfaces:
java.io.Serializable
public class StreamConfiguration extends java.lang.Object implements java.io.Serializable
The configuration of a Stream.- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
StreamConfiguration.StreamConfigurationBuilder
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static StreamConfiguration.StreamConfigurationBuilder
builder()
protected boolean
canEqual(java.lang.Object other)
boolean
equals(java.lang.Object o)
RetentionPolicy
getRetentionPolicy()
API to return retention policy.ScalingPolicy
getScalingPolicy()
API to return scaling policy.long
getTimestampAggregationTimeout()
The duration after the last call toEventStreamWriter.noteTime(long)
which the timestamp should be considered valid before it is forgotten.int
hashCode()
java.lang.String
toString()
-
-
-
Method Detail
-
builder
public static StreamConfiguration.StreamConfigurationBuilder builder()
-
getScalingPolicy
public ScalingPolicy getScalingPolicy()
API to return scaling policy.- Returns:
- Scaling Policy for the Stream.
-
getRetentionPolicy
public RetentionPolicy getRetentionPolicy()
API to return retention policy. Also see:ReaderGroupConfig.StreamDataRetention
- Returns:
- Retention Policy for the Stream.
-
getTimestampAggregationTimeout
public long getTimestampAggregationTimeout()
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. which the timestamp should be considered valid before it is forgotten.- Returns:
- The duration after the last call to
EventStreamWriter.noteTime(long)
which the timestamp should be considered valid before it is forgotten.
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
canEqual
protected boolean canEqual(java.lang.Object other)
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-