org.apache.beam.runners.fnexecution.control

Class TimerReceiverFactory

java.lang.Object

org.apache.beam.runners.fnexecution.control.TimerReceiverFactory

All Implemented Interfaces:

OutputReceiverFactory

public class TimerReceiverFactory
extends java.lang.Object
implements OutputReceiverFactory

OutputReceiverFactory that passes outputs to timerDataConsumer.

Constructor Summary

Constructors

Constructor and Description
TimerReceiverFactory(StageBundleFactory stageBundleFactory, java.util.function.BiConsumer<org.apache.beam.sdk.util.WindowedValue,org.apache.beam.runners.core.TimerInternals.TimerData> timerDataConsumer, Coder windowCoder)

Method Summary

Modifier and Type	Method and Description
<OutputT> FnDataReceiver<OutputT>	create(java.lang.String pCollectionId) Get a new RemoteOutputReceiver for an output PCollection.

Methods inherited from class java.lang.Object

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

Constructor Detail

TimerReceiverFactory

public TimerReceiverFactory(StageBundleFactory stageBundleFactory,
                            java.util.function.BiConsumer<org.apache.beam.sdk.util.WindowedValue,org.apache.beam.runners.core.TimerInternals.TimerData> timerDataConsumer,
                            Coder windowCoder)

Method Detail

create

public <OutputT> FnDataReceiver<OutputT> create(java.lang.String pCollectionId)

Description copied from interface: OutputReceiverFactory

Get a new RemoteOutputReceiver for an output PCollection.

This call should only be invoked once per PCollection id per factory.

Specified by:

create in interface OutputReceiverFactory