From fb6ca303bf7bafe587c24e1022b9d2ab2a4115fc Mon Sep 17 00:00:00 2001 From: Reynold Xin Date: Sun, 26 Jul 2015 21:14:22 -0700 Subject: [PATCH] Support BinaryType. --- .../org/apache/spark/sql/catalyst/expressions/UnsafeRow.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeRow.java b/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeRow.java index f98a53feb4167..0fb33dd5a15a0 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeRow.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeRow.java @@ -259,6 +259,8 @@ public Object get(int ordinal, DataType dataType) { return getInt(ordinal); } else if (dataType instanceof TimestampType) { return getLong(ordinal); + } else if (dataType instanceof BinaryType) { + return getBinary(ordinal); } else if (dataType instanceof StringType) { return getUTF8String(ordinal); } else if (dataType instanceof StructType) {