Home

Welcome to the Gleam wiki!

Architecture

• Gleam data transfer format

Gleam APIs

• Source() TextFile() Lines() Slice() Channel()
• Pipe() and PipeArgs()
• Partition()
• Map() ForEach() FlatMap() Filter()
• Reduce() ReduceByKey()
• Sort()
• Join() CoGroup()
• Output() SaveTextTo()

Examples

• Joined Word Count used APIs: Join(), Script(), Pipe(), SaveTextTo()