Interface | Description |
---|---|
BroadcastStateBootstrapFunction.Context |
Context that
BroadcastStateBootstrapFunction 's can use for getting additional data
about an input record. |
KeyedStateReaderFunction.Context |
Context that
KeyedStateReaderFunction 's can use for getting additional data about an
input record. |
StateBootstrapFunction.Context |
Context that
StateBootstrapFunction 's can use for getting additional data about an
input record. |
Timestamper<T> |
Assigns an event time timestamp to the given record.
|
WindowReaderFunction.Context<W extends Window> |
The context holding window metadata.
|
Class | Description |
---|---|
BroadcastStateBootstrapFunction<IN> |
Interface for writing elements to broadcast state.
|
KeyedStateBootstrapFunction<K,IN> |
A function that writes keyed state to a new operator.
|
KeyedStateReaderFunction<K,OUT> |
A function that processes keys from a restored operator
|
StateBootstrapFunction<IN> |
Interface for writing elements to operator state.
|
WindowReaderFunction<IN,OUT,KEY,W extends Window> |
Base abstract class for functions that are evaluated over keyed (grouped) windows using a context
for retrieving extra information.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.