Hi All,

I am new to Apache beam and I was going through the word count example. I
found that TextIO.Read.Bound is used to read file.

Should TextIO.Read.Bound not extend PTransform<PBegin, PCollection<T>>
instead of PTransform<PInput, PCollection<T>> similar to KafkaIO.Read  and
JMSIO.Read that extend PTransform<PBegin, PCollection<T>>?

Thanks
Gaurav

Reply via email to