我有一个有mongodb作为源的束流管道,但是当我尝试运行它时,它会抛出一个异常。 An exception occured while executing the Java class. null: InvocationTargetException: org.apache.beam.sdk.io.BoundedSource.getDefaultOutputCoder()Lorg/apache/
有什么简单的方法可以将GroupBy的输出重定向到基于组密钥的多个输出文件? Bin.apply(GroupByKey.<String, KV<Long,Iterable<TableRow>>>create())
.apply(ParDo.named("Print Bins").of(...)
.apply(TextIO.Write.to(*Output file based on key*)
我正在迁移将FileBasedSink从2.0.0版扩展到2.2.0的自定义接收器。类已发生变化,增加了两个类型参数:UserT和DestinationT: @Experimental(value=FILESYSTEM)
public abstract class FileBasedSink<UserT,DestinationT,OutputT>
extends java.lang.Objec