public static interface KeyedStateReaderFunction.Context
KeyedStateReaderFunction
's can use for getting additional data about an input
record.
The context is only valid for the duration of a KeyedStateReaderFunction.readKey(Object, Context, Collector)
call. Do not store the context and use
afterwards!
Modifier and Type | Method and Description |
---|---|
Set<Long> |
registeredEventTimeTimers() |
Set<Long> |
registeredProcessingTimeTimers() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.