Skip to content

Commit

Permalink
lint fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
riteshghorse committed Dec 1, 2022
1 parent 57e5b69 commit b803b42
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions sdks/go/pkg/beam/core/runtime/exec/window.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@ type WindowInto struct {
Out Node
}

// ID returns the UnitID for this unit.
func (w *WindowInto) ID() UnitID {
return w.UID
}
Expand Down Expand Up @@ -98,16 +99,20 @@ func (w *WindowInto) String() string {
return fmt.Sprintf("WindowInto[%v]. Out:%v", w.Fn, w.Out.ID())
}

// MapWindows maps each element window from a main input window space
// to window from a side input window space.
type MapWindows struct {
UID UnitID
Fn WindowMapper
Out Node
}

// ID returns the UnitID for this unit.
func (m *MapWindows) ID() UnitID {
return m.UID
}

// Up does nothing
func (m *MapWindows) Up(_ context.Context) error {
return nil
}
Expand Down Expand Up @@ -135,10 +140,12 @@ func (m *MapWindows) ProcessElement(ctx context.Context, elm *FullValue, values
return m.Out.ProcessElement(ctx, out, values...)
}

// FinishBundle propagates finish bundle to downstream nodes.
func (m *MapWindows) FinishBundle(ctx context.Context) error {
return m.Out.FinishBundle(ctx)
}

// Down does nothing.
func (m *MapWindows) Down(_ context.Context) error {
return nil
}
Expand Down

0 comments on commit b803b42

Please sign in to comment.