The Internals of Apache Beam
Home
Products
Product A Product B Product C
Services
Service A Service B Service C
Resources
Resource A Resource B Resource C
Download

Apache Beam

    • Introduction
    • PCollection
    • PTransform
      • GroupByKey
      • MapElements
      • ParDo
        • DoFn
        • WindowedContext
        • ProcessContext
    • Pipeline
      • TransformHierarchy
        • Node
      • PipelineVisitor
    • PipelineResult
    • PipelineOptions
      • PipelineOptionsFactory
      • PipelineOptionsRegistrar
    • PipelineRunner
      • PipelineRunnerRegistrar
    • Values
      • PInput
        • PBegin
      • POutput
        • PDone
      • PValue
      • KV
    • DisplayData
      • HasDisplayData
    • Read
    • Source
      • BoundedSource
        • OffsetBasedSource
        • FileBasedSource
        • BlockBasedSource
        • CompressedSource
        • TextSource
      • UnboundedSource
        • CheckpointMark
    • I/O Utilities
      • Create
      • AvroIO
      • KafkaIO
        • Read
        • Write
      • TextIO
    • Metrics
    • Runners
      • Google Cloud Dataflow
        • DataflowRunner
        • DataflowPipelineOptions
        • DataflowPipelineJob
      • Direct Runner
        • DirectRunner
        • DirectPipelineResult
        • PipelineExecutor
        • EvaluationContext
      • Spark Runner
        • SparkStructuredStreamingRunner
        • SparkStructuredStreamingPipelineOptions
    • Coders
      • Coder
      • CoderProvider
      • CoderProviders
      • DefaultCoder
      • CoderRegistry
      • CoderProviderRegistrar
    • Demo
      • Running Pipeline
      • Custom PTransform
    • Misc
      • PipelineDotRenderer
      • Building Beam
Apache Beam 2.21.0
  • Apache Beam
    • 2.21.0
  • Apache Beam
  • Runners
  • Direct Runner
  • DirectRunner
Edit this Page

DirectRunner

DirectRunner is a PipelineRunner that produces a DirectPipelineResult.

Running Pipeline

DirectPipelineResult run(
  Pipeline pipeline)

run is part of the PipelineRunner abstraction.

This page was built using the Antora default UI.

The source code for this UI is licensed under the terms of the MPL-2.0 license.