From 9d71f003b9b3f663420794dd9bc5103444a3a4d1 Mon Sep 17 00:00:00 2001 From: Chandan Rajah Date: Thu, 6 Jun 2013 16:37:05 +0100 Subject: Minor bug fix in the pipe conversions Modified POM to auto update to maven repo --- src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'src/main/scala/parallelai/spyglass') diff --git a/src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala b/src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala index 21d90e8..6035688 100644 --- a/src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala +++ b/src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala @@ -14,7 +14,8 @@ class HBasePipeWrapper (pipe: Pipe) { asList(f) .foldLeft(pipe){ (p, f) => { p.map(f.toString -> f.toString){ from: String => { - new ImmutableBytesWritable(Bytes.toBytes(from)) + new ImmutableBytesWritable(Bytes.toBytes( + if (from == null) "" else from)) }} }} } -- cgit v1.2.3