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.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.