Re: Count Incoming Unbounded records using Apache Beam java

Hi, thanks for your interest in Apache Beam. I answered your question, see [1] Best,  Jan [1] https://stackoverflow.com/questions/76681800/count-incoming-unbouned-messages-from-pubsub-using-apache-beam-java/76685799#76685799 On 7/13/23 19:17, Phani Geeth wrote: Hi, I am trying to count the

Count Incoming Unbounded records using Apache Beam java

Hi, I am trying to count the incoming messages from PubSub using beam pipeline java sdk. class Display extends DoFn{@ProcessElementpublic void process(ProcessContext c){System.out.println(c.element());}}public class CustomMetrics{public static void main(String args[]){PipelineOptions options = Pipe