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