如何使用.net数据表为parquet.net创建模式

using System;
using System.Data;
using Parquet;
using Parquet.Data;

class Program
{
    static void Main()
    {
        // 创建 DataTable
        DataTable dataTable = new DataTable();
        dataTable.Columns.Add("Id", typeof(int));
        dataTable.Columns.Add("Name", typeof(string));
        dataTable.Columns.Add("Age", typeof(int));

        // 添加数据
        dataTable.Rows.Add(1, "Alice", 30);
        dataTable.Rows.Add(2, "Bob", 25);

        // 创建 Parquet 模式
        var schema = new Schema(dataTable.Columns.Select(c => new DataField(c.ColumnName, c.DataType)));

        // 写入 Parquet 文件
        using (var stream = System.IO.File.OpenWrite("example.parquet"))
        {
            ParquetWriter writer = new ParquetWriter(stream, schema);
            ParquetRowGroupWriter groupWriter = writer.NextRowGroup();

            foreach (DataColumn column in dataTable.Columns)
            {
                switch (column.DataType.Name)
                {
                    case "Int32":
                        groupWriter.WriteColumn(new DataColumn<int>(column.ColumnName, dataTable.AsEnumerable().Select(r => r.Field<int>(column.ColumnName))));
                        break;
                    case "String":
                        groupWriter.WriteColumn(new DataColumn<string>(column.ColumnName, dataTable.AsEnumerable().Select(r => r.Field<string>(column.ColumnName))));
                        break;
                    // 添加其他数据类型的处理
                }
            }

            groupWriter.Complete();
            writer.WriteStop();
        }
    }
}