Package org.apache.beam.runners.fnexecution.control

Class TimerReceiverFactory

java.lang.Object

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

public class TimerReceiverFactory
extends 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	Description
TimerReceiverFactory(StageBundleFactory stageBundleFactory, BiConsumer<org.apache.beam.sdk.util.construction.Timer<?>,org.apache.beam.runners.core.TimerInternals.TimerData> timerDataConsumer, Coder windowCoder)

Method Summary

Modifier and Type	Method	Description
<K> FnDataReceiver<org.apache.beam.sdk.util.construction.Timer<K>>	create(String transformId, String timerFamilyId)
static KV<String,String>	decodeTimerDataTimerId(String timerDataTimerId)	Decodes a string into the transform and timer family ids.
static String	encodeToTimerDataTimerId(String transformId, 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 Details

TimerReceiverFactory

public TimerReceiverFactory(StageBundleFactory stageBundleFactory,
 BiConsumer<org.apache.beam.sdk.util.construction.Timer<?>,org.apache.beam.runners.core.TimerInternals.TimerData> timerDataConsumer,
 Coder windowCoder)

Method Details

create

public <K>
FnDataReceiver<org.apache.beam.sdk.util.construction.Timer<K>> create(String transformId,
 String timerFamilyId)

encodeToTimerDataTimerId

public static String encodeToTimerDataTimerId(String transformId,
 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<String,String> decodeTimerDataTimerId(String timerDataTimerId)

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