Interface ReplicationOperations
Deprecated.
Supports replication configuration
- Since:
- 1.7.0
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Deprecated.Defines a cluster with the given name and the given name system.void
Deprecated.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
Deprecated.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.referencedFiles
(String tableName) Deprecated.Gets all of the referenced files for a table from the metadata table.void
removePeer
(String name) Deprecated.Removes a cluster with the given name.
-
Method Details
-
addPeer
void addPeer(String name, String replicaType) throws AccumuloException, AccumuloSecurityException, PeerExistsException Deprecated.Defines a cluster with the given name and the given name system.- Parameters:
name
- Unique name for the clusterreplicaType
- Class name to use to replicate the data- Throws:
AccumuloException
AccumuloSecurityException
PeerExistsException
-
removePeer
void removePeer(String name) throws AccumuloException, AccumuloSecurityException, PeerNotFoundException Deprecated.Removes a cluster with the given name.- Parameters:
name
- Name of the cluster to remove- Throws:
AccumuloException
AccumuloSecurityException
PeerNotFoundException
-
drain
void drain(String tableName) throws AccumuloException, AccumuloSecurityException, TableNotFoundException Deprecated.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.- Parameters:
tableName
- The table to wait for- Throws:
AccumuloException
AccumuloSecurityException
TableNotFoundException
-
drain
void drain(String tableName, Set<String> files) throws AccumuloException, AccumuloSecurityException, TableNotFoundException Deprecated.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.- Parameters:
tableName
- The table to wait for- Throws:
AccumuloException
AccumuloSecurityException
TableNotFoundException
-
referencedFiles
Set<String> referencedFiles(String tableName) throws AccumuloException, AccumuloSecurityException, TableNotFoundException Deprecated.Gets all of the referenced files for a table from the metadata table. The result of this method is intended to be directly supplied todrain(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 thatSet
todrain(String,Set)
to wait for all of those files to be replicated.
-