From e357b4298dc73c7c36060b7731d06db39acc068c Mon Sep 17 00:00:00 2001 From: Florian Bernard Date: Fri, 14 Jun 2024 13:55:44 +0200 Subject: [PATCH] Improve javadoc in ParquetIO (#31409) --- .../main/java/org/apache/beam/sdk/io/parquet/ParquetIO.java | 4 ++-- 1 file changed, 2 insertions(+), 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 index 33940aa27a5c..24c18f382817 100644 --- 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 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();