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:

java.io.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 java.lang.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 and 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 Detail

PollFn

public PollFn()