Structs
A context structure made available to the callbacks of a OneInOneOut operator. The context
provides access to the current timestamp for which the callback is invoked along with the
state of the operator and the write stream to send the outputs on.
A context structure made available to the callbacks of a OneInTwoOut operator. The context
provides access to the current timestamp for which the callback is invoked along with the
state of the operator and the write streams to send the outputs on.
A context structure made available to the callbacks of a ParallelOneInOneOut operator. The
context provides access to the current timestamp for which the callback is invoked along with
the state of the operator and the write stream to send the outputs on.
A context structure made available to the callbacks of a ParallelOneInTwoOut operator. The
context provides access to the current timestamp for which the callback is invoked along with
the state of the operator and the write streams to send the outputs on.
A context structure made available to the callbacks of a ParallelSink operator. The context
provides access to the current timestamp for which the callback is invoked along with the state
of the operator.
A context structure made available to the callbacks of a ParallelTwoInOneOut operator. The
context provides access to the current timestamp for which the callback is invoked along with
the state of the operator and the write stream to send the outputs on.
A SetupContext is made available to an operator’s setup method, and allows the operators to
register deadlines for events along with their corresponding handlers. The generic type S is
the State registered with the operator.
A context structure made available to the callbacks of a Sink operator. The context provides
access to the current timestamp for which the callback is invoked along with the state
of the operator.
A context structure made available to the callbacks of a TwoInOneOut operator. The context
provides access to the current timestamp for which the callback is invoked along with the
state of the operator and the write stream to send the outputs on.