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

Commit 98d5b3a

Browse files
committed
Test of PR
1 parent 6af85f3 commit 98d5b3a

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

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

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -37,8 +37,8 @@ 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)
4140
case BinaryType => nullableGet(_.getBinary)(attrName)
41+
case DecimalType() => nullableGet(_.getNumber)(attrName)
4242
case ArrayType(innerType, _) =>
4343
nullableGet(_.getList)(attrName).andThen(extractArray(convertValue(innerType)))
4444
case MapType(keyType, valueType, _) =>
@@ -58,10 +58,6 @@ private[dynamodb] object TypeConversion {
5858
case DoubleType => nullableConvert(_.doubleValue())
5959
case FloatType => nullableConvert(_.floatValue())
6060
case DecimalType() => nullableConvert(identity)
61-
case BinaryType => {
62-
case byteArray : Array[Byte] => byteArray
63-
case _ => null
64-
}
6561
case ArrayType(innerType, _) => extractArray(convertValue(innerType))
6662
case MapType(keyType, valueType, _) =>
6763
if (keyType != StringType) throw new IllegalArgumentException(s"Invalid Map key type '${keyType.typeName}'. DynamoDB only supports String as Map key type.")
@@ -77,6 +73,10 @@ private[dynamodb] object TypeConversion {
7773
case string: String => string
7874
case _ => null
7975
}
76+
case BinaryType => {
77+
case byteArray: Array[Byte] => byteArray
78+
case _ => null
79+
}
8080
case _ => throw new IllegalArgumentException(s"Spark DataType '${sparkType.typeName}' could not be mapped to a corresponding DynamoDB data type.")
8181
}
8282

0 commit comments

Comments
 (0)