object WatermarkRequestStrategy extends Serializable

Source
ActorSubscriber.scala
Linear Supertypes
Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. WatermarkRequestStrategy
  2. Serializable
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def apply(highWatermark: Int): WatermarkRequestStrategy

    Create WatermarkRequestStrategy with lowWatermark as half of the specified highWatermark.