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

Class RemoteGrpcPortWrite

java.lang.Object

org.apache.beam.sdk.fn.data.RemoteGrpcPortWrite

public abstract class RemoteGrpcPortWrite
extends Object

An execution-time only RunnerApi.PTransform which represents a write from within an SDK harness to a BeamFnApi.RemoteGrpcPort.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	URN

Constructor Summary

Constructors

Constructor	Description
RemoteGrpcPortWrite()

Method Summary

Modifier and Type	Method	Description
static RemoteGrpcPortWrite	fromPTransform(org.apache.beam.model.pipeline.v1.RunnerApi.PTransform pTransform)
abstract org.apache.beam.model.fnexecution.v1.BeamFnApi.RemoteGrpcPort	getPort()
org.apache.beam.model.pipeline.v1.RunnerApi.PTransform	toPTransform()
static RemoteGrpcPortWrite	writeToPort(String inputPCollectionId, org.apache.beam.model.fnexecution.v1.BeamFnApi.RemoteGrpcPort port)	Create a RemoteGrpcPortWrite which writes the RunnerApi.PCollection with the provided Pipeline id to the provided BeamFnApi.RemoteGrpcPort.

Methods inherited from class java.lang.Object

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

Field Details

URN

public static final String URN

See Also:

• Constant Field Values

Constructor Details

RemoteGrpcPortWrite

public RemoteGrpcPortWrite()

Method Details

writeToPort

public static RemoteGrpcPortWrite writeToPort(String inputPCollectionId,
 org.apache.beam.model.fnexecution.v1.BeamFnApi.RemoteGrpcPort port)

Create a RemoteGrpcPortWrite which writes the RunnerApi.PCollection with the provided Pipeline id to the provided BeamFnApi.RemoteGrpcPort.

fromPTransform

public static RemoteGrpcPortWrite fromPTransform(org.apache.beam.model.pipeline.v1.RunnerApi.PTransform pTransform)
                                          throws org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.InvalidProtocolBufferException

Throws:

org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.InvalidProtocolBufferException

getPort

public abstract org.apache.beam.model.fnexecution.v1.BeamFnApi.RemoteGrpcPort getPort()

toPTransform

public org.apache.beam.model.pipeline.v1.RunnerApi.PTransform toPTransform()