Skip to content

Commit

Permalink
Changed Byte<->String encoding to use iso-8859-1 in LateralViewJoin
Browse files Browse the repository at this point in the history
  • Loading branch information
Harvey committed Jun 10, 2012
1 parent 3acadc3 commit 06dd607
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/main/scala/shark/exec/LateralViewJoinOperator.scala
Expand Up @@ -110,11 +110,11 @@ object KryoSerializerToString extends shark.LogHelper {

def serialize[T](o: T): String = {
val bytes = kryoSer.newInstance().serialize(o)
new String(bytes.map(_.toChar))
new String(bytes, "ISO-8859-1")
}

def deserialize[T](byteString: String): T = {
val bytes = byteString.toCharArray.map(_.toByte)
val bytes = byteString.getBytes("ISO-8859-1")
kryoSer.newInstance().deserialize[T](bytes)
}
}

0 comments on commit 06dd607

Please sign in to comment.