@Internal public class TimestampAssignerWrapper<T> extends Object implements Timestamper<T>
TimestampAssigner
into a Timestamper
.Constructor and Description |
---|
TimestampAssignerWrapper(TimestampAssigner<T> assigner) |
public TimestampAssignerWrapper(TimestampAssigner<T> assigner)
public long timestamp(T element)
timestamp
in interface Timestamper<T>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.