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

Class LogicalEndpoint

java.lang.Object

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

public abstract class LogicalEndpoint
extends 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	Description
LogicalEndpoint()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

LogicalEndpoint

public LogicalEndpoint()

Method Details

getInstructionId

public abstract String getInstructionId()

getTransformId

public abstract String getTransformId()

getTimerFamilyId

public abstract @Nullable String getTimerFamilyId()

isTimer

public boolean isTimer()

data

public static LogicalEndpoint data(String instructionId,
 String transformId)

timer

public static LogicalEndpoint timer(String instructionId,
 String transformId,
 String timerFamilyId)