apache/beam

[Feature Request]: add drain() method to PipelineResult

Open

#38,771 opened on 2026年6月2日

GitHub で見る
 (1 comment) (0 reactions) (1 assignee)Java (4,097 forks)batch import
P3good first issuejavanew feature

Repository metrics

Stars
 (7,313 stars)
PR merge metrics
 (平均マージ 7d 20h) (30d で 227 merged PRs)

説明

What would you like to happen?

both Flink and Dataflow supports that. PipelineResult allow stopping pipeline, drain may be helpful addition.

Issue Priority

Priority: 3 (nice-to-have improvement)

Issue Components

  • Component: Python SDK
  • Component: Java SDK
  • Component: Go SDK
  • Component: Typescript SDK
  • Component: IO connector
  • Component: Beam YAML
  • Component: Beam examples
  • Component: Beam playground
  • Component: Beam katas
  • Component: Website
  • Component: Infrastructure
  • Component: Spark Runner
  • Component: Flink Runner
  • Component: Prism Runner
  • Component: Twister2 Runner
  • Component: Hazelcast Jet Runner
  • Component: Google Cloud Dataflow Runner

コントリビューターガイド