MessagesBuilder returns an empty instance of Messages.

MessageTo creates a Message that will forward to specified "to".

MessageToAll creates a Message that will forward to all.

MessageToDrop creates a Message to be dropped.

MessageTsBuilder returns an empty instance of MessageTs.

MessageTTo creates a MessageT that will forward to specified "to".

MessageTToAll creates a MessageT that will forward to all.

MessageTToDrop creates a MessageT to be dropped.

DefaultMaxMessageSize overrides gRPC max message size configuration https://github.com/grpc/grpc-go/blob/master/server.go#L58-L59 - defaultServerMaxReceiveMessageSize - defaultServerMaxSendMessageSize.

U+005C__ALL__.

U+005C__DROP__.

Message is used to wrap the data return by UDF functions.

MessageT is used to wrap the data return by UDF functions.

Service implements the proto gen server interface and contains the map operation handler and the reduce operation handler.

Client contains methods to call a gRPC client.

Datum contains methods to get the payload information.

IntervalWindow contains methods to get the information for a given interval window.

MapHandler is the interface of map function implementation.

MapTHandler is the interface of mapT function implementation.

Metadata contains methods to get the metadata for the reduce operation.

ReduceHandler is the interface of reduce function implementation.

MapFunc is utility type used to convert a HandleDo function to a MapHandler.

MapTFunc is utility type used to convert a HandleDo function to a MapTHandler.

ReduceFunc is utility type used to convert a HandleDo function to a ReduceHandler.