apache/beam

Standardize naming of PipelineResult objects

Aberta

#18.064 aberto em 3 de jun. de 2022

 (4 comentários) (0 reação) (0 responsável)Java (4.097 forks)batch import
P3coregood first issueimprovementjavapython

Métricas do repositório

Stars
 (7.313 estrelas)
Métricas de merge de PR
 (Métricas PR pendentes)

Description

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.

Guia do colaborador