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

Interface ExecutableStageContext

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

DefaultExecutableStageContext

public interface ExecutableStageContext
extends AutoCloseable

The context required in order to execute stages.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	ExecutableStageContext.Factory	Creates ExecutableStageContext instances.

Method Summary

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

Methods inherited from interface java.lang.AutoCloseable

close

Method Details

getStageBundleFactory

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