com.splicemachine.derby.lifecycle

Class MEnginePartitionAdmin

java.lang.Object

com.splicemachine.derby.lifecycle.MEnginePartitionAdmin

All Implemented Interfaces:

PartitionAdmin, java.lang.AutoCloseable

public class MEnginePartitionAdmin
extends java.lang.Object
implements PartitionAdmin

Constructor Summary

Constructors

Constructor and Description
MEnginePartitionAdmin(PartitionAdmin admin)

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<? extends Partition>	allPartitions(java.lang.String tableName)
java.util.Collection<PartitionServer>	allServers()
void	assign(Partition partition)
void	close()
void	closeRegion(Partition partition)
void	deleteSnapshot(java.lang.String snapshotName)
void	deleteTable(java.lang.String tableName)
void	disableTable(java.lang.String tableName)
void	enableTable(java.lang.String tableName)
TableDescriptor	getTableDescriptor(java.lang.String table)
TableDescriptor[]	getTableDescriptors(java.util.List<java.lang.String> tables)
java.util.List<byte[]>	hbaseOperation(java.lang.String table, java.lang.String operation, byte[] bytes)
java.lang.Iterable<TableDescriptor>	listTables()
void	markDropped(long conglomId, long txn)
void	mergeRegions(java.lang.String regionName1, java.lang.String regionName2)
void	move(java.lang.String partition, java.lang.String server)
PartitionCreator	newPartition()
void	restoreSnapshot(java.lang.String snapshotName)
void	snapshot(java.lang.String snapshotName, java.lang.String tableName)
void	splitRegion(byte[] regionName, byte[]... splitPoints)
void	splitTable(java.lang.String tableName, byte[]... splitPoints)
boolean	tableExists(java.lang.String tableName)

Methods inherited from class java.lang.Object

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

Constructor Detail

MEnginePartitionAdmin

public MEnginePartitionAdmin(PartitionAdmin admin)

Method Detail

newPartition

public PartitionCreator newPartition()
                              throws java.io.IOException

Specified by:

newPartition in interface PartitionAdmin

Throws:

java.io.IOException

deleteTable

public void deleteTable(java.lang.String tableName)
                 throws java.io.IOException

Specified by:

deleteTable in interface PartitionAdmin

Throws:

java.io.IOException

splitTable

public void splitTable(java.lang.String tableName,
                       byte[]... splitPoints)
                throws java.io.IOException

Specified by:

splitTable in interface PartitionAdmin

Throws:

java.io.IOException

splitRegion

public void splitRegion(byte[] regionName,
                        byte[]... splitPoints)
                 throws java.io.IOException

Specified by:

splitRegion in interface PartitionAdmin

Throws:

java.io.IOException

mergeRegions

public void mergeRegions(java.lang.String regionName1,
                         java.lang.String regionName2)
                  throws java.io.IOException

Specified by:

mergeRegions in interface PartitionAdmin

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface PartitionAdmin

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

allServers

public java.util.Collection<PartitionServer> allServers()
                                                 throws java.io.IOException

Specified by:

allServers in interface PartitionAdmin

Throws:

java.io.IOException

allPartitions

public java.lang.Iterable<? extends Partition> allPartitions(java.lang.String tableName)
                                                      throws java.io.IOException

Specified by:

allPartitions in interface PartitionAdmin

Throws:

java.io.IOException

getTableDescriptors

public TableDescriptor[] getTableDescriptors(java.util.List<java.lang.String> tables)
                                      throws java.io.IOException

Specified by:

getTableDescriptors in interface PartitionAdmin

Throws:

java.io.IOException

listTables

public java.lang.Iterable<TableDescriptor> listTables()
                                               throws java.io.IOException

Specified by:

listTables in interface PartitionAdmin

Throws:

java.io.IOException

move

public void move(java.lang.String partition,
                 java.lang.String server)
          throws java.io.IOException

Specified by:

move in interface PartitionAdmin

Throws:

java.io.IOException

getTableDescriptor

public TableDescriptor getTableDescriptor(java.lang.String table)
                                   throws java.io.IOException

Specified by:

getTableDescriptor in interface PartitionAdmin

Throws:

java.io.IOException

snapshot

public void snapshot(java.lang.String snapshotName,
                     java.lang.String tableName)
              throws java.io.IOException

Specified by:

snapshot in interface PartitionAdmin

Throws:

java.io.IOException

deleteSnapshot

public void deleteSnapshot(java.lang.String snapshotName)
                    throws java.io.IOException

Specified by:

deleteSnapshot in interface PartitionAdmin

Throws:

java.io.IOException

restoreSnapshot

public void restoreSnapshot(java.lang.String snapshotName)
                     throws java.io.IOException

Specified by:

restoreSnapshot in interface PartitionAdmin

Throws:

java.io.IOException

disableTable

public void disableTable(java.lang.String tableName)
                  throws java.io.IOException

Specified by:

disableTable in interface PartitionAdmin

Throws:

java.io.IOException

enableTable

public void enableTable(java.lang.String tableName)
                 throws java.io.IOException

Specified by:

enableTable in interface PartitionAdmin

Throws:

java.io.IOException

closeRegion

public void closeRegion(Partition partition)
                 throws java.io.IOException,
                        java.lang.InterruptedException

Specified by:

closeRegion in interface PartitionAdmin

Throws:

java.io.IOException

java.lang.InterruptedException

assign

public void assign(Partition partition)
            throws java.io.IOException,
                   java.lang.InterruptedException

Specified by:

assign in interface PartitionAdmin

Throws:

java.io.IOException

java.lang.InterruptedException

tableExists

public boolean tableExists(java.lang.String tableName)
                    throws java.io.IOException

Specified by:

tableExists in interface PartitionAdmin

Throws:

java.io.IOException

hbaseOperation

public java.util.List<byte[]> hbaseOperation(java.lang.String table,
                                             java.lang.String operation,
                                             byte[] bytes)
                                      throws java.io.IOException

Specified by:

hbaseOperation in interface PartitionAdmin

Throws:

java.io.IOException

markDropped

public void markDropped(long conglomId,
                        long txn)
                 throws java.io.IOException

Specified by:

markDropped in interface PartitionAdmin

Throws:

java.io.IOException