org.apache.beam.sdk.fn.data

Class RemoteGrpcPortWrite

java.lang.Object

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

public abstract class RemoteGrpcPortWrite
extends java.lang.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 and Description
static java.lang.String	URN

Constructor Summary

Constructors

Constructor and Description
RemoteGrpcPortWrite()

Method Summary

Modifier and Type	Method and 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(java.lang.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 Detail

URN

public static final java.lang.String URN

See Also:

Constant Field Values

Constructor Detail

RemoteGrpcPortWrite

public RemoteGrpcPortWrite()

Method Detail

writeToPort

public static RemoteGrpcPortWrite writeToPort(java.lang.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 com.google.protobuf.InvalidProtocolBufferException

Throws:

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