public class BeamJoinTransforms
extends java.lang.Object
PTransform
and DoFn
used to perform JOIN operation.Modifier and Type | Class and Description |
---|---|
static class |
BeamJoinTransforms.JoinAsLookup
Transform to execute Join as Lookup.
|
Constructor and Description |
---|
BeamJoinTransforms() |
Modifier and Type | Method and Description |
---|---|
static FieldAccessDescriptor |
getJoinColumns(boolean isLeft,
java.util.List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.util.Pair<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rex.RexNode,org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rex.RexNode>> joinColumns,
int leftRowColumnCount,
Schema schema) |
public static FieldAccessDescriptor getJoinColumns(boolean isLeft, java.util.List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.util.Pair<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rex.RexNode,org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rex.RexNode>> joinColumns, int leftRowColumnCount, Schema schema)