object WatermarkRequestStrategy extends Serializable

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.