Skip to content
This repository was archived by the owner on Aug 31, 2021. It is now read-only.

Commit 6b9bd8a

Browse files
committed
Merge branch 'lepirlouit-master'
2 parents e05caad + 8cc9aa8 commit 6b9bd8a

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/main/scala/com/audienceproject/spark/dynamodb/rdd/TypeConversion.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@ private[dynamodb] object TypeConversion {
3737
case LongType => nullableGet(_.getLong)(attrName)
3838
case DoubleType => nullableGet(_.getDouble)(attrName)
3939
case FloatType => nullableGet(_.getFloat)(attrName)
40+
case DecimalType() => nullableGet(_.getNumber)(attrName)
4041
case ArrayType(innerType, _) =>
4142
nullableGet(_.getList)(attrName).andThen(extractArray(convertValue(innerType)))
4243
case MapType(keyType, valueType, _) =>
@@ -55,6 +56,7 @@ private[dynamodb] object TypeConversion {
5556
case LongType => nullableConvert(_.longValue())
5657
case DoubleType => nullableConvert(_.doubleValue())
5758
case FloatType => nullableConvert(_.floatValue())
59+
case DecimalType() => nullableConvert(identity)
5860
case ArrayType(innerType, _) => extractArray(convertValue(innerType))
5961
case MapType(keyType, valueType, _) =>
6062
if (keyType != StringType) throw new IllegalArgumentException(s"Invalid Map key type '${keyType.typeName}'. DynamoDB only supports String as Map key type.")

0 commit comments

Comments
 (0)