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 and Description
static class	ExecutionDriver.DriverState The state of the driver.

Method Summary

Modifier and Type	Method and Description
ExecutionDriver.DriverState	drive()

Method Detail

drive

ExecutionDriver.DriverState drive()