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 BeamFnApi.Target 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
abstract java.lang.String	getInstructionId()
abstract org.apache.beam.model.fnexecution.v1.BeamFnApi.Target	getTarget()
static LogicalEndpoint	of(java.lang.String instructionId, org.apache.beam.model.fnexecution.v1.BeamFnApi.Target target)

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()

getTarget

public abstract org.apache.beam.model.fnexecution.v1.BeamFnApi.Target getTarget()

of

public static LogicalEndpoint of(java.lang.String instructionId,
                                 org.apache.beam.model.fnexecution.v1.BeamFnApi.Target target)