Package org.apache.beam.runners.local

Interface ExecutionDriver

public interface ExecutionDriver

Drives the execution of a Pipeline by scheduling work.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	ExecutionDriver.DriverState	The state of the driver.

Method Summary

Modifier and Type	Method	Description
ExecutionDriver.DriverState	drive()

Method Details

drive

ExecutionDriver.DriverState drive()