public class HBaseMailboxSessionMapperFactory extends MailboxSessionMapperFactory<UUID>
MailboxSessionMapperFactoryMAILBOXMAPPER, MESSAGEMAPPER, SUBSCRIPTIONMAPPER| Constructor and Description |
|---|
HBaseMailboxSessionMapperFactory(org.apache.hadoop.conf.Configuration conf,
UidProvider<UUID> uidProvider,
ModSeqProvider<UUID> modSeqProvider)
Creates the necessary tables in HBase if they do not exist.
|
| Modifier and Type | Method and Description |
|---|---|
protected MailboxMapper<UUID> |
createMailboxMapper(MailboxSession session)
Create a
MailboxMapper instance which will get reused during the whole MailboxSession |
protected MessageMapper<UUID> |
createMessageMapper(MailboxSession session)
Create a
MessageMapper instance which will get reused during the whole MailboxSession |
protected SubscriptionMapper |
createSubscriptionMapper(MailboxSession session)
Create a
SubscriptionMapper instance which will get reused during the whole MailboxSession |
org.apache.hadoop.conf.Configuration |
getClusterConfiguration()
Returns the configuration object for accessing the cluster.
|
ModSeqProvider<UUID> |
getModSeqProvider()
Returns the ModSeqProvider used.
|
UidProvider<UUID> |
getUidProvider()
Returns the UidProvider that generates UID's for mailboxes.
|
endProcessingRequest, getMailboxMapper, getMessageMapper, getSubscriptionMapper, startProcessingRequestpublic HBaseMailboxSessionMapperFactory(org.apache.hadoop.conf.Configuration conf,
UidProvider<UUID> uidProvider,
ModSeqProvider<UUID> modSeqProvider)
conf - Configuration for the clusteruidProvider - UID provider for mailbox uid.modSeqProvider - org.apache.hadoop.hbase.MasterNotRunningExceptionorg.apache.hadoop.hbase.ZooKeeperConnectionExceptionIOExceptionprotected MessageMapper<UUID> createMessageMapper(MailboxSession session) throws MailboxException
MailboxSessionMapperFactoryMessageMapper instance which will get reused during the whole MailboxSessioncreateMessageMapper in class MailboxSessionMapperFactory<UUID>MailboxExceptionprotected MailboxMapper<UUID> createMailboxMapper(MailboxSession session) throws MailboxException
MailboxSessionMapperFactoryMailboxMapper instance which will get reused during the whole MailboxSessioncreateMailboxMapper in class MailboxSessionMapperFactory<UUID>MailboxExceptionprotected SubscriptionMapper createSubscriptionMapper(MailboxSession session) throws SubscriptionException
MailboxSessionMapperFactorySubscriptionMapper instance which will get reused during the whole MailboxSessioncreateSubscriptionMapper in class MailboxSessionMapperFactory<UUID>SubscriptionExceptionpublic org.apache.hadoop.conf.Configuration getClusterConfiguration()
public ModSeqProvider<UUID> getModSeqProvider()
public UidProvider<UUID> getUidProvider()
Copyright © 2010-2012 The Apache Software Foundation. All Rights Reserved.