public static class BeamJoinTransforms.ExtractJoinFields extends SimpleFunction<BeamRecord,KV<BeamRecord,BeamRecord>>
SimpleFunction
to extract join fields from the specified row.Constructor and Description |
---|
ExtractJoinFields(boolean isLeft,
java.util.List<<any>> joinColumns) |
Modifier and Type | Method and Description |
---|---|
KV<BeamRecord,BeamRecord> |
apply(BeamRecord input)
Returns the result of invoking this function on the given input.
|
fromSerializableFunctionWithOutputType, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData
public ExtractJoinFields(boolean isLeft, java.util.List<<any>> joinColumns)
public KV<BeamRecord,BeamRecord> apply(BeamRecord input)
SerializableFunction
apply
in interface SerializableFunction<BeamRecord,KV<BeamRecord,BeamRecord>>
apply
in class SimpleFunction<BeamRecord,KV<BeamRecord,BeamRecord>>