org.apache.beam.runners.fnexecution.control

Class TimerReceiverFactory

java.lang.Object

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

public class TimerReceiverFactory
extends java.lang.Object

A factory that passes timers to timerDataConsumer.

The constructed timers uses len(transformId):transformId:timerId as the timer id to prevent string collisions. See encodeToTimerDataTimerId(java.lang.String, java.lang.String) and decodeTimerDataTimerId(java.lang.String) for functions to aid with encoding and decoding.

If the incoming timer is being cleared, the TimerInternals.TimerData sets the fire and hold timestamps to BoundedWindow.TIMESTAMP_MAX_VALUE.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
<K> FnDataReceiver<org.apache.beam.runners.core.construction.Timer<K>>	create(java.lang.String transformId, java.lang.String timerFamilyId)
static KV<java.lang.String,java.lang.String>	decodeTimerDataTimerId(java.lang.String timerDataTimerId) Decodes a string into the transform and timer family ids.
static java.lang.String	encodeToTimerDataTimerId(java.lang.String transformId, java.lang.String timerFamilyId) Encodes transform and timer family ids into a single string which retains the human readable format len(transformId):transformId:timerId.

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.runners.core.construction.Timer<?>,org.apache.beam.runners.core.TimerInternals.TimerData> timerDataConsumer,
                            Coder windowCoder)

Method Detail

create

public <K> FnDataReceiver<org.apache.beam.runners.core.construction.Timer<K>> create(java.lang.String transformId,
                                                                                     java.lang.String timerFamilyId)

encodeToTimerDataTimerId

public static java.lang.String encodeToTimerDataTimerId(java.lang.String transformId,
                                                        java.lang.String timerFamilyId)

Encodes transform and timer family ids into a single string which retains the human readable format len(transformId):transformId:timerId. See decodeTimerDataTimerId(java.lang.String) for decoding.

decodeTimerDataTimerId

public static KV<java.lang.String,java.lang.String> decodeTimerDataTimerId(java.lang.String timerDataTimerId)

Decodes a string into the transform and timer family ids. See encodeToTimerDataTimerId(java.lang.String, java.lang.String) for encoding.