Skip to content

Commit

Permalink
[prism] preparer comment
Browse files Browse the repository at this point in the history
  • Loading branch information
lostluck committed Feb 18, 2023
1 parent d98754a commit e3c3199
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions sdks/go/pkg/beam/runners/prism/internal/preprocess.go
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,9 @@ func newPreprocessor(preps []transformPreparer) *preprocessor {
}
}

// transformPreparer is an interface for handling different urns in the prepropcessor
// largely for exchanging transforms for others, to be added to the complete set of
// components in the pipeline.
type transformPreparer interface {
// PrepareUrns returns the Beam URNs that this handler deals with for preprocessing.
PrepareUrns() []string
Expand Down

0 comments on commit e3c3199

Please sign in to comment.