Skip to content

Commit

Permalink
Merge pull request apache#12008: [BEAM-9951] Fixing some lint bugs.
Browse files Browse the repository at this point in the history
  • Loading branch information
youngoli committed Jun 15, 2020
2 parents dc8df09 + 439cee7 commit bf0117b
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions sdks/go/pkg/beam/io/synthetic/step.go
Original file line number Diff line number Diff line change
Expand Up @@ -47,9 +47,8 @@ func Step(s beam.Scope, cfg StepConfig, col beam.PCollection) beam.PCollection {
s = s.Scope("synthetic.Step")
if cfg.Splittable {
return beam.ParDo(s, &sdfStepFn{cfg: cfg}, col)
} else {
return beam.ParDo(s, &stepFn{cfg: cfg}, col)
}
return beam.ParDo(s, &stepFn{cfg: cfg}, col)
}

// stepFn is a DoFn implementing behavior for synthetic steps. For usage
Expand Down Expand Up @@ -150,7 +149,7 @@ type StepConfigBuilder struct {
cfg StepConfig
}

// DefaultSourceConfig creates a StepConfig with intended defaults for the
// DefaultStepConfig creates a StepConfig with intended defaults for the
// StepConfig fields. This function is the intended starting point for
// initializing a StepConfig and should always be used to create
// StepConfigBuilders.
Expand Down

0 comments on commit bf0117b

Please sign in to comment.