using System;

using ChoETL;

​

public class Program

{

    public static void Main()

    {

        string parquetFilePath = "emp.parquet";

        CreateParquetFile(parquetFilePath);

        ChoParquetRecordConfiguration config = new ChoParquetRecordConfiguration();

        config.ParquetRecordFieldConfigurations.Add(new ChoParquetRecordFieldConfiguration("Id"));

        config.ParquetRecordFieldConfigurations.Add(new ChoParquetRecordFieldConfiguration("Name"));

​

        foreach (var rec in new ChoParquetReader(parquetFilePath, config))

        {

            Console.WriteLine($"Id: {rec.Id}, Name: {rec.Name}");

        }

    }

    static void CreateParquetFile(string parquetFilePath)

    {

        string csv = @"Id,Name

1,Tom

2,Carl

3,Mark";

        using (var r = ChoCSVReader.LoadText(csv)

               .WithFirstLineHeader()

              )

        {

            using (var w = new ChoParquetWriter(parquetFilePath))

                w.Write(r);

        }

    }

}