如果我在java中有记录/dicts列表,我如何编写波束代码来在tf.train.Examples被序列化的tfrecords中编写它们。使用python有很多例子,下面是python中的一个例子,我如何用java编写相同的逻辑?import tensorflow as tffrom apache_beam.runners.inter
我们有一个步骤,在Dataflow的newline上拆分Pubsub消息。我们有一个通过代码的测试,但它似乎在生产中失败了。看起来我们一次在多个地方得到相同的Pubsub消息(至少据我所知)。或者,这仅仅是一个关于在Apache中不做什么的艰难教训吗?import apache_beam as beamfrom ap