(beam) branch master updated: [CsvIO] update input Pcollection type arguments due to change in implementation details. (#31891)

[yhu]

This is an automated email from the ASF dual-hosted git repository.

yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new a767d41daaf [CsvIO] update input Pcollection type arguments due to 
change in implementation details. (#31891)
a767d41daaf is described below

commit a767d41daafb7f7c2e0226214d67e174c959678b
Author: Francis O'Hara <francisoh...@google.com>
AuthorDate: Wed Jul 17 20:37:49 2024 +0000

    [CsvIO] update input Pcollection type arguments due to change in 
implementation details. (#31891)
---
 .../csv/src/main/java/org/apache/beam/sdk/io/csv/CsvIOParseKV.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/CsvIOParseKV.java 
b/sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/CsvIOParseKV.java
index 55e3bc2dab0..1b8e43314b1 100644
--- 
a/sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/CsvIOParseKV.java
+++ 
b/sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/CsvIOParseKV.java
@@ -30,11 +30,12 @@ import org.apache.commons.csv.CSVRecord;
  */
 // TODO(https://github.com/apache/beam/issues/31873): implement class after 
all dependencies are
 // completed.
-class CsvIOParseKV<T> extends PTransform<PCollection<KV<String, CSVRecord>>, 
PCollection<T>> {
+class CsvIOParseKV<T>
+    extends PTransform<PCollection<KV<String, Iterable<String>>>, 
PCollection<T>> {
 
   // TODO(https://github.com/apache/beam/issues/31873): implement method.
   @Override
-  public PCollection<T> expand(PCollection<KV<String, CSVRecord>> input) {
-    return input.apply(ParDo.of(new DoFn<KV<String, CSVRecord>, T>() {}));
+  public PCollection<T> expand(PCollection<KV<String, Iterable<String>>> 
input) {
+    return input.apply(ParDo.of(new DoFn<KV<String, Iterable<String>>, T>() 
{}));
   }
 }