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
abstract java.lang.String	getInstructionId()
abstract java.lang.String	getPTransformId()
static LogicalEndpoint	of(java.lang.String instructionId, java.lang.String transformId)

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

getPTransformId

public abstract java.lang.String getPTransformId()

of

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