diff options
| -rw-r--r-- | src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala b/src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala index debc66c..0acec44 100644 --- a/src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala +++ b/src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala @@ -31,6 +31,7 @@ class HBasePipeWrapper (pipe: Pipe) { trait HBasePipeConversions { implicit def pipeWrapper(pipe: Pipe) = new HBasePipeWrapper(pipe) + implicit def richPipeWrapper(rp: RichPipe) = new HBasePipeWrapper(rp.pipe) } |