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 java.lang.Object

Constructor Summary

Constructors

Constructor and Description
TimerEndpoint()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

TimerEndpoint

public TimerEndpoint()

Method Detail

create

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

getTransformId

public abstract java.lang.String getTransformId()

getTimerFamilyId

public abstract java.lang.String getTimerFamilyId()

getCoder

public abstract Coder<T> getCoder()

getReceiver

public abstract FnDataReceiver<T> getReceiver()