Package org.apache.beam.runners.portability

Support for executing a pipeline locally over the Beam fn API.

See: Description

Interface Summary

Interface	Description
CloseableResource.Closer<T>	A function that knows how to clean up after a resource.

Class Summary

Class	Description
CloseableResource<T>	An AutoCloseable that wraps a resource that needs to be cleaned up but does not implement AutoCloseable itself.
PortableMetrics
PortableRunner	A PipelineRunner a Pipeline against a JobService.
PortableRunnerRegistrar	Registrar for the portable runner.

Exception Summary

Exception	Description
CloseableResource.CloseException	An exception that wraps errors thrown while a resource is being closed.

Package org.apache.beam.runners.portability Description

Support for executing a pipeline locally over the Beam fn API.