Skip to content

Commit

Permalink
periodic: remove defunct Setup
Browse files Browse the repository at this point in the history
  • Loading branch information
hnnsgstfssn committed Mar 20, 2023
1 parent 6af6dce commit de762ce
Showing 1 changed file with 0 additions and 3 deletions.
3 changes: 0 additions & 3 deletions sdks/go/pkg/beam/transforms/periodic/periodic.go
Original file line number Diff line number Diff line change
Expand Up @@ -47,9 +47,6 @@ type SequenceDefinition struct {

type sequenceGenDoFn struct{}

func (fn *sequenceGenDoFn) Setup() {
}

func (fn *sequenceGenDoFn) CreateInitialRestriction(sd SequenceDefinition) offsetrange.Restriction {
totalOutputs := mtime.Time(sd.End).ToTime().Sub(mtime.Time(sd.Start).ToTime()) / sd.Interval
return offsetrange.Restriction{
Expand Down

0 comments on commit de762ce

Please sign in to comment.