From 25a5c0d76ac54b2e45a4e830a52dd4ea7c79f8b4 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=BB=84=E6=80=9D=E4=BC=9F?=
 <80809913+svea-vip@users.noreply.github.com>
Date: Thu, 12 Sep 2024 09:56:42 +0800
Subject: [PATCH] Update ParquetWriter.java

Add support for the long type for ParquetWriter
---
 .../wgzhao/addax/plugin/writer/hdfswriter/ParquetWriter.java   | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/plugin/writer/hdfswriter/src/main/java/com/wgzhao/addax/plugin/writer/hdfswriter/ParquetWriter.java b/plugin/writer/hdfswriter/src/main/java/com/wgzhao/addax/plugin/writer/hdfswriter/ParquetWriter.java
index cfc35e403..cf70491e8 100644
--- a/plugin/writer/hdfswriter/src/main/java/com/wgzhao/addax/plugin/writer/hdfswriter/ParquetWriter.java
+++ b/plugin/writer/hdfswriter/src/main/java/com/wgzhao/addax/plugin/writer/hdfswriter/ParquetWriter.java
@@ -275,6 +275,9 @@ private MessageType generateParquetSchema(List<Configuration> columns) {
                 case "INT":
                     t = Types.primitive(PrimitiveType.PrimitiveTypeName.INT32, repetition).named(fieldName);
                     break;
+                case "LONG":
+                    t = Types.primitive(PrimitiveType.PrimitiveTypeName.INT64, repetition).named(fieldName);
+                    break;
                 case "DECIMAL":
                     // use fixed 16 bytes array
                     int prec = column.getInt(Key.PRECISION, Constant.DEFAULT_DECIMAL_MAX_PRECISION);