public class HBaseUtils extends Object
Constructor and Description |
---|
HBaseUtils() |
Modifier and Type | Method and Description |
---|---|
static byte[] |
customMessageRowKey(UUID mailboxUid,
long value)
Utility to build row keys from mailboxUID and a value.
|
static org.apache.hadoop.hbase.client.Delete |
flagsToDelete(Message<UUID> message,
javax.mail.Flags flags) |
static org.apache.hadoop.hbase.client.Put |
flagsToPut(Message<UUID> message,
javax.mail.Flags flags)
Utility method to transform message flags into a put opperation.
|
static String |
flagsToString(javax.mail.Flags flags)
Returns a String composed of all flags in the parameter.
|
static Mailbox<UUID> |
mailboxFromResult(org.apache.hadoop.hbase.client.Result result)
Creates a Mailbox object from a HBase Result object.
|
static byte[] |
mailboxRowKey(UUID uuid)
This returns the row key needed for HBase.
|
static Message<UUID> |
messageMetaFromResult(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.hbase.client.Result result)
Creates a HBaseMessage from a Result object.
|
static byte[] |
messageRowKey(Message<UUID> message)
Create a row key for a message in a mailbox.
|
static byte[] |
messageRowKey(UUID mailboxUid,
long uid)
Utility method to build row keys from mailbox UUID and message uid.
|
static org.apache.hadoop.hbase.client.Put |
metadataToPut(Message<UUID> message)
Transforms only the metadata into a Put object.
|
static org.apache.hadoop.hbase.client.Put |
toPut(HBaseMailbox mailbox)
Transforms the mailbox into a Put operation.
|
static org.apache.hadoop.hbase.client.Put |
toPut(Subscription subscription)
Creates a Put object from this subscription object
|
static UUID |
UUIDFromRowKey(byte[] rowkey)
Returns a UUID from the a byte array.
|
public static Mailbox<UUID> mailboxFromResult(org.apache.hadoop.hbase.client.Result result)
result
- a result of a HBase Get operationpublic static byte[] mailboxRowKey(UUID uuid)
uuid
- public static UUID UUIDFromRowKey(byte[] rowkey)
rowkey
- public static org.apache.hadoop.hbase.client.Put toPut(HBaseMailbox mailbox)
public static org.apache.hadoop.hbase.client.Put metadataToPut(Message<UUID> message)
message
- public static byte[] messageRowKey(Message<UUID> message)
message
- message to get row key frompublic static byte[] messageRowKey(UUID mailboxUid, long uid)
mailboxUid
- mailbox UUIDuid
- message uidpublic static byte[] customMessageRowKey(UUID mailboxUid, long value)
mailboxUid
- mailbox UUIDvalue
- public static Message<UUID> messageMetaFromResult(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.Result result)
ChunkInputStream
.
IMPORTANT: the method expects a single version of each cell. Use setMaxVersions(1).conf
- configuration object for HBase clusterresult
- the result object containing message datapublic static org.apache.hadoop.hbase.client.Put toPut(Subscription subscription)
public static org.apache.hadoop.hbase.client.Put flagsToPut(Message<UUID> message, javax.mail.Flags flags)
message
- flags
- public static org.apache.hadoop.hbase.client.Delete flagsToDelete(Message<UUID> message, javax.mail.Flags flags)
public static String flagsToString(javax.mail.Flags flags)
flags
- Copyright © 2010-2012 The Apache Software Foundation. All Rights Reserved.