public abstract class WatermarkParameters
extends java.lang.Object
implements java.io.Serializable
WatermarkParameters
contains the parameters used for watermark computation.Constructor and Description |
---|
WatermarkParameters() |
Modifier and Type | Method and Description |
---|---|
static org.apache.beam.sdk.io.aws2.kinesis.WatermarkParameters.Builder |
builder() |
static WatermarkParameters |
create() |
abstract org.apache.beam.sdk.io.aws2.kinesis.WatermarkParameters.Builder |
toBuilder() |
WatermarkParameters |
withTimestampFn(SerializableFunction<KinesisRecord,Instant> timestampFn)
Specify the
SerializableFunction to extract the event time from a KinesisRecord . |
WatermarkParameters |
withWatermarkIdleDurationThreshold(Duration idleDurationThreshold)
Specify the watermark idle duration to consider before advancing the watermark.
|
public abstract org.apache.beam.sdk.io.aws2.kinesis.WatermarkParameters.Builder toBuilder()
public static org.apache.beam.sdk.io.aws2.kinesis.WatermarkParameters.Builder builder()
public static WatermarkParameters create()
public WatermarkParameters withTimestampFn(SerializableFunction<KinesisRecord,Instant> timestampFn)
SerializableFunction
to extract the event time from a KinesisRecord
. The default event timestamp is the arrival timestamp of the record.timestampFn
- Serializable function to extract the timestamp from a record.public WatermarkParameters withWatermarkIdleDurationThreshold(Duration idleDurationThreshold)