Skip to content

Commit

Permalink
Remove unused arrow marshaler
Browse files Browse the repository at this point in the history
  • Loading branch information
syucream committed Jul 26, 2020
1 parent b62073c commit f524f61
Show file tree
Hide file tree
Showing 6 changed files with 5 additions and 875 deletions.
14 changes: 0 additions & 14 deletions columnifier/parquet.go
Original file line number Diff line number Diff line change
Expand Up @@ -94,20 +94,6 @@ func (c *parquetColumnifier) Write(data []byte) (int, error) {
}
afterSize := c.w.Size

// Intermediate record type is wrapped Apache Arrow record
// It requires Arrow Golang implementation more logical type supports
// ref. https://github.com/apache/arrow/blob/9c9dc2012266442d0848e4af0cf52874bc4db151/go/arrow/array/builder.go#L211
/*
c.w.MarshalFunc = parquet.MarshalArrow
records, err := record.FormatToArrow(data, c.schema, c.rt)
if err != nil {
return err
}
if err := c.w.Write(&records); err != nil {
return err
}
*/

return int(afterSize - beforeSize), nil
}

Expand Down
12 changes: 0 additions & 12 deletions parquet/doc.go

This file was deleted.

266 changes: 0 additions & 266 deletions parquet/marshal_arrow.go

This file was deleted.

Loading

0 comments on commit f524f61

Please sign in to comment.