Update CassandraReaderHelper.java

支持Counter类型
2025-05-02 04:59:51 +08:00 · 2022-12-28 16:52:41 +08:00 · 2022-12-28 16:52:41 +08:00 · a572f38ddf
commit a572f38ddf
parent a8ec3af387
1 changed files with 1 additions and 0 deletions
--- 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;