File tree Expand file tree Collapse file tree 2 files changed +4
-1
lines changed
modules/core/src/main/scala/me/mnedokushev/zio/apache/parquet/core/hadoop Expand file tree Collapse file tree 2 files changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -73,7 +73,7 @@ object ParquetWriter {
73
73
for {
74
74
schema <- schemaEncoder.encodeZIO(schema, tag.tag.shortName, optional = false )
75
75
messageSchema <- castSchema(schema)
76
- hadoopFile <- ZIO .attemptBlockingIO(HadoopOutputFile .fromPath(path.underlying , hadoopConf))
76
+ hadoopFile <- ZIO .attemptBlockingIO(HadoopOutputFile .fromPath(path.toHadoop , hadoopConf))
77
77
builder = new Builder (hadoopFile, messageSchema)
78
78
.withWriteMode(writeMode)
79
79
.withCompressionCodec(compressionCodecName)
Original file line number Diff line number Diff line change @@ -16,6 +16,9 @@ case class Path(underlying: HadoopPath) {
16
16
def toJava : JPath =
17
17
Paths .get(underlying.toUri)
18
18
19
+ def toHadoop : HadoopPath =
20
+ underlying
21
+
19
22
}
20
23
21
24
object Path {
You can’t perform that action at this time.
0 commit comments