org.apache.flink.datastream.impl.context

类 DefaultProcessingTimeManager

java.lang.Object

org.apache.flink.datastream.impl.context.DefaultProcessingTimeManager

所有已实现的接口:

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

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

The default implementation of ProcessingTimeManager.

构造器概要

构造器

构造器和说明
DefaultProcessingTimeManager(org.apache.flink.streaming.api.operators.InternalTimerService<org.apache.flink.runtime.state.VoidNamespace> timerService)

方法概要

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

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

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

构造器详细资料

DefaultProcessingTimeManager

public DefaultProcessingTimeManager(org.apache.flink.streaming.api.operators.InternalTimerService<org.apache.flink.runtime.state.VoidNamespace> timerService)

方法详细资料

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