This is an automated email from the ASF dual-hosted git repository.
damondouglas 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 5a090958992 Move CsvIOParseResult (#31722)
5a090958992 is described below
commit 5a09095899289155edf977c65b962f414ba24c48
Author: lahariguduru <[email protected]>
AuthorDate: Sat Jun 29 00:04:01 2024 +0000
Move CsvIOParseResult (#31722)
Co-authored-by: Lahari Guduru <[email protected]>
---
.../beam/sdk/io/csv/{providers => }/CsvIOParseResult.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git
a/sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/providers/CsvIOParseResult.java
b/sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/CsvIOParseResult.java
similarity index 86%
rename from
sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/providers/CsvIOParseResult.java
rename to
sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/CsvIOParseResult.java
index 3a6299e1591..5d4d4c8c02e 100644
---
a/sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/providers/CsvIOParseResult.java
+++
b/sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/CsvIOParseResult.java
@@ -15,11 +15,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.beam.sdk.io.csv.providers;
+package org.apache.beam.sdk.io.csv;
import java.util.Map;
import org.apache.beam.sdk.Pipeline;
-import org.apache.beam.sdk.io.csv.CsvIOParseError;
import org.apache.beam.sdk.transforms.PTransform;
import org.apache.beam.sdk.values.PCollection;
import org.apache.beam.sdk.values.PCollectionTuple;
@@ -30,8 +29,9 @@ import org.apache.beam.sdk.values.TupleTag;
import
org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableMap;
/**
- * The {@link T} and {@link CsvIOParseError} {@link PCollection} results of
parsing CSV records. Use
- * {@link #getOutput()} and {@link #getErrors()} to apply these results in a
pipeline.
+ * The {@link T} and {@link org.apache.beam.sdk.io.csv.CsvIOParseError} {@link
PCollection} results
+ * of parsing CSV records. Use {@link #getOutput()} and {@link #getErrors()}
to apply these results
+ * in a pipeline.
*/
public class CsvIOParseResult<T> implements POutput {
@@ -61,8 +61,8 @@ public class CsvIOParseResult<T> implements POutput {
}
/**
- * The {@link CsvIOParseError} {@link PCollection} as a result of errors
associated with parsing
- * CSV records.
+ * The {@link org.apache.beam.sdk.io.csv.CsvIOParseError} {@link
PCollection} as a result of
+ * errors associated with parsing CSV records.
*/
public PCollection<CsvIOParseError> getErrors() {
return errors;