Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ReduceApplier ¶
type ReduceApplier interface { // ApplyReduce applies the reduce UDF on the stream of window requests and streams the timed window response. // It doesn't wait for the response for all the keys in the window, before sending the response back. ApplyReduce(ctx context.Context, partitionID *partition.ID, messageStream <-chan *window.TimedWindowRequest) (<-chan *window.TimedWindowResponse, <-chan error) }
ReduceApplier applies the GRPCBasedReduceUDF on the stream of read messages and gives back a new message.
Click to show internal directories.
Click to hide internal directories.