[beam] branch master updated: lint fixes (#24455)

[riteshghorse]

This is an automated email from the ASF dual-hosted git repository.

riteshghorse pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 263a7d8f432 lint fixes (#24455)
263a7d8f432 is described below

commit 263a7d8f43224b6082c7be5b0608a362741633c0
Author: Ritesh Ghorse <riteshgho...@gmail.com>
AuthorDate: Thu Dec 1 20:45:29 2022 +0530

    lint fixes (#24455)
---
 sdks/go/pkg/beam/core/runtime/exec/window.go | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/sdks/go/pkg/beam/core/runtime/exec/window.go 
b/sdks/go/pkg/beam/core/runtime/exec/window.go
index 4048d102790..081fed48ac6 100644
--- a/sdks/go/pkg/beam/core/runtime/exec/window.go
+++ b/sdks/go/pkg/beam/core/runtime/exec/window.go
@@ -33,6 +33,7 @@ type WindowInto struct {
        Out Node
 }
 
+// ID returns the UnitID for this unit.
 func (w *WindowInto) ID() UnitID {
        return w.UID
 }
@@ -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
 }
@@ -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
 }