[FLINK-17658] Rename DefaultTimestampAssigner to RecordTimestampAssigner

上级 ba79c0c1
......@@ -24,7 +24,7 @@ import org.apache.flink.annotation.Public;
* A {@link TimestampAssigner} that simply forwards the internal timestamp.
*/
@Public
public final class DefaultTimestampAssigner<E> implements TimestampAssigner<E> {
public final class RecordTimestampAssigner<E> implements TimestampAssigner<E> {
private static final long serialVersionUID = 1L;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册