From de762ce4d74ed43ba0f905cfdb053704b6976ee9 Mon Sep 17 00:00:00 2001 From: Hannes Gustafsson Date: Mon, 20 Mar 2023 23:48:32 +0000 Subject: [PATCH] periodic: remove defunct Setup --- sdks/go/pkg/beam/transforms/periodic/periodic.go | 3 --- 1 file changed, 3 deletions(-) diff --git a/sdks/go/pkg/beam/transforms/periodic/periodic.go b/sdks/go/pkg/beam/transforms/periodic/periodic.go index 57b91ee8c38f..4f0f6e802dad 100644 --- a/sdks/go/pkg/beam/transforms/periodic/periodic.go +++ b/sdks/go/pkg/beam/transforms/periodic/periodic.go @@ -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{