Package org.apache.beam.sdk.fn.data

Class TimerEndpoint<T>

java.lang.Object

org.apache.beam.sdk.fn.data.TimerEndpoint<T>

public abstract class TimerEndpoint<T>
extends Object

Constructor Summary

Constructors

Constructor	Description
TimerEndpoint()

Method Summary

Modifier and Type	Method	Description
static <T> TimerEndpoint<T>	create(String transformId, String timerFamilyId, Coder<T> coder, FnDataReceiver<T> receiver)
abstract Coder<T>	getCoder()
abstract FnDataReceiver<T>	getReceiver()
abstract String	getTimerFamilyId()
abstract String	getTransformId()

Methods inherited from class java.lang.Object

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

Constructor Details

TimerEndpoint

public TimerEndpoint()

Method Details

create

public static <T> TimerEndpoint<T> create(String transformId,
 String timerFamilyId,
 Coder<T> coder,
 FnDataReceiver<T> receiver)

getTransformId

public abstract String getTransformId()

getTimerFamilyId

public abstract String getTimerFamilyId()

getCoder

public abstract Coder<T> getCoder()

getReceiver

public abstract FnDataReceiver<T> getReceiver()