Improve javadoc in ParquetIO (#31409)

apache · Jun 14, 2024 · e357b42 · e357b42
1 parent 1e39407
commit e357b42
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sdks/java/io/parquet/src/main/java/org/apache/beam/sdk/io/parquet/ParquetIO.java b/sdks/java/io/parquet/src/main/java/org/apache/beam/sdk/io/parquet/ParquetIO.java
@@ -1046,13 +1046,13 @@ public Sink withCompressionCodec(CompressionCodecName compressionCodecName) {
       return toBuilder().setCompressionCodec(compressionCodecName).build();
     }
 
-    /** Specifies configuration to be passed into the sink's writer. */
+    /** Specify Hadoop configuration for ParquetWriter. */
     public Sink withConfiguration(Map<String, String> configuration) {
       checkArgument(configuration != null, "configuration can not be null");
       return toBuilder().setConfiguration(SerializableConfiguration.fromMap(configuration)).build();
     }
 
-    /** Specify Hadoop configuration for ParquetReader. */
+    /** Specify Hadoop configuration for ParquetWriter. */
     public Sink withConfiguration(Configuration configuration) {
       checkArgument(configuration != null, "configuration can not be null");
       return toBuilder().setConfiguration(new SerializableConfiguration(configuration)).build();