Package org.apache.beam.runners.reference

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.
PortableRunner	A PipelineRunner a Pipeline against a JobService.
ReferenceRunner	A PipelineRunner that executes a job via the Beam portability framework.

Exception Summary

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

Package org.apache.beam.runners.reference Description

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