Merge pull request #64 from datastax/feature/cant-migrate-time-type

Added support for 'time' & 'smallint' data type

Author: pravinbhat

pom.xml

@@ -3,7 +3,7 @@
 
   <groupId>datastax.astra.migrate</groupId>
   <artifactId>cassandra-data-migrator</artifactId>
-  <version>3.0.3</version>
+  <version>3.0.4</version>
   <packaging>jar</packaging>
 
   <properties>

src/main/java/datastax/astra/migrate/MigrateDataType.java

@@ -8,6 +8,7 @@
 import java.nio.ByteBuffer;
 import java.time.Instant;
 import java.time.LocalDate;
+import java.time.LocalTime;
 import java.util.*;
 
 public class MigrateDataType {
@@ -81,6 +82,10 @@ private Class getType(int type) {
                 return UdtValue.class;
             case 17:
                 return BigInteger.class;
+            case 18:
+                return LocalTime.class;
+            case 19:
+                return Short.class;
         }
 
         return Object.class;

src/resources/sparkConf.properties

@@ -89,10 +89,10 @@ spark.query.writetime.cols                        2,3
 #############################################################################################################
 # Following are the supported data types and their corresponding [Cassandra data-types]
 #  0: ascii, text, varchar
-#  1: int, smallint
+#  1: int
 #  2: bigint, counter
 #  3: double
-#  4: time, timestamp
+#  4: timestamp
 #  5: map (separate type by %) - Example: 5%1%0 for map<int, text>
 #  6: list (separate type by %) - Example: 6%0 for list<text>
 #  7: blob
@@ -106,6 +106,8 @@ spark.query.writetime.cols                        2,3
 # 15: date
 # 16: UDT [any user-defined-type created using 'CREATE TYPE']
 # 17: varint
+# 18: time
+# 19: smallint
 
 # Note: Ignore "Frozen" while mapping Collections (Map/List/Set) - Example: 5%1%0 for frozen<map<int, text>>
 #