I think FooIO.read() and FooIO.write() is the new API convention for IO (recently BigtableIO from Dan does the same).
On Tue, Jun 7, 2016 at 9:50 AM, Jesse Anderson <[email protected]> wrote: > Ah the over the weekend part explains that. > > Is there a reason KafkaIO doesn't follow the separate classes for read and > write like TextIO does? Following the TextIO style, there should be a > KafkaIO.Read.method() or KafkaIO.Write.method(). > > On Tue, Jun 7, 2016 at 12:22 PM Dan Halperin <[email protected]> wrote: > >> Hi Jesse, >> >> KafkaIO supports write: >> https://github.com/apache/incubator-beam/blob/master/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java#L161 >> >> (This was merged over the weekend as part of @rangadi's >> https://github.com/apache/incubator-beam/pull/271) >> >> Dan >> >> On Tue, Jun 7, 2016 at 9:04 AM, Jesse Anderson <[email protected]> >> wrote: >> >>> Are there plans to add a writer to KafkaIO? Right now, it's only read. >>> >>> The class itself is written to only expect a reader. Adding any sort of >>> write would require refactoring the class to Read and Write like TextIO >>> does. >>> >>> Thanks, >>> >>> Jesse >>> >> >>
