public static class BeamJoinTransforms.JoinParts2WholeRow extends SimpleFunction<KV<BeamRecord,KV<BeamRecord,BeamRecord>>,BeamRecord>
SimpleFunction
to combine two rows into one.Constructor and Description |
---|
JoinParts2WholeRow() |
Modifier and Type | Method and Description |
---|---|
BeamRecord |
apply(KV<BeamRecord,KV<BeamRecord,BeamRecord>> input)
Returns the result of invoking this function on the given input.
|
fromSerializableFunctionWithOutputType, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData
public BeamRecord apply(KV<BeamRecord,KV<BeamRecord,BeamRecord>> input)
SerializableFunction
apply
in interface SerializableFunction<KV<BeamRecord,KV<BeamRecord,BeamRecord>>,BeamRecord>
apply
in class SimpleFunction<KV<BeamRecord,KV<BeamRecord,BeamRecord>>,BeamRecord>