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

Interface JobBundleFactory

All Superinterfaces:
AutoCloseable
All Known Implementing Classes:
DefaultJobBundleFactory, SingleEnvironmentInstanceJobBundleFactory
public interface JobBundleFactory extends AutoCloseable
A factory that has all job-scoped information, and can be combined with stage-scoped information to create a StageBundleFactory.

Releases all job-scoped resources when closed.

  • Method Summary

    Modifier and Type
    Method
    Description
    StageBundleFactory
    forStage(org.apache.beam.sdk.util.construction.graph.ExecutableStage executableStage)
     

    Methods inherited from interface java.lang.AutoCloseable

    close

  • Method Details

    • forStage

      StageBundleFactory forStage(org.apache.beam.sdk.util.construction.graph.ExecutableStage executableStage)