[Task]: Implement CsvIO.Read

[damondouglas]

What work does this Task describe?

This task addresses support for transforming CSV records into schema aware PCollection elements.

What value may result from this Task's output?

Some legacy systems only support CSV export and having a mechanism for parsing files in CSV format may help users.

Ready and Done Measures

Ready

• [Task]: Implement CsvIO.Write #24469

Done

The following are measures for marking this Task complete.

Tests detect errors in:

• validating an output Schema
• converting PCollection<String> to PCollection<Row>
• converting PCollection<String> to PCollection<T> where T is a user class type
• mapping a header to an input Schema field names, included and positioned appropriately for each sharded CSV file
• PBegin source with multiple headers map to the appropriate Schema

Issue Priority

Priority: 3

Issue Component

Component: beam-community

[twosom]

Hi. is this task done?

I think it overlaps with the issue #31877

[liferoad]

@damondouglas Please check.