Convert csv to parquet but getting emptyfile

[IsabelDing00]

Convert csv to parquet,

1. Got 4bytes parquet file with "PAR1" only.
2. WriteStop() panic with error: interface conversion: interface {} is nil, not string

Here is my code:

package main

import (
	"bufio"
	"encoding/csv"
	"fmt"
	"io"
	"log"
	"os"

	"github.com/xitongsys/parquet-go-source/local"
	"github.com/xitongsys/parquet-go/parquet"
	"github.com/xitongsys/parquet-go/writer"
)

type custReport struct {
	phoneNumber string `parquet:"name=phone_number, type=BYTE_ARRAY"`
}

func main() {
	fw, err := local.NewLocalFileWriter("test.parquet")
	if err != nil {
		fmt.Println("Fail to create parquet file path:", err)
	}
	pw, err := writer.NewParquetWriter(fw, new(custReport), 1)
	if err != nil {
		fmt.Println("Fail to create parquet writer:", err)
	}

	pw.RowGroupSize = 128 * 1024 * 1024 //128M
	pw.CompressionType = parquet.CompressionCodec_SNAPPY

	csvFile, err := os.Open("test.csv")
	if err != nil {
		fmt.Println("Fail to open csv file:", err)
	}

	reader := csv.NewReader(bufio.NewReader(csvFile))
	for {
		line, error := reader.Read()
		if error == io.EOF {
			break
		} else if error != nil {
			log.Fatal(error)
		}

		report := custReport{
			phoneNumber: line[0],
		}
		if err = pw.Write(report); err != nil {
			fmt.Println("Write error", err)
		}
	}

	if err = pw.WriteStop(); err != nil {
		fmt.Println("WriteStop error:", err)
	}

	fmt.Println("Write Finished")
	fw.Close()

}

csv file: test.csv

Phone Number
+13912345678

@xitongsys

[xitongsys]

The first letter should be upper.

type custReport struct {
	PhoneNumber string `parquet:"name=phone_number, type=BYTE_ARRAY"`
}