Class CoGroup.By

  • All Implemented Interfaces:
    java.io.Serializable
    Enclosing class:
    CoGroup

    public abstract static class CoGroup.By
    extends java.lang.Object
    implements java.io.Serializable
    Defines the set of fields to extract for the join key, as well as other per-input join options.
    See Also:
    Serialized Form
    • Constructor Detail

      • By

        public By()
    • Method Detail

      • fieldNames

        public static CoGroup.By fieldNames​(java.lang.String... fieldNames)
        Join by the following field names.
      • fieldIds

        public static CoGroup.By fieldIds​(java.lang.Integer... fieldIds)
        Join by the following field ids.
      • fieldAccessDescriptor

        public static CoGroup.By fieldAccessDescriptor​(FieldAccessDescriptor fieldAccessDescriptor)
        Join by the following field access descriptor.
      • withOptionalParticipation

        public CoGroup.By withOptionalParticipation()
        Means that this field will participate in a join even when not present, similar to SQL outer-join semantics. Missing entries will be replaced by nulls.

        This only affects the results of expandCrossProduct.

      • withSideInput

        public CoGroup.By withSideInput()