Merge pull request #6596 from lostluck/patch-14
[BEAM-3612] Add way to query emitter registration
diff --git a/sdks/go/pkg/beam/core/runtime/exec/emit.go b/sdks/go/pkg/beam/core/runtime/exec/emit.go
index 9b47821..b26c5dd 100644
--- a/sdks/go/pkg/beam/core/runtime/exec/emit.go
+++ b/sdks/go/pkg/beam/core/runtime/exec/emit.go
@@ -53,6 +53,12 @@
emitters[key] = maker
}
+// IsEmitterRegistered returns whether an emitter maker has already been registered.
+func IsEmitterRegistered(t reflect.Type) bool {
+ _, exists := emitters[t.String()]
+ return exists
+}
+
func makeEmit(t reflect.Type, n ElementProcessor) ReusableEmitter {
emittersMu.Lock()
maker, exists := emitters[t.String()]
