org.apache.beam.sdk.fn.data

Class LogicalEndpoint

java.lang.Object

org.apache.beam.sdk.fn.data.LogicalEndpoint

public abstract class LogicalEndpoint
extends java.lang.Object

A logical endpoint is a pair of an instruction ID corresponding to the BeamFnApi.ProcessBundleRequest and the transform within the processing graph. This enables the same Data Service or Data Client to be re-used across multiple bundles.

Constructor Summary

Constructors

Constructor and Description
LogicalEndpoint()

Method Summary

Modifier and Type	Method and Description
static LogicalEndpoint	data(java.lang.String instructionId, java.lang.String transformId)
abstract java.lang.String	getInstructionId()
abstract java.lang.String	getTimerFamilyId()
abstract java.lang.String	getTransformId()
boolean	isTimer()
static LogicalEndpoint	timer(java.lang.String instructionId, java.lang.String transformId, java.lang.String timerFamilyId)

Methods inherited from class java.lang.Object

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

Constructor Detail

LogicalEndpoint

public LogicalEndpoint()

Method Detail

getInstructionId

public abstract java.lang.String getInstructionId()

getTransformId

public abstract java.lang.String getTransformId()

getTimerFamilyId

@Nullable
public abstract java.lang.String getTimerFamilyId()

isTimer

public boolean isTimer()

data

public static LogicalEndpoint data(java.lang.String instructionId,
                                   java.lang.String transformId)

timer

public static LogicalEndpoint timer(java.lang.String instructionId,
                                    java.lang.String transformId,
                                    java.lang.String timerFamilyId)