From a572f38ddf18cdeea7caec42ec50fa4f1752541b Mon Sep 17 00:00:00 2001
From: YanxinXue <YanxinXue@gmail.com>
Date: Wed, 28 Dec 2022 16:52:41 +0800
Subject: [PATCH] Update CassandraReaderHelper.java
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

支持Counter类型
---
 .../plugin/reader/cassandrareader/CassandraReaderHelper.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderHelper.java b/cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderHelper.java
index 2e23aced..dd56e49c 100644
--- a/cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderHelper.java
+++ b/cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderHelper.java
@@ -298,6 +298,7 @@ public class CassandraReaderHelper {
           record.addColumn(new LongColumn(rs.getInt(i)));
           break;
 
+        case COUNTER:
         case BIGINT:
           record.addColumn(new LongColumn(rs.getLong(i)));
           break;