Apache Beam Java SDK Extensions

Join-library

Join-library provides inner join, outer left join, and outer right join functions. The aim is to simplify the most common cases of join to a simple function call.

The functions are generic and support joins of any Beam-supported types. Input to the join functions are PCollections of Key / Values. Both the left and right PCollections need the same type for the key. All the join functions return a Key / Value where