public static class BeamSetOperatorsTransforms.BeamSqlRow2KvFn extends SimpleFunction<BeamRecord,KV<BeamRecord,BeamRecord>>
BeamSqlRow
to a KV<BeamSqlRow, BeamSqlRow>
.Constructor and Description |
---|
BeamSqlRow2KvFn() |
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 KV<BeamRecord,BeamRecord> apply(BeamRecord input)
SerializableFunction
apply
in interface SerializableFunction<BeamRecord,KV<BeamRecord,BeamRecord>>
apply
in class SimpleFunction<BeamRecord,KV<BeamRecord,BeamRecord>>