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 java.lang.Object

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

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
FieldsEqual()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

FieldsEqual

public FieldsEqual()

Method Detail

left

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

left

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

left

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

right

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

right

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

right

public Join.FieldsEqual.Impl right(FieldAccessDescriptor fieldAccessDescriptor)