Hi,
According to this commit [0] it seems to me that there were some changes in the
way the Coder interface is
being used.
Before switching from the Dataflow SDK 1.9 this code was working for me (I
already adjusted the way PubSubIO is accessed):
.apply("WriteToPubSub", PubsubIO.write()
.topic(topic)
.withCoder(TableRowJsonCoder.of())
.timestampLabel("ts"));
Now withCoder(Coder<T> coder) no longer accepts the instance of
TableRowJsonCoder. I have checked that
the TableRowJsonCoder is still registered as a StandardCoder [1] in the current
master - how is it being used now?
Thank you for all your effort,
Tobi
[0]
https://github.com/apache/beam/commit/7b98fa08d14e8121e8885f00a9a9a878b73f81a6
[1]
https://github.com/apache/beam/blob/d9657ffc37490b063835672e0b5287b4d18aba96/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java#L94
