Hi, I need a help regarding dynamic naming for Xml with KV PCollection.
PCollection<KV<String,XmlDTO>> xmlCollection =…. I am not able to use XmlIO for this PCollection XmlDTO is actually the dto marshalled and String is the key I tried using KV but XmlIO needs a Class type, KV.getClass does not work… I need to get the Key for distribution and XmlDTO does not have it. Any suggestions? Regards, Vinay Patil
