Package org.apache.beam.sdk.extensions.joinlibrary

package org.apache.beam.sdk.extensions.joinlibrary
Utilities for performing SQL-style joins of keyed PCollections.
  • Classes
    Class
    Description
    Join
    Utility class with different versions of joins.
    Join.FullOuterJoin<K,V1,V2>
    PTransform representing a full outer join of two collections of KV elements.
    Join.InnerJoin<K,V1,V2>
    PTransform representing an inner join of two collections of KV elements.
    Join.LeftOuterJoin<K,V1,V2>
    PTransform representing a left outer join of two collections of KV elements.
    Join.RightOuterJoin<K,V1,V2>
    PTransform representing a right outer join of two collections of KV elements.