Merge branch 'Neuw84-master'

Author: jacobfi

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

@@ -107,6 +107,7 @@ private[dynamodb] class DynamoRelation(userSchema: StructType, parameters: Map[S
             }).toSeq
             StructType(mapFields)
         case _: java.lang.Boolean => BooleanType
+        case _: Array[Byte] => BinaryType
         case _ => StringType
     }
 

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

@@ -37,6 +37,7 @@ private[dynamodb] object TypeConversion {
             case LongType => nullableGet(_.getLong)(attrName)
             case DoubleType => nullableGet(_.getDouble)(attrName)
             case FloatType => nullableGet(_.getFloat)(attrName)
+            case BinaryType => nullableGet(_.getBinary)(attrName)
             case DecimalType() => nullableGet(_.getNumber)(attrName)
             case ArrayType(innerType, _) =>
                 nullableGet(_.getList)(attrName).andThen(extractArray(convertValue(innerType)))
@@ -72,6 +73,10 @@ private[dynamodb] object TypeConversion {
                 case string: String => string
                 case _ => null
             }
+            case BinaryType => {
+                case byteArray: Array[Byte] => byteArray
+                case _ => null
+            }
             case _ => throw new IllegalArgumentException(s"Spark DataType '${sparkType.typeName}' could not be mapped to a corresponding DynamoDB data type.")
         }