org.hbase.async
Class MapRConverter

java.lang.Object
  extended by org.hbase.async.MapRConverter

public class MapRConverter
extends Object


Constructor Summary
MapRConverter()
           
 
Method Summary
static int compareTo(byte[] buffer1, int offset1, int length1, byte[] buffer2, int offset2, int length2)
           
static ArrayList<KeyValue> toAsyncHBaseResult(com.mapr.fs.jni.MapRResult mresult, byte[] key, com.mapr.fs.MapRHTable htable)
           
static com.mapr.fs.jni.MapRGet toMapRGet(GetRequest get, com.mapr.fs.MapRHTable mtable)
           
static com.mapr.fs.jni.MapRIncrement toMapRIncrement(byte[] key, byte[] family, byte[] qualifier, long delta, com.mapr.fs.MapRHTable mtable)
           
static com.mapr.fs.jni.MapRPut toMapRPut(DeleteRequest drpc, com.mapr.fs.MapRHTable mTable)
           
static com.mapr.fs.jni.MapRPut toMapRPut(PutRequest put, com.mapr.fs.MapRHTable mtable, MapRThreadPool cbq)
           
static com.mapr.fs.jni.MapRScan toMapRScan(Scanner scan, com.mapr.fs.MapRHTable mtable)
           
static com.mapr.fs.jni.MapRRowConstraint toRowConstraint(com.mapr.fs.MapRHTable mtable, byte[][] families, byte[][][] qualifiers, long minTimeStamp, long maxTimeStamp, int maxVers)
           
static com.mapr.fs.jni.MapRRowConstraint toRowConstraint(com.mapr.fs.MapRHTable htable, String family, byte[][] qualifier, int maxVers)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MapRConverter

public MapRConverter()
Method Detail

compareTo

public static int compareTo(byte[] buffer1,
                            int offset1,
                            int length1,
                            byte[] buffer2,
                            int offset2,
                            int length2)

toMapRPut

public static com.mapr.fs.jni.MapRPut toMapRPut(PutRequest put,
                                                com.mapr.fs.MapRHTable mtable,
                                                MapRThreadPool cbq)

toMapRPut

public static com.mapr.fs.jni.MapRPut toMapRPut(DeleteRequest drpc,
                                                com.mapr.fs.MapRHTable mTable)

toMapRGet

public static com.mapr.fs.jni.MapRGet toMapRGet(GetRequest get,
                                                com.mapr.fs.MapRHTable mtable)

toRowConstraint

public static com.mapr.fs.jni.MapRRowConstraint toRowConstraint(com.mapr.fs.MapRHTable htable,
                                                                String family,
                                                                byte[][] qualifier,
                                                                int maxVers)
                                                         throws IOException
Throws:
IOException

toAsyncHBaseResult

public static ArrayList<KeyValue> toAsyncHBaseResult(com.mapr.fs.jni.MapRResult mresult,
                                                     byte[] key,
                                                     com.mapr.fs.MapRHTable htable)

toMapRScan

public static com.mapr.fs.jni.MapRScan toMapRScan(Scanner scan,
                                                  com.mapr.fs.MapRHTable mtable)
                                           throws IOException
Throws:
IOException

toRowConstraint

public static com.mapr.fs.jni.MapRRowConstraint toRowConstraint(com.mapr.fs.MapRHTable mtable,
                                                                byte[][] families,
                                                                byte[][][] qualifiers,
                                                                long minTimeStamp,
                                                                long maxTimeStamp,
                                                                int maxVers)
                                                         throws IOException
Throws:
IOException

toMapRIncrement

public static com.mapr.fs.jni.MapRIncrement toMapRIncrement(byte[] key,
                                                            byte[] family,
                                                            byte[] qualifier,
                                                            long delta,
                                                            com.mapr.fs.MapRHTable mtable)
                                                     throws IOException
Throws:
IOException


Copyright © 2010-2015, The Async HBase Authors