A B C D E F G H I K L M N O P Q R S T U V W X Z

A

AbstractPartitionAllocator - xin.bluesky.leiothrix.server.action.allocate中的类

AbstractPartitionAllocator() - 类 的构造器xin.bluesky.leiothrix.server.action.allocate.AbstractPartitionAllocator

AcquireTaskHandler - xin.bluesky.leiothrix.server.interactive.worker.msghandler中的类

AcquireTaskHandler() - 类 的构造器xin.bluesky.leiothrix.server.interactive.worker.msghandler.AcquireTaskHandler

addIntValue(String, Integer) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

该方法不是线程安全的

addLongValue(String, Long) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

该方法不是线程安全的

addServerListWatch(ServerUpdatedTrigger) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.ServerStorage

addUnallocatedRangeName(String) - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.RangeScanResult

addWorkerProcessor(String, String, String, Date) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

给task记录处理其的worker进程及相关信息

after() - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerProcessorLauncher

alreadyRegister() - 类 中的静态方法xin.bluesky.leiothrix.server.storage.WorkerStorage

appendValue(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

该方法不是线程安全的

availableWorkers() - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerInfoInitializer

availableWorkersPhysicalInfo() - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerInfoInitializer

B

before() - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerProcessorLauncher

bingServlets(ServletContextHandler) - 类 中的静态方法xin.bluesky.leiothrix.server.interactive.client.UrlMapping

C

calAvailableProcessNum(NodeInfo) - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerProcessorInvoker

以内存来计算可分配的worker进程数量.

calAvailableProcessNum(NodeInfo) - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerProcessorLauncher

cancel(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

取消任务.

CancelTaskServlet - xin.bluesky.leiothrix.server.interactive.client中的类

CancelTaskServlet() - 类 的构造器xin.bluesky.leiothrix.server.interactive.client.CancelTaskServlet

channelActive(ChannelHandlerContext) - 类 中的方法xin.bluesky.leiothrix.server.interactive.worker.WorkerChannelInboundHandler

channelInactive(ChannelHandlerContext) - 类 中的方法xin.bluesky.leiothrix.server.interactive.worker.WorkerChannelInboundHandler

channelRead(ChannelHandlerContext, Object) - 类 中的方法xin.bluesky.leiothrix.server.interactive.worker.WorkerChannelInboundHandler

checkExists(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

chooseSuitableDatabase(String) - 类 中的方法xin.bluesky.leiothrix.server.action.PartitionTaskFinder

clean() - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.EmbeddedZookeeperServer

ClientRequestListener - xin.bluesky.leiothrix.server.interactive.client中的类

ClientRequestListener() - 类 的构造器xin.bluesky.leiothrix.server.interactive.client.ClientRequestListener

collectExecutionStatistics() - 类 中的方法xin.bluesky.leiothrix.server.action.TaskStatisticsCollector

collectWorkersInfo() - 类 中的方法xin.bluesky.leiothrix.server.action.TaskStatisticsCollector

CommandFactory - xin.bluesky.leiothrix.server.interactive.worker中的类

CommandFactory() - 类 的构造器xin.bluesky.leiothrix.server.interactive.worker.CommandFactory

CompensateSingleTaskStrategy - xin.bluesky.leiothrix.server.background.compensate中的类

补偿单个任务的策略.将空闲资源首先分配给未被执行的任务,如不存在则分配给最老的任务

CompensateSingleTaskStrategy() - 类 的构造器xin.bluesky.leiothrix.server.background.compensate.CompensateSingleTaskStrategy

CompensateStrategy - xin.bluesky.leiothrix.server.background.compensate中的接口

ConfigureException - xin.bluesky.leiothrix.server.conf中的异常错误

ConfigureException() - 异常错误 的构造器xin.bluesky.leiothrix.server.conf.ConfigureException

ConfigureException(String) - 异常错误 的构造器xin.bluesky.leiothrix.server.conf.ConfigureException

ConfigureException(String, Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.conf.ConfigureException

ConfigureException(Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.conf.ConfigureException

ConfigureException(String, Throwable, boolean, boolean) - 异常错误 的构造器xin.bluesky.leiothrix.server.conf.ConfigureException

Constant - xin.bluesky.leiothrix.server中的类

Constant() - 类 的构造器xin.bluesky.leiothrix.server.Constant

containsKey(K) - 类 中的方法xin.bluesky.leiothrix.server.cache.ExpiredMap

copyJar2Worker(String, String, String) - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerManager

createEmptyTask(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

创建一个空任务,只包含taskId节点和状态节点

createEmptyTask(String, TaskStatus) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

createNode(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

createNode(String, CreateMode) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

createNodeAndSetData(String, String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

createNodeAndSetData(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

createRange(String, String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.RangeStorage

createRange(String, String, String, int) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.RangeStorage

createTable(String, TableMeta) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TableStorage

D

DatabaseSchemaLoader - xin.bluesky.leiothrix.server.tablemeta中的类

DatabaseSchemaLoader() - 类 的构造器xin.bluesky.leiothrix.server.tablemeta.DatabaseSchemaLoader

DataLoaderException - xin.bluesky.leiothrix.server.tablemeta中的异常错误

DataLoaderException() - 异常错误 的构造器xin.bluesky.leiothrix.server.tablemeta.DataLoaderException

DataLoaderException(String) - 异常错误 的构造器xin.bluesky.leiothrix.server.tablemeta.DataLoaderException

DataLoaderException(String, Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.tablemeta.DataLoaderException

DataLoaderException(Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.tablemeta.DataLoaderException

DataLoaderException(String, Throwable, boolean, boolean) - 异常错误 的构造器xin.bluesky.leiothrix.server.tablemeta.DataLoaderException

delete(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

删除Task

delete(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.WorkerStorage

delete(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

DELETE_DAY_THRESHOLD - 类 中的静态变量xin.bluesky.leiothrix.server.background.TaskDeleteJob

deleteOnAllServers(String) - 类 中的静态方法xin.bluesky.leiothrix.server.interactive.client.TaskFileService

doLaunch() - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerProcessorLauncher

doLoad(String, DatabaseInfo, List<String>) - 类 中的方法xin.bluesky.leiothrix.server.tablemeta.DatabaseSchemaLoader

doLoad(String, DatabaseInfo, List<String>) - 类 中的方法xin.bluesky.leiothrix.server.tablemeta.MySQLSchemaLoader

doPost(HttpServletRequest, HttpServletResponse) - 类 中的方法xin.bluesky.leiothrix.server.interactive.client.CancelTaskServlet

doPost(HttpServletRequest, HttpServletResponse) - 类 中的方法xin.bluesky.leiothrix.server.interactive.client.KillForceTaskProcessorServlet

doPost(HttpServletRequest, HttpServletResponse) - 类 中的方法xin.bluesky.leiothrix.server.interactive.client.QueryProgressServlet

doPost(HttpServletRequest, HttpServletResponse) - 类 中的方法xin.bluesky.leiothrix.server.interactive.client.SubmitTaskServlet

E

EmbeddedZookeeperServer - xin.bluesky.leiothrix.server.storage.zk中的类

evict(String) - 类 中的静态方法xin.bluesky.leiothrix.server.cache.PartitionTaskContainer

exceptionCaught(ChannelHandlerContext, Throwable) - 类 中的方法xin.bluesky.leiothrix.server.interactive.worker.WorkerChannelInboundHandler

execute() - 类 中的方法xin.bluesky.leiothrix.server.background.compensate.CompensateSingleTaskStrategy

execute() - 接口 中的方法xin.bluesky.leiothrix.server.background.compensate.CompensateStrategy

exist(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.WorkerStorage

ExpiredMap<K,V> - xin.bluesky.leiothrix.server.cache中的类

元素会超时的map,主要是为了定时清理掉可能不再需要的数据.

ExpiredMap(int) - 类 的构造器xin.bluesky.leiothrix.server.cache.ExpiredMap

F

find() - 类 中的方法xin.bluesky.leiothrix.server.action.PartitionTaskFinder

findRange(String) - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.AbstractPartitionAllocator

findRange(String, List<String>) - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.AbstractPartitionAllocator

findRange(String, List<String>) - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.RandomTablePartitionAllocator

已过时。

findRange(String, List<String>) - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.SequencePartitionAllocator

findRange(String, List<String>) - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.TableOneByOnePartitionAllocator

这种场景的分配调度比较复杂.

findRange(String) - 接口 中的方法xin.bluesky.leiothrix.server.action.PartitionAllocator

FindTaskException - xin.bluesky.leiothrix.server.action.exception中的异常错误

FindTaskException() - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.FindTaskException

FindTaskException(String) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.FindTaskException

FindTaskException(String, Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.FindTaskException

FindTaskException(Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.FindTaskException

FindTaskException(String, Throwable, boolean, boolean) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.FindTaskException

FinishedComponentCache - xin.bluesky.leiothrix.server.cache中的类

FinishedPartitionTaskHandler - xin.bluesky.leiothrix.server.interactive.worker.msghandler中的类

FinishedPartitionTaskHandler() - 类 的构造器xin.bluesky.leiothrix.server.interactive.worker.msghandler.FinishedPartitionTaskHandler

finishedWorkerProcessor(String, String, String, Date) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

给task记录处理其的worker进程的结束记录

G

get(String) - 类 中的静态方法xin.bluesky.leiothrix.server.action.PartitionAllocatorFactory

根据task的配置,来获得对应的PartitionAllocator的实现类

get(K) - 类 中的方法xin.bluesky.leiothrix.server.cache.ExpiredMap

get(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.cache.TaskRangesCache

get(String) - 类 中的静态方法xin.bluesky.leiothrix.server.cache.TaskStaticInfoCache

get(String) - 类 中的静态方法xin.bluesky.leiothrix.server.cache.TaskTablesCache

get(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.cache.TaskTablesMetaCache

get(String) - 类 中的静态方法xin.bluesky.leiothrix.server.conf.ServerConfigure

get(String, boolean) - 类 中的静态方法xin.bluesky.leiothrix.server.conf.ServerConfigure

get(String, Class<T>) - 类 中的静态方法xin.bluesky.leiothrix.server.conf.ServerConfigure

get(String) - 类 中的静态方法xin.bluesky.leiothrix.server.interactive.worker.CommandFactory

get(String) - 类 中的静态方法xin.bluesky.leiothrix.server.lock.ProcessorStartingHolder

get() - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperClientFactory

getAllFinishedTasks() - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

获得所有已结束的任务

getAllProcessingTasks() - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

获得所有当前正在处理中的任务

getAllRangesByTableName(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.RangeStorage

getAllServers() - 类 中的静态方法xin.bluesky.leiothrix.server.storage.ServerStorage

getAllTables(String) - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.AbstractPartitionAllocator

getAllTables(String) - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.TableOneByOnePartitionAllocator

getAllTablesByTaskId(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TableStorage

getAllTasks() - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

获得所有Task

getAllTaskWorkers(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

getAllWorkerInfoWithInitialMemory() - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerManager

getAllWorkers() - 类 中的静态方法xin.bluesky.leiothrix.server.storage.WorkerStorage

getChildrenWithFullPath(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

getChildrenWithSimplePath(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

getClient() - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

getClientsSet() - 类 中的静态方法xin.bluesky.leiothrix.server.interactive.worker.WorkerChannelInboundHandler

getCpuNumber() - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

getDataBoolean(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

getDataByte(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

getDataInteger(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

getDataLong(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

getDataString(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

getErrorMsg() - 类 中的方法xin.bluesky.leiothrix.server.lock.ProcessorStartingHolder

getExecutionStatistics(String, String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.RangeStorage

getFinishedTime() - 类 中的方法xin.bluesky.leiothrix.server.action.TaskStatisticsCollector.ProcessorInfo

getInstance() - 类 中的静态方法xin.bluesky.leiothrix.server.cache.FinishedComponentCache

getInstance(String) - 类 中的静态方法xin.bluesky.leiothrix.server.cache.PartitionTaskContainer

getIp() - 类 中的方法xin.bluesky.leiothrix.server.action.TaskStatisticsCollector.WorkerInfo

getIp() - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodeInfo

getIp() - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

getMemoryFree() - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

getMemoryFreeBeforeAsWorker() - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

getMemoryTotal() - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

getMyIp() - 类 中的静态方法xin.bluesky.leiothrix.server.util.LeiothrixUtils

getNodeStat(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

getOldestProcessingTask() - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

获得最老的Task(执行完的task除外)

getPartitionTask(String, String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.RangeStorage

getPartitionTaskFindLock(String) - 类 中的静态方法xin.bluesky.leiothrix.server.lock.LockFactory

getPhysicalInfo() - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodeInfo

getPhysicalInfo(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.WorkerStorage

getPhysicalUpperLimitProcessNum(NodeInfo) - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerProcessorInvoker

获得worker物理机的自身内存,所允许启动的进程数量上限

getPid() - 类 中的方法xin.bluesky.leiothrix.server.action.TaskStatisticsCollector.ProcessorInfo

getPort() - 类 中的方法xin.bluesky.leiothrix.server.interactive.worker.WorkerMessageListener

getPrimaryKey() - 类 中的方法xin.bluesky.leiothrix.server.tablemeta.TableMeta

getProcessors() - 类 中的方法xin.bluesky.leiothrix.server.action.TaskStatisticsCollector.WorkerInfo

getRangeLastUpdateTime(String, String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.RangeStorage

getRangeNameList() - 类 中的方法xin.bluesky.leiothrix.server.bean.task.TaskRanges

getRangeStatus(String, String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.RangeStorage

getRemoteFullCommand(String, String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.interactive.worker.CommandFactory

getRemoteFullCommandByKey(String, String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.interactive.worker.CommandFactory

getRunningTime() - 类 中的方法xin.bluesky.leiothrix.server.action.TaskStatisticsCollector.ProcessorInfo

getServer() - 类 中的静态方法xin.bluesky.leiothrix.server.Server

getStartTime() - 类 中的方法xin.bluesky.leiothrix.server.action.TaskStatisticsCollector.ProcessorInfo

getStatus(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TableStorage

getStatus(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

获得Task的当前状态

getTableMeta(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TableStorage

getTableName() - 类 中的方法xin.bluesky.leiothrix.server.bean.task.TaskRanges

getTableName() - 类 中的方法xin.bluesky.leiothrix.server.tablemeta.TableMeta

getTableNameList() - 类 中的方法xin.bluesky.leiothrix.server.bean.task.TaskTables

getTaskConfig(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

获得Task的config信息

getTaskDirPath(String) - 类 中的静态方法xin.bluesky.leiothrix.server.util.LeiothrixUtils

getTaskFinishedTime(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

getTaskId() - 类 中的方法xin.bluesky.leiothrix.server.bean.task.TaskRanges

getTaskId() - 类 中的方法xin.bluesky.leiothrix.server.bean.task.TaskTables

getTaskRangesCacheLock(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.lock.LockFactory

getTaskStaticInfo(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

getTaskStaticInfoCacheLock(String) - 类 中的静态方法xin.bluesky.leiothrix.server.lock.LockFactory

getTaskTableMetaCacheLock(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.lock.LockFactory

getTaskTablesCacheLock(String) - 类 中的静态方法xin.bluesky.leiothrix.server.lock.LockFactory

getUnallocatedRangeNameList() - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.RangeScanResult

getUnallocatedTask() - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

获得未被分配执行的任务

getUser() - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

getWorkerNumbers() - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodeInfo

getWorkerProcessor(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

getWorkerProcessorFinishedTime(String, String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

getWorkerProcessorStartTime(String, String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

getWorkersNumber(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.WorkerStorage

GiveBackPartitionTaskHandler - xin.bluesky.leiothrix.server.interactive.worker.msghandler中的类

GiveBackPartitionTaskHandler() - 类 的构造器xin.bluesky.leiothrix.server.interactive.worker.msghandler.GiveBackPartitionTaskHandler

H

handle(ChannelHandlerContext, WorkerMessage) - 类 中的方法xin.bluesky.leiothrix.server.interactive.worker.msghandler.AcquireTaskHandler

handle(ChannelHandlerContext, WorkerMessage) - 类 中的方法xin.bluesky.leiothrix.server.interactive.worker.msghandler.FinishedPartitionTaskHandler

handle(ChannelHandlerContext, WorkerMessage) - 类 中的方法xin.bluesky.leiothrix.server.interactive.worker.msghandler.GiveBackPartitionTaskHandler

handle(ChannelHandlerContext, WorkerMessage) - 类 中的方法xin.bluesky.leiothrix.server.interactive.worker.msghandler.PingHandler

handle(ChannelHandlerContext, WorkerMessage) - 类 中的方法xin.bluesky.leiothrix.server.interactive.worker.msghandler.ProcessorAnnounceHandler

handle(ChannelHandlerContext, WorkerMessage) - 类 中的方法xin.bluesky.leiothrix.server.interactive.worker.msghandler.WorkerProgressReportHandler

handle(ChannelHandlerContext, WorkerMessage) - 接口 中的方法xin.bluesky.leiothrix.server.interactive.worker.WorkerMessageHandler

hasUnallocatedRange() - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.RangeScanResult

hold() - 类 中的方法xin.bluesky.leiothrix.server.lock.ProcessorStartingHolder

hold(long, TimeUnit) - 类 中的方法xin.bluesky.leiothrix.server.lock.ProcessorStartingHolder

I

invoke(String, String, String, String) - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerProcessorInvoker

isEmpty() - 类 中的方法xin.bluesky.leiothrix.server.cache.ExpiredMap

isEmpty() - 类 中的方法xin.bluesky.leiothrix.server.cache.PartitionTaskContainer

isFinished() - 类 中的方法xin.bluesky.leiothrix.server.action.TaskStatisticsCollector.ProcessorInfo

isPartitionTaskFinished(String, String, String) - 类 中的方法xin.bluesky.leiothrix.server.cache.FinishedComponentCache

isResourceEnough(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

得到该任务的当前运行资源是否足够的值

isRunningSuccess() - 类 中的方法xin.bluesky.leiothrix.server.lock.ProcessorStartingHolder

isTableFinished(String, String) - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.AbstractPartitionAllocator

isTableFinished() - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.RangeScanResult

isTableFinished(String, String) - 类 中的方法xin.bluesky.leiothrix.server.cache.FinishedComponentCache

isTableProcessing(String, String) - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.AbstractPartitionAllocator

isTableProcessingOrFinished(String, String) - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.AbstractPartitionAllocator

isTaskFinished(String) - 类 中的方法xin.bluesky.leiothrix.server.cache.FinishedComponentCache

K

KillForceTaskProcessorServlet - xin.bluesky.leiothrix.server.interactive.client中的类

KillForceTaskProcessorServlet() - 类 的构造器xin.bluesky.leiothrix.server.interactive.client.KillForceTaskProcessorServlet

L

launch() - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerProcessorLauncher

LeiothrixUtils - xin.bluesky.leiothrix.server.util中的类

LeiothrixUtils() - 类 的构造器xin.bluesky.leiothrix.server.util.LeiothrixUtils

loadDatabaseSchema(String) - 类 中的静态方法xin.bluesky.leiothrix.server.tablemeta.DatabaseSchemaLoader

LockFactory - xin.bluesky.leiothrix.server.lock中的类

LockFactory() - 类 的构造器xin.bluesky.leiothrix.server.lock.LockFactory

logger - 类 中的静态变量xin.bluesky.leiothrix.server.action.allocate.TableOneByOnePartitionAllocator

logger - 类 中的静态变量xin.bluesky.leiothrix.server.background.compensate.CompensateSingleTaskStrategy

logger - 类 中的静态变量xin.bluesky.leiothrix.server.background.TaskCompensatorJob

logger - 类 中的静态变量xin.bluesky.leiothrix.server.interactive.worker.msghandler.ProcessorAnnounceHandler

logger - 类 中的静态变量xin.bluesky.leiothrix.server.storage.zk.EmbeddedZookeeperServer

logTaskFinishedTime(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

记录任务的结束时间

logTaskStartTime(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

记录任务的启动时间

M

main(String[]) - 类 中的静态方法xin.bluesky.leiothrix.server.action.exception.Test

main(String[]) - 类 中的静态方法xin.bluesky.leiothrix.server.Server

makePath(String...) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

mkdir(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

mkdir(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

mkdirRecursive(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

MySQLSchemaLoader - xin.bluesky.leiothrix.server.tablemeta中的类

MySQLSchemaLoader() - 类 的构造器xin.bluesky.leiothrix.server.tablemeta.MySQLSchemaLoader

N

NAME_CONFIG_FILE - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TaskStorage

NAME_JAR - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TaskStorage

NAME_MAIN_CLASS - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TaskStorage

NAME_META - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TableStorage

NAME_RANGE_END_INDEX - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

NAME_RANGE_RECORD_NUM - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

NAME_RANGE_START_INDEX - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

NAME_RANGES - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

NAME_RESOURCE_ENOUGH - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TaskStorage

NAME_STAT - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

NAME_STAT_EXCEPTION_STACK_TRACE - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

NAME_STAT_FAIL_PAGE - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

NAME_STAT_HANDLE_USING_TIME - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

NAME_STAT_QUERY_USING_TIME - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

NAME_STAT_RECORD_NUM - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

NAME_STAT_RECORD_NUM_FAIL - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

NAME_STAT_RECORD_NUM_SUCCESS - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

NAME_STAT_TOTAL_TIME - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

NAME_STATISTICS - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TaskStorage

NAME_STATISTICS_TASK_FINISHED_TIME - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TaskStorage

NAME_STATISTICS_TASK_START_TIME - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TaskStorage

NAME_STATUS - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

NAME_STATUS - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TableStorage

NAME_STATUS - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TaskStorage

NAME_TABLES - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TableStorage

NAME_TIMEOUT_FLAG - 类 中的静态变量xin.bluesky.leiothrix.server.storage.RangeStorage

判断range是否处理超时的标志字段

NAME_WORKER_PROCESSOR_NUMBER - 类 中的静态变量xin.bluesky.leiothrix.server.storage.WorkerStorage

NAME_WORKERS - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TaskStorage

NAME_WORKERS_PROCESSOR_FINISHED_TIME - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TaskStorage

NAME_WORKERS_PROCESSOR_START_TIME - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TaskStorage

NodeInfo - xin.bluesky.leiothrix.server.bean.node中的类

NodeInfo() - 类 的构造器xin.bluesky.leiothrix.server.bean.node.NodeInfo

NodeInfo(NodePhysicalInfo, int) - 类 的构造器xin.bluesky.leiothrix.server.bean.node.NodeInfo

NodePhysicalInfo - xin.bluesky.leiothrix.server.bean.node中的类

NodePhysicalInfo() - 类 的构造器xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

NodePhysicalInfo(String, String) - 类 的构造器xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

NoResourceException - xin.bluesky.leiothrix.server.action.exception中的异常错误

NoResourceException() - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.NoResourceException

NoResourceException(String) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.NoResourceException

NoResourceException(String, Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.NoResourceException

NoResourceException(Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.NoResourceException

NotAllowedLaunchException - xin.bluesky.leiothrix.server.action.exception中的异常错误

NotAllowedLaunchException() - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.NotAllowedLaunchException

NotAllowedLaunchException(String) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.NotAllowedLaunchException

NotAllowedLaunchException(String, Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.NotAllowedLaunchException

NotAllowedLaunchException(Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.NotAllowedLaunchException

NoTaskException - xin.bluesky.leiothrix.server.action.exception中的异常错误

NoTaskException() - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.NoTaskException

NoTaskException(String) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.NoTaskException

NoTaskException(String, Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.NoTaskException

NoTaskException(Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.NoTaskException

NoTaskException(String, Throwable, boolean, boolean) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.NoTaskException

notExist(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.WorkerStorage

O

offer(List<PartitionTask>) - 类 中的方法xin.bluesky.leiothrix.server.cache.PartitionTaskContainer

offer(PartitionTask) - 类 中的方法xin.bluesky.leiothrix.server.cache.PartitionTaskContainer

P

PARTITION_TASK_FIND_LOCK_PATH - 类 中的静态变量xin.bluesky.leiothrix.server.lock.LockFactory

PartitionAllocator - xin.bluesky.leiothrix.server.action中的接口

片划分的抽象接口.

PartitionAllocatorFactory - xin.bluesky.leiothrix.server.action中的类

PartitionAllocatorFactory() - 类 的构造器xin.bluesky.leiothrix.server.action.PartitionAllocatorFactory

PartitionTaskContainer - xin.bluesky.leiothrix.server.cache中的类

PartitionTaskFinder - xin.bluesky.leiothrix.server.action中的类

PartitionTaskFinder(String, PartitionAllocator) - 类 的构造器xin.bluesky.leiothrix.server.action.PartitionTaskFinder

physicalInfo(String) - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerInfoInitializer

PingHandler - xin.bluesky.leiothrix.server.interactive.worker.msghandler中的类

PingHandler() - 类 的构造器xin.bluesky.leiothrix.server.interactive.worker.msghandler.PingHandler

poll() - 类 中的方法xin.bluesky.leiothrix.server.cache.PartitionTaskContainer

preAllocate(String, String, List<String>) - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.AbstractPartitionAllocator

ProcessorAnnounceHandler - xin.bluesky.leiothrix.server.interactive.worker.msghandler中的类

ProcessorAnnounceHandler() - 类 的构造器xin.bluesky.leiothrix.server.interactive.worker.msghandler.ProcessorAnnounceHandler

ProcessorInfo(String, String, String) - 类 的构造器xin.bluesky.leiothrix.server.action.TaskStatisticsCollector.ProcessorInfo

ProcessorLaunchException - xin.bluesky.leiothrix.server.action.exception中的异常错误

ProcessorLaunchException() - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.ProcessorLaunchException

ProcessorLaunchException(String) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.ProcessorLaunchException

ProcessorLaunchException(String, Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.ProcessorLaunchException

ProcessorLaunchException(Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.ProcessorLaunchException

ProcessorLaunchException(String, Throwable, boolean, boolean) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.ProcessorLaunchException

ProcessorRunningException - xin.bluesky.leiothrix.server.action.exception中的异常错误

ProcessorRunningException() - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.ProcessorRunningException

ProcessorRunningException(String) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.ProcessorRunningException

ProcessorRunningException(String, Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.ProcessorRunningException

ProcessorRunningException(Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.ProcessorRunningException

ProcessorRunningException(String, Throwable, boolean, boolean) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.ProcessorRunningException

ProcessorStartingHolder - xin.bluesky.leiothrix.server.lock中的类

put(K, V) - 类 中的方法xin.bluesky.leiothrix.server.cache.ExpiredMap

put(TaskRanges) - 类 中的静态方法xin.bluesky.leiothrix.server.cache.TaskRangesCache

put(String, TaskStaticInfo) - 类 中的静态方法xin.bluesky.leiothrix.server.cache.TaskStaticInfoCache

put(TaskTables) - 类 中的静态方法xin.bluesky.leiothrix.server.cache.TaskTablesCache

put(String, TableMeta) - 类 中的静态方法xin.bluesky.leiothrix.server.cache.TaskTablesMetaCache

putIfAbsent(K, V) - 类 中的方法xin.bluesky.leiothrix.server.cache.ExpiredMap

Q

QueryProgressServlet - xin.bluesky.leiothrix.server.interactive.client中的类

QueryProgressServlet() - 类 的构造器xin.bluesky.leiothrix.server.interactive.client.QueryProgressServlet

R

RANDOM_TABLE - 类 中的静态变量xin.bluesky.leiothrix.server.action.PartitionAllocatorFactory

RandomTablePartitionAllocator - xin.bluesky.leiothrix.server.action.allocate中的类

已过时。

RandomTablePartitionAllocator() - 类 的构造器xin.bluesky.leiothrix.server.action.allocate.RandomTablePartitionAllocator

已过时。

RANGE_SEPARATOR - 类 中的静态变量xin.bluesky.leiothrix.server.Constant

RANGE_SEQUENCE - 类 中的静态变量xin.bluesky.leiothrix.server.action.PartitionAllocatorFactory

RANGE_UPDATED_THRESHOLD - 类 中的静态变量xin.bluesky.leiothrix.server.background.TimeoutPartitionTaskChecker

RangeScanner - xin.bluesky.leiothrix.server.action.allocate中的类

RangeScanner(String, String) - 类 的构造器xin.bluesky.leiothrix.server.action.allocate.RangeScanner

RangeScanResult - xin.bluesky.leiothrix.server.action.allocate中的类

扫描某个表的range的结果.

RangeScanResult() - 类 的构造器xin.bluesky.leiothrix.server.action.allocate.RangeScanResult

RangeSplitter - xin.bluesky.leiothrix.server.tablemeta中的类

RangeSplitter(String, DatabaseInfo, TableMeta, CountDownLatch) - 类 的构造器xin.bluesky.leiothrix.server.tablemeta.RangeSplitter

RangeStatus - xin.bluesky.leiothrix.server.bean.status中的枚举

RangeStorage - xin.bluesky.leiothrix.server.storage中的类

RangeStorage() - 类 的构造器xin.bluesky.leiothrix.server.storage.RangeStorage

refreshAndGetAllWorkerInfo() - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerManager

refreshAndGetAllWorkerPhysicalInfo() - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerManager

refreshRangeLastUpdateTime(String, String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.RangeStorage

registerServer(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.ServerStorage

在zk上给server注册EPHEMERAL类型的节点.如果已经存在,则先删后建.

releaseLeaderSelector() - 类 中的方法xin.bluesky.leiothrix.server.Server

remove(K) - 类 中的方法xin.bluesky.leiothrix.server.cache.ExpiredMap

resourceIsNotEnough(String) - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerProcessorLauncher

respond(HttpServletResponse, int, String) - 类 中的静态方法xin.bluesky.leiothrix.server.interactive.client.WebUtils

respond(HttpServletResponse, int, Object) - 类 中的静态方法xin.bluesky.leiothrix.server.interactive.client.WebUtils

retrieveCpuInfo() - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

retrieveMemoryInfo() - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

ROOT_DIR - 类 中的静态变量xin.bluesky.leiothrix.server.Constant

ROOT_PATH - 类 中的静态变量xin.bluesky.leiothrix.server.storage.zk.ZookeeperClientFactory

run() - 类 中的方法xin.bluesky.leiothrix.server.background.ShutDownHook

run() - 类 中的方法xin.bluesky.leiothrix.server.background.TaskCompensatorJob

run() - 类 中的方法xin.bluesky.leiothrix.server.background.TaskDeleteJob

run() - 类 中的方法xin.bluesky.leiothrix.server.background.TaskStatusChecker

run() - 类 中的方法xin.bluesky.leiothrix.server.background.TimeoutPartitionTaskChecker

run() - 类 中的方法xin.bluesky.leiothrix.server.background.WorkerHealthChecker

run() - 类 中的方法xin.bluesky.leiothrix.server.interactive.worker.WorkerMessageListener

run() - 类 中的方法xin.bluesky.leiothrix.server.tablemeta.RangeSplitter

S

savePhysicalInfo(NodePhysicalInfo) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.WorkerStorage

scan() - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.RangeScanner

扫描某个表的range,以找到尚未被分配的range.如果没有找到,则返回null.在扫描过程中,如果所有range都已结束,则更新表状态为结束

SCAN_INTERVAL - 类 中的静态变量xin.bluesky.leiothrix.server.cache.ExpiredMap

scp2OtherServers(String, File) - 类 中的静态方法xin.bluesky.leiothrix.server.interactive.client.TaskFileService

SequencePartitionAllocator - xin.bluesky.leiothrix.server.action.allocate中的类

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

SequencePartitionAllocator() - 类 的构造器xin.bluesky.leiothrix.server.action.allocate.SequencePartitionAllocator

Server - xin.bluesky.leiothrix.server中的类

server.

Server() - 类 的构造器xin.bluesky.leiothrix.server.Server

SERVER - 类 中的静态变量xin.bluesky.leiothrix.server.storage.ServerStorage

ServerConfigure - xin.bluesky.leiothrix.server.conf中的类

ServerConfigure() - 类 的构造器xin.bluesky.leiothrix.server.conf.ServerConfigure

ServerStorage - xin.bluesky.leiothrix.server.storage中的类

ServerStorage() - 类 的构造器xin.bluesky.leiothrix.server.storage.ServerStorage

ServerUpdatedTrigger - xin.bluesky.leiothrix.server.action中的类

server列表发生变化时,通知所有worker更新.

ServerUpdatedTrigger() - 类 的构造器xin.bluesky.leiothrix.server.action.ServerUpdatedTrigger

setConfig(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

设置该Task对应的config信息

setCpuNumber(int) - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

setData(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

setErrorMsg(String) - 类 中的方法xin.bluesky.leiothrix.server.lock.ProcessorStartingHolder

setIp(String) - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

setIsTableFinished(boolean) - 类 中的方法xin.bluesky.leiothrix.server.action.allocate.RangeScanResult

setJarPath(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

设置运行该Task对应的jar路径

setMainClass(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

设置运行该Task的main函数

setMemoryFree(long) - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

setMemoryFreeBeforeAsWorker(long) - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

setMemoryTotal(long) - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

setNameRangeStartIndex(String, String, String, long) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.RangeStorage

setPhysicalInfo(NodePhysicalInfo) - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodeInfo

setPrimaryKey(String) - 类 中的方法xin.bluesky.leiothrix.server.tablemeta.TableMeta

setProcessors(List<TaskStatisticsCollector.ProcessorInfo>) - 类 中的方法xin.bluesky.leiothrix.server.action.TaskStatisticsCollector.WorkerInfo

setProperties(Properties) - 类 中的静态方法xin.bluesky.leiothrix.server.conf.ServerConfigure

setProperty(String, String) - 类 中的静态方法xin.bluesky.leiothrix.server.conf.ServerConfigure

setRangeRecordNum(String, String, String, int) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.RangeStorage

setRangeStatus(String, String, String, RangeStatus) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.RangeStorage

setResourceEnough(String, boolean) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

设置该任务的当前运行资源是否足够

setRunningSuccess(boolean) - 类 中的方法xin.bluesky.leiothrix.server.lock.ProcessorStartingHolder

setStatus(String, String, TableStatus) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TableStorage

setStatus(String, TaskStatus) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

设置任务的状态

setTableName(String) - 类 中的方法xin.bluesky.leiothrix.server.tablemeta.TableMeta

setUser(String) - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

setWorkerManager(WorkerManager) - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerProcessorLauncher

setWorkerNumbers(int) - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodeInfo

setWorkerProcessorInvoker(WorkerProcessorInvoker) - 类 中的方法xin.bluesky.leiothrix.server.action.WorkerProcessorLauncher

setWorkersNumber(String, int) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.WorkerStorage

ShutDownHook - xin.bluesky.leiothrix.server.background中的类

ShutDownHook() - 类 的构造器xin.bluesky.leiothrix.server.background.ShutDownHook

size() - 类 中的方法xin.bluesky.leiothrix.server.cache.PartitionTaskContainer

start() - 类 中的静态方法xin.bluesky.leiothrix.server.background.TaskCompensatorJob

start() - 类 中的静态方法xin.bluesky.leiothrix.server.background.TaskDeleteJob

start() - 类 中的静态方法xin.bluesky.leiothrix.server.background.TaskStatusChecker

start() - 类 中的静态方法xin.bluesky.leiothrix.server.background.TimeoutPartitionTaskChecker

start() - 类 中的静态方法xin.bluesky.leiothrix.server.background.WorkerHealthChecker

start(int) - 类 中的静态方法xin.bluesky.leiothrix.server.interactive.client.ClientRequestListener

start(int) - 类 中的静态方法xin.bluesky.leiothrix.server.interactive.worker.WorkerMessageListener

start() - 类 中的方法xin.bluesky.leiothrix.server.Server

server是无中心的集群模式

start() - 类 中的静态方法xin.bluesky.leiothrix.server.storage.zk.EmbeddedZookeeperServer

submit(RangeSplitter) - 类 中的方法xin.bluesky.leiothrix.server.tablemeta.DatabaseSchemaLoader

SubmitTaskServlet - xin.bluesky.leiothrix.server.interactive.client中的类

SubmitTaskServlet() - 类 的构造器xin.bluesky.leiothrix.server.interactive.client.SubmitTaskServlet

SYS_PROP_CONFIG_FILE - 类 中的静态变量xin.bluesky.leiothrix.server.Constant

SYS_PROP_WORKER_COMPENSATE_ENABLE - 类 中的静态变量xin.bluesky.leiothrix.server.Constant

SYS_PROP_WORKER_COMPENSATE_ENABLE_VALUE_FALSE - 类 中的静态变量xin.bluesky.leiothrix.server.Constant

T

TableMeta - xin.bluesky.leiothrix.server.tablemeta中的类

TableMeta() - 类 的构造器xin.bluesky.leiothrix.server.tablemeta.TableMeta

TableMeta(String, String) - 类 的构造器xin.bluesky.leiothrix.server.tablemeta.TableMeta

TableOneByOnePartitionAllocator - xin.bluesky.leiothrix.server.action.allocate中的类

按照表为维度,一张表一张表地处理.

TableOneByOnePartitionAllocator() - 类 的构造器xin.bluesky.leiothrix.server.action.allocate.TableOneByOnePartitionAllocator

TableStatus - xin.bluesky.leiothrix.server.bean.status中的枚举

TableStorage - xin.bluesky.leiothrix.server.storage中的类

TableStorage() - 类 的构造器xin.bluesky.leiothrix.server.storage.TableStorage

TaskCompensatorJob - xin.bluesky.leiothrix.server.background中的类

当worker进程执行完毕后(或worker进程crash),资源会被释放出来,此时应该针对正在运行中的任务来进行补偿,给它们分配更多的worker进程.

TaskDeleteJob - xin.bluesky.leiothrix.server.background中的类

TaskDeleteJob() - 类 的构造器xin.bluesky.leiothrix.server.background.TaskDeleteJob

taskExist(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

判断该task是否存在

TaskFileService - xin.bluesky.leiothrix.server.interactive.client中的类

TaskFileService() - 类 的构造器xin.bluesky.leiothrix.server.interactive.client.TaskFileService

taskNotExist(String) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.TaskStorage

判断该task是否不存在

TaskRanges - xin.bluesky.leiothrix.server.bean.task中的类

TaskRanges(String, String, List<String>) - 类 的构造器xin.bluesky.leiothrix.server.bean.task.TaskRanges

TaskRangesCache - xin.bluesky.leiothrix.server.cache中的类

TASKS - 类 中的静态变量xin.bluesky.leiothrix.server.storage.TaskStorage

TaskStaticInfoCache - xin.bluesky.leiothrix.server.cache中的类

TaskStatisticsCollector - xin.bluesky.leiothrix.server.action中的类

TaskStatisticsCollector(String) - 类 的构造器xin.bluesky.leiothrix.server.action.TaskStatisticsCollector

TaskStatisticsCollector.ProcessorInfo - xin.bluesky.leiothrix.server.action中的类

TaskStatisticsCollector.WorkerInfo - xin.bluesky.leiothrix.server.action中的类

TaskStatusChecker - xin.bluesky.leiothrix.server.background中的类

TaskStatusChecker() - 类 的构造器xin.bluesky.leiothrix.server.background.TaskStatusChecker

TaskStorage - xin.bluesky.leiothrix.server.storage中的类

TaskStorage() - 类 的构造器xin.bluesky.leiothrix.server.storage.TaskStorage

TaskTables - xin.bluesky.leiothrix.server.bean.task中的类

TaskTables(String, List<String>) - 类 的构造器xin.bluesky.leiothrix.server.bean.task.TaskTables

TaskTablesCache - xin.bluesky.leiothrix.server.cache中的类

TaskTablesMetaCache - xin.bluesky.leiothrix.server.cache中的类

Test - xin.bluesky.leiothrix.server.action.exception中的类

Test() - 类 的构造器xin.bluesky.leiothrix.server.action.exception.Test

TimeoutPartitionTaskChecker - xin.bluesky.leiothrix.server.background中的类

TimeoutPartitionTaskChecker() - 类 的构造器xin.bluesky.leiothrix.server.background.TimeoutPartitionTaskChecker

toString() - 类 中的方法xin.bluesky.leiothrix.server.bean.node.NodePhysicalInfo

trigger(List<String>) - 类 中的方法xin.bluesky.leiothrix.server.action.ServerUpdatedTrigger

U

unHold() - 类 中的方法xin.bluesky.leiothrix.server.lock.ProcessorStartingHolder

updatePageExecutionStatistics(String, String, String, ExecutionStatistics) - 类 中的静态方法xin.bluesky.leiothrix.server.storage.RangeStorage

UrlMapping - xin.bluesky.leiothrix.server.interactive.client中的类

UrlMapping() - 类 的构造器xin.bluesky.leiothrix.server.interactive.client.UrlMapping

V

valueOf(String) - 枚举 中的静态方法xin.bluesky.leiothrix.server.bean.status.RangeStatus

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法xin.bluesky.leiothrix.server.bean.status.TableStatus

返回带有指定名称的该类型的枚举常量。

values() - 枚举 中的静态方法xin.bluesky.leiothrix.server.bean.status.RangeStatus

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法xin.bluesky.leiothrix.server.bean.status.TableStatus

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

W

WaitAndTryLaterException - xin.bluesky.leiothrix.server.action.exception中的异常错误

WaitAndTryLaterException() - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.WaitAndTryLaterException

WaitAndTryLaterException(String) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.WaitAndTryLaterException

WaitAndTryLaterException(String, Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.WaitAndTryLaterException

WaitAndTryLaterException(Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.WaitAndTryLaterException

WaitAndTryLaterException(String, Throwable, boolean, boolean) - 异常错误 的构造器xin.bluesky.leiothrix.server.action.exception.WaitAndTryLaterException

WebUtils - xin.bluesky.leiothrix.server.interactive.client中的类

WebUtils() - 类 的构造器xin.bluesky.leiothrix.server.interactive.client.WebUtils

WORKER_MEMORY_REDUNDANCY - 类 中的静态变量xin.bluesky.leiothrix.server.action.WorkerProcessorInvoker

WORKER_PROCESSOR_MEMORY - 类 中的静态变量xin.bluesky.leiothrix.server.action.WorkerProcessorInvoker

WorkerChannelInboundHandler - xin.bluesky.leiothrix.server.interactive.worker中的类

WorkerChannelInboundHandler() - 类 的构造器xin.bluesky.leiothrix.server.interactive.worker.WorkerChannelInboundHandler

WorkerHealthChecker - xin.bluesky.leiothrix.server.background中的类

WorkerInfo(String) - 类 的构造器xin.bluesky.leiothrix.server.action.TaskStatisticsCollector.WorkerInfo

WorkerInfoInitializer - xin.bluesky.leiothrix.server.action中的类

WorkerInfoInitializer() - 类 的构造器xin.bluesky.leiothrix.server.action.WorkerInfoInitializer

WorkerManager - xin.bluesky.leiothrix.server.action中的类

WorkerManager() - 类 的构造器xin.bluesky.leiothrix.server.action.WorkerManager

WorkerMessageHandler - xin.bluesky.leiothrix.server.interactive.worker中的接口

WorkerMessageListener - xin.bluesky.leiothrix.server.interactive.worker中的类

WorkerProcessorInvoker - xin.bluesky.leiothrix.server.action中的类

WorkerProcessorInvoker() - 类 的构造器xin.bluesky.leiothrix.server.action.WorkerProcessorInvoker

WorkerProcessorLauncher - xin.bluesky.leiothrix.server.action中的类

WorkerProcessorLauncher(String) - 类 的构造器xin.bluesky.leiothrix.server.action.WorkerProcessorLauncher

WorkerProcessorNumberCorrector - xin.bluesky.leiothrix.server.background中的类

WorkerProcessorNumberCorrector() - 类 的构造器xin.bluesky.leiothrix.server.background.WorkerProcessorNumberCorrector

WorkerProgressReportHandler - xin.bluesky.leiothrix.server.interactive.worker.msghandler中的类

WorkerProgressReportHandler() - 类 的构造器xin.bluesky.leiothrix.server.interactive.worker.msghandler.WorkerProgressReportHandler

WORKERS - 类 中的静态变量xin.bluesky.leiothrix.server.storage.WorkerStorage

WorkerStorage - xin.bluesky.leiothrix.server.storage中的类

WorkerStorage() - 类 的构造器xin.bluesky.leiothrix.server.storage.WorkerStorage

X

xin.bluesky.leiothrix.server - 程序包 xin.bluesky.leiothrix.server

xin.bluesky.leiothrix.server.action - 程序包 xin.bluesky.leiothrix.server.action

xin.bluesky.leiothrix.server.action.allocate - 程序包 xin.bluesky.leiothrix.server.action.allocate

xin.bluesky.leiothrix.server.action.exception - 程序包 xin.bluesky.leiothrix.server.action.exception

xin.bluesky.leiothrix.server.background - 程序包 xin.bluesky.leiothrix.server.background

xin.bluesky.leiothrix.server.background.compensate - 程序包 xin.bluesky.leiothrix.server.background.compensate

xin.bluesky.leiothrix.server.bean.node - 程序包 xin.bluesky.leiothrix.server.bean.node

xin.bluesky.leiothrix.server.bean.status - 程序包 xin.bluesky.leiothrix.server.bean.status

xin.bluesky.leiothrix.server.bean.task - 程序包 xin.bluesky.leiothrix.server.bean.task

xin.bluesky.leiothrix.server.cache - 程序包 xin.bluesky.leiothrix.server.cache

xin.bluesky.leiothrix.server.conf - 程序包 xin.bluesky.leiothrix.server.conf

xin.bluesky.leiothrix.server.interactive.client - 程序包 xin.bluesky.leiothrix.server.interactive.client

xin.bluesky.leiothrix.server.interactive.worker - 程序包 xin.bluesky.leiothrix.server.interactive.worker

xin.bluesky.leiothrix.server.interactive.worker.msghandler - 程序包 xin.bluesky.leiothrix.server.interactive.worker.msghandler

xin.bluesky.leiothrix.server.lock - 程序包 xin.bluesky.leiothrix.server.lock

xin.bluesky.leiothrix.server.storage - 程序包 xin.bluesky.leiothrix.server.storage

xin.bluesky.leiothrix.server.storage.zk - 程序包 xin.bluesky.leiothrix.server.storage.zk

xin.bluesky.leiothrix.server.tablemeta - 程序包 xin.bluesky.leiothrix.server.tablemeta

xin.bluesky.leiothrix.server.util - 程序包 xin.bluesky.leiothrix.server.util

Z

ZookeeperClientFactory - xin.bluesky.leiothrix.server.storage.zk中的类

ZookeeperClientFactory() - 类 的构造器xin.bluesky.leiothrix.server.storage.zk.ZookeeperClientFactory

ZookeeperException - xin.bluesky.leiothrix.server.storage.zk中的异常错误

ZookeeperException() - 异常错误 的构造器xin.bluesky.leiothrix.server.storage.zk.ZookeeperException

ZookeeperException(String) - 异常错误 的构造器xin.bluesky.leiothrix.server.storage.zk.ZookeeperException

ZookeeperException(String, Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.storage.zk.ZookeeperException

ZookeeperException(Throwable) - 异常错误 的构造器xin.bluesky.leiothrix.server.storage.zk.ZookeeperException

ZookeeperException(String, Throwable, boolean, boolean) - 异常错误 的构造器xin.bluesky.leiothrix.server.storage.zk.ZookeeperException

ZookeeperUtils - xin.bluesky.leiothrix.server.storage.zk中的类

ZookeeperUtils() - 类 的构造器xin.bluesky.leiothrix.server.storage.zk.ZookeeperUtils

A B C D E F G H I K L M N O P Q R S T U V W X Z