Package org.apache.accumulo.core.replication

Class ReplicationTable

java.lang.Object

org.apache.accumulo.core.replication.ReplicationTable

public class ReplicationTable
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	COMBINER_NAME
static TableId	ID
static Map<String,Set<org.apache.hadoop.io.Text>>	LOCALITY_GROUPS
static String	NAME
static Set<org.apache.hadoop.io.Text>	STATUS_LG_COLFAMS
static String	STATUS_LG_NAME
static Set<org.apache.hadoop.io.Text>	WORK_LG_COLFAMS
static String	WORK_LG_NAME

Constructor Summary

Constructors

Constructor	Description
ReplicationTable()

Method Summary

Modifier and Type	Method	Description
static BatchScanner	getBatchScanner(AccumuloClient client, int queryThreads)
static BatchWriter	getBatchWriter(AccumuloClient client)
static Scanner	getScanner(AccumuloClient client)
static boolean	isOnline(AccumuloClient client)
static void	setOnline(AccumuloClient client)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ID

public static final TableId ID

NAME

public static final String NAME

COMBINER_NAME

public static final String COMBINER_NAME

See Also:

Constant Field Values

STATUS_LG_NAME

public static final String STATUS_LG_NAME

STATUS_LG_COLFAMS

public static final Set<org.apache.hadoop.io.Text> STATUS_LG_COLFAMS

WORK_LG_NAME

public static final String WORK_LG_NAME

WORK_LG_COLFAMS

public static final Set<org.apache.hadoop.io.Text> WORK_LG_COLFAMS

LOCALITY_GROUPS

public static final Map<String,Set<org.apache.hadoop.io.Text>> LOCALITY_GROUPS

Constructor Detail

ReplicationTable

public ReplicationTable()

Method Detail

getScanner

public static Scanner getScanner(AccumuloClient client)
                          throws ReplicationTableOfflineException

Throws:

ReplicationTableOfflineException

getBatchWriter

public static BatchWriter getBatchWriter(AccumuloClient client)
                                  throws ReplicationTableOfflineException

Throws:

ReplicationTableOfflineException

getBatchScanner

public static BatchScanner getBatchScanner(AccumuloClient client,
                                           int queryThreads)
                                    throws ReplicationTableOfflineException

Throws:

ReplicationTableOfflineException

isOnline

public static boolean isOnline(AccumuloClient client)

setOnline

public static void setOnline(AccumuloClient client)
                      throws AccumuloSecurityException,
                             AccumuloException

Throws:

AccumuloSecurityException

AccumuloException