Hi,

I noticed that ModelCoderRegistrar only includes 9 out of ~40 coders. May I
know the rationale behind this decision?

https://github.com/apache/beam/blob/release-2.7.0/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ModelCoderRegistrar.java

I think one consequence of the above configuration is
that WireCoders.instantiateRunnerWireCoder cannot instantiate KV coders
correctly, where VoidCoder (key coder) becomes
LengthPrefixCoder(ByteArrayCoder). What is the appropriate way to get
KvCoder<Void, T> from RunnerApi.Pipeline?

Thanks,
Shen

Reply via email to