Interface for working with time and timers.
A reader for a
A writer for a
Inteface for setting and querying the current key of keyed operations.
Interface for stream operators with one input.
A callback registered with the
Stream operators can implement this interface if they need access to the output type information at
Basic interface for stream operators.
This interface represents a context from which a stream operator can initialize everything connected to state such as e.g.
This is the interface through which stream task expose a
Interface for things that can be called by
Interface for stream operators with two inputs.
Base class for all stream operators.
|AbstractUdfStreamOperator<OUT,F extends Function>||
This is used as the base class for operators that have a user-defined function.
|BackendRestorerProcedure<T extends Closeable & Disposable & Snapshotable<?,Collection<S>>,S extends StateObject>||
This class implements the logic that creates (and potentially restores) a state backend.
Internal class for keeping track of in-flight timers.
Serialization proxy for the timer services for a given key-group.
A snapshot of internal timers, containing event and processing timers and the serializers to use to write / read them.
Readers and writers for different versions of the
An entity keeping all the time-related services available to all operators extending the
This class finalizes
|StoppableStreamSource<OUT,SRC extends SourceFunction<OUT> & StoppableFunction>|
will be removed in a future version
Implementation of the
|StreamProject<IN,OUT extends Tuple>||
|StreamSource<OUT,SRC extends SourceFunction<OUT>>||
Source contexts for various stream time characteristics.
This class is the main implementation of a
Defines the chaining scheme for the operator.
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.