Package org.apache.beam.sdk.transforms

Class Watch.Growth.PollFn<InputT,OutputT>

java.lang.Object

org.apache.beam.sdk.transforms.Watch.Growth.PollFn<InputT,OutputT>

All Implemented Interfaces:

Serializable, Contextful.Fn<InputT,Watch.Growth.PollResult<OutputT>>

Enclosing class:

Watch.Growth<InputT,OutputT,KeyT>

public abstract static class Watch.Growth.PollFn<InputT,OutputT>
extends Object
implements Contextful.Fn<InputT,Watch.Growth.PollResult<OutputT>>

A function that computes the current set of outputs for the given input, in the form of a Watch.Growth.PollResult.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.transforms.Contextful.Fn

Contextful.Fn.Context

Constructor Summary

Constructors

Constructor	Description
PollFn()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.beam.sdk.transforms.Contextful.Fn

apply

Constructor Details

PollFn

public PollFn()