Skip to content

Commit

Permalink
[BEAM-9951] Fixing some lint bugs.
Browse files Browse the repository at this point in the history
  • Loading branch information
youngoli committed Jun 13, 2020
1 parent b0d8f3b commit 439cee7
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 439cee7

Please sign in to comment.