public class HBaseMailboxSessionMapperFactory extends MailboxSessionMapperFactory<UUID>
MailboxSessionMapperFactory
MAILBOXMAPPER, 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, startProcessingRequest
public 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.MasterNotRunningException
org.apache.hadoop.hbase.ZooKeeperConnectionException
IOException
protected MessageMapper<UUID> createMessageMapper(MailboxSession session) throws MailboxException
MailboxSessionMapperFactory
MessageMapper
instance which will get reused during the whole MailboxSession
createMessageMapper
in class MailboxSessionMapperFactory<UUID>
MailboxException
protected MailboxMapper<UUID> createMailboxMapper(MailboxSession session) throws MailboxException
MailboxSessionMapperFactory
MailboxMapper
instance which will get reused during the whole MailboxSession
createMailboxMapper
in class MailboxSessionMapperFactory<UUID>
MailboxException
protected SubscriptionMapper createSubscriptionMapper(MailboxSession session) throws SubscriptionException
MailboxSessionMapperFactory
SubscriptionMapper
instance which will get reused during the whole MailboxSession
createSubscriptionMapper
in class MailboxSessionMapperFactory<UUID>
SubscriptionException
public org.apache.hadoop.conf.Configuration getClusterConfiguration()
public ModSeqProvider<UUID> getModSeqProvider()
public UidProvider<UUID> getUidProvider()
Copyright © 2010-2012 The Apache Software Foundation. All Rights Reserved.