xin.bluesky.leiothrix.server.action.allocate

类 AbstractPartitionAllocator

java.lang.Object

xin.bluesky.leiothrix.server.action.allocate.AbstractPartitionAllocator

所有已实现的接口:

PartitionAllocator

直接已知子类:

RandomTablePartitionAllocator, SequencePartitionAllocator, TableOneByOnePartitionAllocator

public abstract class AbstractPartitionAllocator
extends Object
implements PartitionAllocator

作者:

张轲

构造器概要

构造器

构造器和说明
AbstractPartitionAllocator()

方法概要

限定符和类型	方法和说明
List<PartitionTask>	findRange(String taskId)
protected abstract List<PartitionTask>	findRange(String taskId, List<String> tableNameList)
protected List<String>	getAllTables(String taskId)
protected boolean	isTableFinished(String taskId, String tableName)
protected boolean	isTableProcessing(String taskId, String tableName)
protected boolean	isTableProcessingOrFinished(String taskId, String tableName)
protected List<PartitionTask>	preAllocate(String taskId, String tableName, List<String> rangeNameList)

从类继承的方法 java.lang.Object

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

构造器详细资料

AbstractPartitionAllocator

public AbstractPartitionAllocator()

方法详细资料

findRange

public List<PartitionTask> findRange(String taskId)
                              throws NoTaskException,
                                     WaitAndTryLaterException

指定者:

findRange 在接口中 PartitionAllocator

抛出:

NoTaskException

WaitAndTryLaterException

getAllTables

protected List<String> getAllTables(String taskId)

findRange

protected abstract List<PartitionTask> findRange(String taskId,
                                                 List<String> tableNameList)
                                          throws NoTaskException,
                                                 WaitAndTryLaterException

抛出:

NoTaskException

WaitAndTryLaterException

preAllocate

protected List<PartitionTask> preAllocate(String taskId,
                                          String tableName,
                                          List<String> rangeNameList)

isTableProcessingOrFinished

protected boolean isTableProcessingOrFinished(String taskId,
                                              String tableName)

isTableProcessing

protected boolean isTableProcessing(String taskId,
                                    String tableName)

isTableFinished

protected boolean isTableFinished(String taskId,
                                  String tableName)