org.apache.flink.datastream.impl.context

类 UnsupportedProcessingTimeManager

java.lang.Object

org.apache.flink.datastream.impl.context.UnsupportedProcessingTimeManager

所有已实现的接口:

org.apache.flink.datastream.api.context.ProcessingTimeManager

public class UnsupportedProcessingTimeManager
extends Object
implements org.apache.flink.datastream.api.context.ProcessingTimeManager

The special implementation of ProcessingTimeManager, all its methods are not supported. This is used for context that can not define the key.

字段概要

字段

限定符和类型	字段和说明
static UnsupportedProcessingTimeManager	INSTANCE

方法概要

限定符和类型	方法和说明
long	currentTime()
void	deleteTimer(long timestamp)
void	registerTimer(long timestamp)

从类继承的方法 java.lang.Object

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

字段详细资料

INSTANCE

public static final UnsupportedProcessingTimeManager INSTANCE

方法详细资料

registerTimer

public void registerTimer(long timestamp)

指定者:

registerTimer 在接口中 org.apache.flink.datastream.api.context.ProcessingTimeManager

deleteTimer

public void deleteTimer(long timestamp)

指定者:

deleteTimer 在接口中 org.apache.flink.datastream.api.context.ProcessingTimeManager

currentTime

public long currentTime()

指定者:

currentTime 在接口中 org.apache.flink.datastream.api.context.ProcessingTimeManager