org.apache.beam.runners.fnexecution.control

Interface ExecutableStageContext

All Superinterfaces:

java.lang.AutoCloseable

All Known Implementing Classes:

DefaultExecutableStageContext

public interface ExecutableStageContext
extends java.lang.AutoCloseable

The context required in order to execute stages.

Nested Class Summary

Nested Classes

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

Method Summary

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

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

getStageBundleFactory

StageBundleFactory getStageBundleFactory(org.apache.beam.runners.core.construction.graph.ExecutableStage executableStage)