xin.bluesky.leiothrix.server.action.allocate

类 SequencePartitionAllocator

java.lang.Object

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

xin.bluesky.leiothrix.server.action.allocate.SequencePartitionAllocator

所有已实现的接口:

PartitionAllocator

public class SequencePartitionAllocator
extends AbstractPartitionAllocator

按照table+range作为维度,依次分配.

eg:假设两个表(table-1,table-2),各自range情况如下:

• table-1:0-1000,1001-2000两个range
• table-2:0-3000,3001-6000,6001-9000三个range

那么分配顺序依次是:table-1:0-1000,table-1:1001-2000,table-2:0-3000,table-2:3001-6000,table-3:6001-9000. 当然这是理论上的划分,实际上由于多线程的关系和网络时延区别,这个顺序会略有颠倒,并不保证严格有序,但总体来说,是按照从前到后的顺序.

在这种情况下,会出现同一时刻,两个表的range在同时处理的情况,比如table-1:1001-2000和table-2:0-3000会分别被两个worker线程执行. 在实际场景中,可能有这样的业务:需要等待table-1全部处理完毕,再处理table-2的数据(比如数据清洗),此时需要保证table-2严格在table-1 完全结束后再执行,此时应该使用TableOneByOnePartitionAllocator

作者:

张轲

构造器概要

构造器

构造器和说明
SequencePartitionAllocator()

方法概要

限定符和类型	方法和说明
List<PartitionTask>	findRange(String taskId, List<String> tableNameList)

从类继承的方法 xin.bluesky.leiothrix.server.action.allocate.AbstractPartitionAllocator

findRange, getAllTables, isTableFinished, isTableProcessing, isTableProcessingOrFinished, preAllocate

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

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

构造器详细资料

SequencePartitionAllocator

public SequencePartitionAllocator()

方法详细资料

findRange

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

指定者:

findRange 在类中 AbstractPartitionAllocator

抛出:

NoTaskException