public static class BeamJoinTransforms.ExtractJoinFields extends SimpleFunction<Row,KV<Row,Row>>
SimpleFunction
to extract join fields from the specified row.Constructor and Description |
---|
ExtractJoinFields(boolean isLeft,
java.util.List<org.apache.calcite.util.Pair<java.lang.Integer,java.lang.Integer>> joinColumns,
Schema schema) |
Modifier and Type | Method and Description |
---|---|
KV<Row,Row> |
apply(Row input)
Returns the result of invoking this function on the given input.
|
fromSerializableFunctionWithOutputType, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData
public ExtractJoinFields(boolean isLeft, java.util.List<org.apache.calcite.util.Pair<java.lang.Integer,java.lang.Integer>> joinColumns, Schema schema)