Skip to content

Commit f524f61

Browse files
committed
Remove unused arrow marshaler
1 parent b62073c commit f524f61

File tree

6 files changed

+5
-875
lines changed

6 files changed

+5
-875
lines changed

columnifier/parquet.go

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -94,20 +94,6 @@ func (c *parquetColumnifier) Write(data []byte) (int, error) {
9494
}
9595
afterSize := c.w.Size
9696

97-
// Intermediate record type is wrapped Apache Arrow record
98-
// It requires Arrow Golang implementation more logical type supports
99-
// ref. https://github.com/apache/arrow/blob/9c9dc2012266442d0848e4af0cf52874bc4db151/go/arrow/array/builder.go#L211
100-
/*
101-
c.w.MarshalFunc = parquet.MarshalArrow
102-
records, err := record.FormatToArrow(data, c.schema, c.rt)
103-
if err != nil {
104-
return err
105-
}
106-
if err := c.w.Write(&records); err != nil {
107-
return err
108-
}
109-
*/
110-
11197
return int(afterSize - beforeSize), nil
11298
}
11399

parquet/doc.go

Lines changed: 0 additions & 12 deletions
This file was deleted.

parquet/marshal_arrow.go

Lines changed: 0 additions & 266 deletions
This file was deleted.

0 commit comments

Comments
 (0)