stream.scotty.flinkBenchmark

Class BenchmarkJob.TimestampsAndWatermarks

java.lang.Object

flinkBenchmark.stream.scotty.BenchmarkJob.TimestampsAndWatermarks

All Implemented Interfaces:

java.io.Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>, org.apache.flink.streaming.api.functions.TimestampAssigner<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>

Enclosing class:

BenchmarkJob

public static class BenchmarkJob.TimestampsAndWatermarks
extends java.lang.Object
implements org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
private long	currentMaxTimestamp
private long	maxOutOfOrderness
private long	startTime

Constructor Summary

Constructors

Constructor and Description
TimestampsAndWatermarks()

Method Summary

Modifier and Type	Method and Description
long	extractTimestamp(org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> element, long previousElementTimestamp)
org.apache.flink.streaming.api.watermark.Watermark	getCurrentWatermark()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

maxOutOfOrderness

private final long maxOutOfOrderness

currentMaxTimestamp

private long currentMaxTimestamp

startTime

private long startTime

Constructor Detail

TimestampsAndWatermarks

public TimestampsAndWatermarks()

Method Detail

extractTimestamp

public long extractTimestamp(org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> element,
                             long previousElementTimestamp)

Specified by:

extractTimestamp in interface org.apache.flink.streaming.api.functions.TimestampAssigner<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>

getCurrentWatermark

@Nullable
public org.apache.flink.streaming.api.watermark.Watermark getCurrentWatermark()

Specified by:

getCurrentWatermark in interface org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>