applier

Documentation

Index

• type ReduceApplier

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.