Skip to content

Commit

Permalink
more deprecation
Browse files Browse the repository at this point in the history
  • Loading branch information
sebastian-alfers committed Nov 22, 2023
1 parent 4d705b9 commit 684e989
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion avroparquet-tests/src/test/java/docs/javadsl/Examples.java
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down Expand Up @@ -53,7 +54,7 @@ public Examples() throws IOException {

// #init-flow
ParquetWriter<GenericRecord> writer =
AvroParquetWriter.<GenericRecord>builder(new Path("./test.parquet"))
AvroParquetWriter.<GenericRecord>builder(HadoopOutputFile.fromPath(new Path("./test.parquet"), conf))
.withConf(conf)
.withSchema(schema)
.build();
Expand Down

0 comments on commit 684e989

Please sign in to comment.