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