make-streams

Splits the input stream into multiple output streams based on the distinct values of one or more columns.

Spec

... | make-streams <column> [, ...]

Parameters

column - One or more columns whose distinct values determine how the stream is split.

Return Value

Multiple output streams, one per unique combination of the specified column values.

Example

datatable(Service:string, Level:string, Message:string)
[
    "web", "info", "request started",
    "web", "error", "timeout",
    "api", "info", "healthy"
]
| make-streams Service

#	Service	Level	Message
0	web	info	request started
1	web	error	timeout
2	api	info	healthy