我希望能够通过自定义键使用分组,但这是我到目前为止的尝试, at org.apache.beam.sdk.transforms.GroupByKey.expand(GroupByKey.java:107)at org.apache.beam.sdk.Pipeline.applyInternal(Pipeline.java:5
如何用java编写以下代码?如果我在java中有记录/dicts列表,我如何编写波束代码来在tf.train.Examples被序列化的tfrecords中编写它们。使用python有很多例子,下面是python中的一个例子,我如何用java编写相同的逻辑?import tensorflow as tffrom apache<