Merge pull request #77 from fogrid/master

jacobfi · web-flow · commit 03217f7df882 · 2020-12-09T11:19:58.000+01:00
Add support for LongType &amp; DecimalType in converter
diff --git a/src/main/scala/com/audienceproject/spark/dynamodb/catalyst/JavaConverter.scala b/src/main/scala/com/audienceproject/spark/dynamodb/catalyst/JavaConverter.scala
@@ -37,6 +37,8 @@ object JavaConverter {
             case MapType(keyType, valueType, _) => convertMap(row.getMap(index), keyType, valueType)
             case StructType(fields) => convertStruct(row.getStruct(index, fields.length), fields)
             case StringType => row.getString(index)
+            case LongType => row.getLong(index)
+            case t: DecimalType => row.getDecimal(index, t.precision, t.scale).toBigDecimal
             case _ => row.get(index, elementType)
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -37,6 +37,8 @@ object JavaConverter {`
`37`	`37`	`case MapType(keyType, valueType, _) => convertMap(row.getMap(index), keyType, valueType)`
`38`	`38`	`case StructType(fields) => convertStruct(row.getStruct(index, fields.length), fields)`
`39`	`39`	`case StringType => row.getString(index)`
	`40`	`+ case LongType => row.getLong(index)`
	`41`	`+ case t: DecimalType => row.getDecimal(index, t.precision, t.scale).toBigDecimal`
`40`	`42`	`case _ => row.get(index, elementType)`
`41`	`43`	`}`
`42`	`44`	`}`