object WatermarkRequestStrategy extends Serializable
- Source
- ActorSubscriber.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- WatermarkRequestStrategy
- Serializable
- Serializable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Value Members
-
def
apply(highWatermark: Int): WatermarkRequestStrategy
Create WatermarkRequestStrategy with
lowWatermark
as half of the specifiedhighWatermark
.