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

Class RemoteGrpcPortRead

java.lang.Object

org.apache.beam.sdk.fn.data.RemoteGrpcPortRead

public abstract class RemoteGrpcPortRead
extends Object

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

Field Summary

Fields

Modifier and Type	Field	Description
static final String	URN

Constructor Summary

Constructors

Constructor	Description
RemoteGrpcPortRead()

Method Summary

Modifier and Type	Method	Description
static RemoteGrpcPortRead	fromPTransform(org.apache.beam.model.pipeline.v1.RunnerApi.PTransform pTransform)
abstract org.apache.beam.model.fnexecution.v1.BeamFnApi.RemoteGrpcPort	getPort()
static RemoteGrpcPortRead	readFromPort(org.apache.beam.model.fnexecution.v1.BeamFnApi.RemoteGrpcPort port, String outputPCollectionId)
org.apache.beam.model.pipeline.v1.RunnerApi.PTransform	toPTransform()

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

RemoteGrpcPortRead

public RemoteGrpcPortRead()

Method Details

readFromPort

public static RemoteGrpcPortRead readFromPort(org.apache.beam.model.fnexecution.v1.BeamFnApi.RemoteGrpcPort port,
 String outputPCollectionId)

fromPTransform

public static RemoteGrpcPortRead 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

toPTransform

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

getPort

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