public static class SqsReadSchemaTransformProvider.SqsMessageToBeamRow extends java.lang.Object implements SerializableFunction<SqsMessage,Row>
Constructor and Description |
---|
SqsMessageToBeamRow() |
Modifier and Type | Method and Description |
---|---|
Row |
apply(SqsMessage input)
Returns the result of invoking this function on the given input.
|
public Row apply(SqsMessage input)
SerializableFunction
apply
in interface ProcessFunction<SqsMessage,Row>
apply
in interface SerializableFunction<SqsMessage,Row>