Interface Timestamper<T>
-
- All Superinterfaces:
Function
,Serializable
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@PublicEvolving @FunctionalInterface public interface Timestamper<T> extends Function
Assigns an event time timestamp to the given record. This class does not create watermarks.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description long
timestamp(T element)
-
-
-
Method Detail
-
timestamp
long timestamp(T element)
-
-