IN
- The type of the input value.OUT
- The type of the output value.KEY
- The type of the window key.W
- The type of the window.@Internal public class InternalProcessApplyWindowContext<IN,OUT,KEY,W extends Window> extends ProcessWindowFunction.Context
Modifier and Type | Method and Description |
---|---|
long |
currentProcessingTime()
Returns the current processing time.
|
long |
currentWatermark()
Returns the current event-time watermark.
|
KeyedStateStore |
globalState()
State accessor for per-key global state.
|
W |
window()
Returns the window that is being evaluated.
|
KeyedStateStore |
windowState()
State accessor for per-key and per-window state.
|
public W window()
ProcessWindowFunction.Context
window
in class ProcessWindowFunction.Context
public long currentProcessingTime()
ProcessWindowFunction.Context
currentProcessingTime
in class ProcessWindowFunction.Context
public long currentWatermark()
ProcessWindowFunction.Context
currentWatermark
in class ProcessWindowFunction.Context
public KeyedStateStore windowState()
ProcessWindowFunction.Context
NOTE:If you use per-window state you have to ensure that you clean it up
by implementing ProcessWindowFunction.clear(Context)
.
windowState
in class ProcessWindowFunction.Context
public KeyedStateStore globalState()
ProcessWindowFunction.Context
globalState
in class ProcessWindowFunction.Context
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.