diff --git a/avroparquet-tests/src/test/java/docs/javadsl/Examples.java b/avroparquet-tests/src/test/java/docs/javadsl/Examples.java index e4093523e1..3b7cf4775a 100644 --- a/avroparquet-tests/src/test/java/docs/javadsl/Examples.java +++ b/avroparquet-tests/src/test/java/docs/javadsl/Examples.java @@ -22,6 +22,7 @@ import org.apache.avro.Schema; import akka.stream.javadsl.Source; import org.apache.parquet.avro.AvroParquetReader; +import org.apache.parquet.hadoop.util.HadoopOutputFile; // #init-reader public class Examples { @@ -53,7 +54,7 @@ public Examples() throws IOException { // #init-flow ParquetWriter writer = - AvroParquetWriter.builder(new Path("./test.parquet")) + AvroParquetWriter.builder(HadoopOutputFile.fromPath(new Path("./test.parquet"), conf)) .withConf(conf) .withSchema(schema) .build();