apache/beam

Standardize naming of PipelineResult objects

Open

#18.064 aperta il 3 giu 2022

Vedi su GitHub
 (4 commenti) (0 reazioni) (0 assegnatari)Java (4097 fork)batch import
P3coregood first issueimprovementjavapython

Metriche repository

Star
 (7313 star)
Metriche merge PR
 (Merge medio 6g) (243 PR mergiate in 30 g)

Descrizione

Today:

PipelineResult is an interface returned by running a pipeline. DataflowPipelineJob is the Dataflow implementation of that interface FlinkRunnerResult is the Flink implementation EvaluationContext is the Spark implementation DirectPipelineResult is the DirectRunner implementation

Ideally, all the names would indicate that they are a PipelineResult, like the DirectRunner does.

Imported from Jira BEAM-726. Original Jira may contain additional context. Reported by: bchambers.

Guida contributor