Package org.apache.beam.runners.fnexecution.control

Class DefaultJobBundleFactory.WrappedSdkHarnessClient

java.lang.Object

org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.WrappedSdkHarnessClient

Enclosing class:

DefaultJobBundleFactory

protected static class DefaultJobBundleFactory.WrappedSdkHarnessClient
extends Object

Holder for an SdkHarnessClient along with its associated state and data servers. As of now, there is a 1:1 relationship between data services and harness clients. The servers are packaged here to tie server lifetimes to harness client lifetimes.

Method Summary

Modifier and Type	Method	Description
void	close()

Methods inherited from class java.lang.Object

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

Method Details

close

public void close()