diff options
Diffstat (limited to 'src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala')
| -rw-r--r-- | src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala | 17 |
1 files changed, 0 insertions, 17 deletions
diff --git a/src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala b/src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala index 31ed3ea..debc66c 100644 --- a/src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala +++ b/src/main/scala/parallelai/spyglass/hbase/HBaseConversions.scala @@ -19,14 +19,6 @@ class HBasePipeWrapper (pipe: Pipe) { } } -// def toBytesWritable : Pipe = { -// asList(Fields.ALL.asInstanceOf[TupleEntry].getFields()).foldLeft(pipe){ (p, f) => { -// p.map(f.toString -> f.toString){ from: String => { -// new ImmutableBytesWritable(Bytes.toBytes(from)) -// }} -// }} -// } - def fromBytesWritable(f: Fields): Pipe = { asList(f) .foldLeft(pipe) { (p, fld) => { @@ -35,15 +27,6 @@ class HBasePipeWrapper (pipe: Pipe) { } }} } - -// def fromBytesWritable : Pipe = { -// asList(Fields.ALL.asInstanceOf[TupleEntry].getFields()).foldLeft(pipe) { (p, fld) => -// p.map(fld.toString -> fld.toString) { from: ImmutableBytesWritable => { -// Bytes.toString(from.get) -// } -// } -// } -// } } trait HBasePipeConversions { |