public abstract static class WindowAssigner.WindowAssignerContext extends Object
WindowAssigner
that allows it to query the
current processing time.
This is provided to the assigner by its containing
WindowOperator
,
which, in turn, gets it from the containing
StreamTask
.
Constructor and Description |
---|
WindowAssignerContext() |
Modifier and Type | Method and Description |
---|---|
abstract long |
getCurrentProcessingTime()
Returns the current processing time, as returned by
the
StreamTask.getCurrentProcessingTime() . |
public abstract long getCurrentProcessingTime()
StreamTask.getCurrentProcessingTime()
.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.