org.apache.beam.runners.fnexecution.control

Class SdkHarnessClient.RemoteInputDestination<T>

java.lang.Object

org.apache.beam.runners.fnexecution.control.SdkHarnessClient.RemoteInputDestination<T>

Enclosing class:

SdkHarnessClient

public abstract static class SdkHarnessClient.RemoteInputDestination<T>
extends java.lang.Object

A pair of Coder and BeamFnApi.Target which can be handled by the remote SDK harness to receive elements sent from the runner.

Constructor Summary

Constructors

Constructor and Description
RemoteInputDestination()

Method Summary

Modifier and Type	Method and Description
abstract Coder<T>	getCoder()
abstract org.apache.beam.model.fnexecution.v1.BeamFnApi.Target	getTarget()
static <T> SdkHarnessClient.RemoteInputDestination<T>	of(Coder<T> coder, 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

RemoteInputDestination

public RemoteInputDestination()

Method Detail

of

public static <T> SdkHarnessClient.RemoteInputDestination<T> of(Coder<T> coder,
                                                                org.apache.beam.model.fnexecution.v1.BeamFnApi.Target target)

getCoder

public abstract Coder<T> getCoder()

getTarget

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