You want to use ParDo: https://cloud.google.com/dataflow/model/par-do
Note that Beam started off from the Dataflow code base and all the concepts outlined on the model page are still relevant. The documentation conversion from the Dataflow pages for Beam is still in progress. On Fri, Apr 29, 2016 at 11:53 AM, amir bahmanyari <[email protected]> wrote: > Hi Colleagues, > I receive data fro KafkaIO bounded source as : > PCollection<KafkaRecord<byte[],byte[]>> kafkarecords = > p.apply(KafkaIO.read().withBootstrapServers("kirkhost:9092").withTopics(topics).withMaxNumRecords(10)); > How do I print out and/or access the records one at a time as String? > Thanks for your help. > Amir >
