Package org.apache.beam.runners.portability

package org.apache.beam.runners.portability

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

Related Packages

Package	Description
org.apache.beam.runners.portability.testing	Testing utilities for the reference runner.

Class	Description
CloseableResource<T>	An AutoCloseable that wraps a resource that needs to be cleaned up but does not implement AutoCloseable itself.
CloseableResource.CloseException	An exception that wraps errors thrown while a resource is being closed.
CloseableResource.Closer<T>	A function that knows how to clean up after a resource.
PortableMetrics
PortableRunner	A PipelineRunner a Pipeline against a JobService.
PortableRunnerRegistrar	Registrar for the portable runner.