org.wikimedia.eventutilities.flink.stream

Class EventTimeAssigner

java.lang.Object

org.wikimedia.eventutilities.flink.stream.EventTimeAssigner

public final class EventTimeAssigner
extends Object

Creates a flink TimestampAssigner that extracts the event time.

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.api.common.eventtime.SerializableTimestampAssigner<org.apache.flink.types.Row>	create() A timestamp extractor that reads the event time field from Event Platform events.

Methods inherited from class java.lang.Object

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

Method Detail

create

public static org.apache.flink.api.common.eventtime.SerializableTimestampAssigner<org.apache.flink.types.Row> create()

A timestamp extractor that reads the event time field from Event Platform events.