Class 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
    • Method Detail

      • getScalingPolicy

        public ScalingPolicy getScalingPolicy()
        API to return scaling policy.
        Returns:
        Scaling Policy for the Stream.
      • getTimestampAggregationTimeout

        public long getTimestampAggregationTimeout()
        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. 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 class java.lang.Object
      • canEqual

        protected boolean canEqual​(java.lang.Object other)
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object