Package org.apache.accumulo.core.clientImpl

Class ReplicationOperationsImpl

java.lang.Object

org.apache.accumulo.core.clientImpl.ReplicationOperationsImpl

All Implemented Interfaces:

ReplicationOperations

public class ReplicationOperationsImpl
extends Object
implements ReplicationOperations

Constructor Summary

Constructors

Constructor	Description
ReplicationOperationsImpl(ClientContext context)

Method Summary

Modifier and Type	Method	Description
void	addPeer(String name, String replicaType)	Defines a cluster with the given name and the given name system.
void	drain(String tableName)	Waits for a table to be fully replicated, given the state of files pending replication for the provided table at the point in time which this method is invoked.
void	drain(String tableName, Set<String> wals)	Given the provided set of files that are pending replication for a table, wait for those files to be fully replicated to all configured peers.
protected boolean	getMasterDrain(TInfo tinfo, TCredentials rpcCreds, String tableName, Set<String> wals)
protected TableId	getTableId(AccumuloClient client, String tableName)
Set<String>	referencedFiles(String tableName)	Gets all of the referenced files for a table from the metadata table.
void	removePeer(String name)	Removes a cluster with the given name.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationOperationsImpl

public ReplicationOperationsImpl(ClientContext context)

Method Detail

addPeer

public void addPeer(String name,
                    String replicaType)
             throws AccumuloException,
                    AccumuloSecurityException

Description copied from interface: ReplicationOperations

Defines a cluster with the given name and the given name system.

Specified by:

addPeer in interface ReplicationOperations

Parameters:

name - Unique name for the cluster

replicaType - Class name to use to replicate the data

Throws:

AccumuloException

AccumuloSecurityException

removePeer

public void removePeer(String name)
                throws AccumuloException,
                       AccumuloSecurityException

Description copied from interface: ReplicationOperations

Removes a cluster with the given name.

Specified by:

removePeer in interface ReplicationOperations

Parameters:

name - Name of the cluster to remove

Throws:

AccumuloException

AccumuloSecurityException

drain

public void drain(String tableName)
           throws AccumuloException,
                  AccumuloSecurityException,
                  TableNotFoundException

Description copied from interface: ReplicationOperations

Waits for a table to be fully replicated, given the state of files pending replication for the provided table at the point in time which this method is invoked.

Specified by:

drain in interface ReplicationOperations

Parameters:

tableName - The table to wait for

Throws:

AccumuloException

AccumuloSecurityException

TableNotFoundException

drain

public void drain(String tableName,
                  Set<String> wals)
           throws AccumuloException,
                  AccumuloSecurityException,
                  TableNotFoundException

Description copied from interface: ReplicationOperations

Given the provided set of files that are pending replication for a table, wait for those files to be fully replicated to all configured peers. This allows for the accurate calculation when a table, at a given point in time, has been fully replicated.

Specified by:

drain in interface ReplicationOperations

Parameters:

tableName - The table to wait for

Throws:

AccumuloException

AccumuloSecurityException

TableNotFoundException

getMasterDrain

protected boolean getMasterDrain(TInfo tinfo,
                                 TCredentials rpcCreds,
                                 String tableName,
                                 Set<String> wals)
                          throws AccumuloException,
                                 AccumuloSecurityException,
                                 TableNotFoundException

Throws:

AccumuloException

AccumuloSecurityException

TableNotFoundException

getTableId

protected TableId getTableId(AccumuloClient client,
                             String tableName)
                      throws TableNotFoundException

Throws:

TableNotFoundException

referencedFiles

public Set<String> referencedFiles(String tableName)
                            throws TableNotFoundException

Description copied from interface: ReplicationOperations

Gets all of the referenced files for a table from the metadata table. The result of this method is intended to be directly supplied to ReplicationOperations.drain(String, Set). This helps determine when all data from a given point in time has been fully replicated.

This also allows callers to get the Set of files for a table at some time, and later provide that Set to ReplicationOperations.drain(String,Set) to wait for all of those files to be replicated.

Specified by:

referencedFiles in interface ReplicationOperations

Throws:

TableNotFoundException