Yes, that makes sense, feel free to create an issue or create a PR resolving this discrepancy. Taking a pass over the existing IO transforms would also be helpful.
On Thu, Aug 25, 2016 at 11:42 AM, Gaurav Gupta <[email protected]> wrote: > 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 >
