Package org.apache.airflow.sdk
Class Builder
-
- All Implemented Interfaces:
public final class BuilderContainer for the annotation-based Dag-authoring API.
This class is not instantiated directly. Its nested annotations drive the BuilderProcessor annotation processor, which generates a
*Builderclass for each class annotated with Dag.Example:
@Builder.Dag(id = "my_pipeline") public class MyPipeline { @Builder.Task(id = "extract") public long extract(Client client) { ... } @Builder.Task(id = "transform") public long transform(Client client, @Builder.XCom(task = "extract") long extracted) { ... } }The processor generates
MyPipelineBuilder.build(), which returns a fully wired-up Dag ready to add to a Bundle.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public @interfaceBuilder.DagAnnotation to automate a Dag-builder pattern.
When applied on a class Foo, this generates a FooBuilder class with a static build method to create the Dag structure automatically.
public @interfaceBuilder.TaskAnnotation to automate task definition in a Dag-builder pattern.
public @interfaceBuilder.XComAnnotation to mark a task definition's method parameter as an XCom input.
-