Package org.apache.beam.sdk.schemas.transforms

Class Join.FieldsEqual

java.lang.Object

org.apache.beam.sdk.schemas.transforms.Join.FieldsEqual

Enclosing class:

Join

public static class Join.FieldsEqual
extends Object

Predicate object to specify fields to compare when doing an equi-join.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Join.FieldsEqual.Impl	Implementation class for FieldsEqual.

Constructor Summary

Constructors

Constructor	Description
FieldsEqual()

Method Summary

Modifier and Type	Method	Description
static Join.FieldsEqual.Impl	left(Integer... fieldIds)
static Join.FieldsEqual.Impl	left(String... fieldNames)
static Join.FieldsEqual.Impl	left(FieldAccessDescriptor fieldAccessDescriptor)
Join.FieldsEqual.Impl	right(Integer... fieldIds)
Join.FieldsEqual.Impl	right(String... fieldNames)
Join.FieldsEqual.Impl	right(FieldAccessDescriptor fieldAccessDescriptor)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FieldsEqual

public FieldsEqual()

Method Details

left

public static Join.FieldsEqual.Impl left(String... fieldNames)

left

public static Join.FieldsEqual.Impl left(Integer... fieldIds)

left

public static Join.FieldsEqual.Impl left(FieldAccessDescriptor fieldAccessDescriptor)

right

public Join.FieldsEqual.Impl right(String... fieldNames)

right

public Join.FieldsEqual.Impl right(Integer... fieldIds)

right

public Join.FieldsEqual.Impl right(FieldAccessDescriptor fieldAccessDescriptor)