@InterfaceAudience.Private public class CreateTableHandler extends EventHandler
EventHandler.EventHandlerListener
Modifier and Type | Field and Description |
---|---|
protected Configuration |
conf |
protected MasterFileSystem |
fileSystemManager |
protected HTableDescriptor |
hTableDescriptor |
eventType, seqids, server, waitingTimeForEvents
Constructor and Description |
---|
CreateTableHandler(Server server,
MasterFileSystem fileSystemManager,
HTableDescriptor hTableDescriptor,
Configuration conf,
HRegionInfo[] newRegions,
MasterServices masterServices) |
Modifier and Type | Method and Description |
---|---|
protected void |
addRegionsToMeta(java.util.List<HRegionInfo> regionInfos,
int regionReplication)
Add the specified set of regions to the hbase:meta table.
|
protected java.util.List<HRegionInfo> |
addReplicas(HTableDescriptor hTableDescriptor,
java.util.List<HRegionInfo> regions)
Create any replicas for the regions (the default replicas that was
already created is passed to the method)
|
protected void |
completed(java.lang.Throwable exception)
Called after that process() is completed.
|
protected java.util.List<HRegionInfo> |
handleCreateHdfsRegions(Path tableRootDir,
TableName tableName)
Create the on-disk structure for the table, and returns the regions info.
|
CreateTableHandler |
prepare()
Event handlers should do all the necessary checks in this method (rather than
in the constructor, or in process()) so that the caller, which is mostly executed
in the ipc context can fail fast.
|
void |
process()
This method is the main processing loop to be implemented by the various
subclasses.
|
java.lang.String |
toString() |
compareTo, getEventType, getInformativeName, getListener, getPriority, getSeqid, handleException, run, setListener
protected final MasterFileSystem fileSystemManager
protected final HTableDescriptor hTableDescriptor
protected final Configuration conf
public CreateTableHandler(Server server, MasterFileSystem fileSystemManager, HTableDescriptor hTableDescriptor, Configuration conf, HRegionInfo[] newRegions, MasterServices masterServices)
public CreateTableHandler prepare() throws NotAllMetaRegionsOnlineException, TableExistsException, java.io.IOException
EventHandler
prepare
in class EventHandler
NotAllMetaRegionsOnlineException
TableExistsException
java.io.IOException
public java.lang.String toString()
toString
in class EventHandler
public void process()
EventHandler
process
in class EventHandler
protected void completed(java.lang.Throwable exception)
exception
- null if process() is successful or not null if something has failed.protected java.util.List<HRegionInfo> addReplicas(HTableDescriptor hTableDescriptor, java.util.List<HRegionInfo> regions)
hTableDescriptor
- regions
- default replicasprotected java.util.List<HRegionInfo> handleCreateHdfsRegions(Path tableRootDir, TableName tableName) throws java.io.IOException
tableRootDir
- directory where the table is being createdtableName
- name of the table under constructionjava.io.IOException
protected void addRegionsToMeta(java.util.List<HRegionInfo> regionInfos, int regionReplication) throws java.io.IOException
java.io.IOException