Class WatermarkRequestStrategy$

  • All Implemented Interfaces:
    java.io.Serializable, scala.Serializable

    public class WatermarkRequestStrategy$
    extends java.lang.Object
    implements scala.Serializable
    Create WatermarkRequestStrategy with lowWatermark as half of the specified highWatermark.
    See Also:
    Serialized Form
    • Field Detail

      • MODULE$

        public static final WatermarkRequestStrategy$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • WatermarkRequestStrategy$

        public WatermarkRequestStrategy$()
    • Method Detail

      • apply

        public WatermarkRequestStrategy apply​(int highWatermark,
                                              int lowWatermark)
        Requests up to the highWatermark when the remainingRequested is below the lowWatermark. This a good strategy when the actor performs work itself.
        Parameters:
        highWatermark - (undocumented)
        lowWatermark - (undocumented)
        Returns:
        (undocumented)
      • unapply

        public scala.Option<scala.Tuple2<java.lang.Object,​java.lang.Object>> unapply​(WatermarkRequestStrategy x$0)