A C D E G H I L M P R S T V W X

A

AcquireTaskResponseHandler - xin.bluesky.leiothrix.worker.msghandler中的类

AcquireTaskResponseHandler() - 类 的构造器xin.bluesky.leiothrix.worker.msghandler.AcquireTaskResponseHandler

announceExit() - 类 中的静态方法xin.bluesky.leiothrix.worker.executor.ProcessorAnnouncer

announceExit(String) - 类 中的静态方法xin.bluesky.leiothrix.worker.executor.ProcessorAnnouncer

announceStartupFail(String) - 类 中的静态方法xin.bluesky.leiothrix.worker.executor.ProcessorAnnouncer

announceStartupSuccess() - 类 中的静态方法xin.bluesky.leiothrix.worker.executor.ProcessorAnnouncer

awaitTermination() - 类 中的方法xin.bluesky.leiothrix.worker.executor.ExecutorsPoolTry

awaitTermination() - 类 中的方法xin.bluesky.leiothrix.worker.WorkerProcessor

C

calExecutorsNumbers() - 类 中的方法xin.bluesky.leiothrix.worker.executor.ExecutorsPool

calExecutorsNumbers() - 类 中的方法xin.bluesky.leiothrix.worker.executor.ExecutorsPoolTry

channelCreated(Channel) - 类 中的方法xin.bluesky.leiothrix.worker.client.ServerChannel.ServerChannelPoolHandler

ChannelPool - xin.bluesky.leiothrix.worker.client中的类

ChannelPool() - 类 的构造器xin.bluesky.leiothrix.worker.client.ChannelPool

ChannelPool(String, SimpleChannelPool) - 类 的构造器xin.bluesky.leiothrix.worker.client.ChannelPool

channelRead(ChannelHandlerContext, Object) - 类 中的方法xin.bluesky.leiothrix.worker.msghandler.ServerChannelInboundHandler

channelRegistered(ChannelHandlerContext) - 类 中的方法xin.bluesky.leiothrix.worker.msghandler.ServerChannelInboundHandler

ChannelStatus - xin.bluesky.leiothrix.worker.client中的枚举

connect(String[], int) - 类 中的静态方法xin.bluesky.leiothrix.worker.client.ServerChannel

D

DatabasePageDataHandler - xin.bluesky.leiothrix.worker.api中的接口

提供给application的数据处理API.

E

exceptionCaught(String, List<JSONObject>, Exception) - 接口 中的方法xin.bluesky.leiothrix.worker.api.DatabasePageDataHandler

exceptionCaught(ChannelHandlerContext, Throwable) - 类 中的方法xin.bluesky.leiothrix.worker.msghandler.ServerChannelInboundHandler

ExecutorsPool - xin.bluesky.leiothrix.worker.executor中的类

ExecutorsPool() - 类 的构造器xin.bluesky.leiothrix.worker.executor.ExecutorsPool

ExecutorsPoolTry - xin.bluesky.leiothrix.worker.executor中的类

ExecutorsPoolTry() - 类 的构造器xin.bluesky.leiothrix.worker.executor.ExecutorsPoolTry

G

getChannelPool() - 类 中的方法xin.bluesky.leiothrix.worker.client.ChannelPool

getChannelStatus() - 类 中的方法xin.bluesky.leiothrix.worker.client.ChannelPool

getConfiguration() - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.Settings

getCpuWarnCount() - 类 中的方法xin.bluesky.leiothrix.worker.background.ResourceMonitor

getDatabasePageDataHandler() - 类 中的方法xin.bluesky.leiothrix.worker.conf.WorkerConfiguration

getGcWarnCount() - 类 中的方法xin.bluesky.leiothrix.worker.background.ResourceMonitor

getIp() - 类 中的方法xin.bluesky.leiothrix.worker.client.ChannelPool

getPoolSize() - 类 中的方法xin.bluesky.leiothrix.worker.executor.ExecutorsPool

getPoolSize() - 类 中的方法xin.bluesky.leiothrix.worker.executor.ExecutorsPoolTry

getProcessor() - 类 中的静态方法xin.bluesky.leiothrix.worker.WorkerProcessor

getRangePageSize() - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.Settings

getRemainingExecutorSize() - 类 中的方法xin.bluesky.leiothrix.worker.executor.ExecutorsPool

getServerPort() - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.Settings

getServersIp() - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.Settings

getStaticProcessInfo() - 类 中的静态方法xin.bluesky.leiothrix.worker.executor.ProcessorAnnouncer

getStatus() - 类 中的方法xin.bluesky.leiothrix.worker.WorkerProcessor

getTaskId() - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.Settings

getThreadNumFactor() - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.Settings

getWorkerIp() - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.Settings

H

handle(String, String, List<JSONObject>) - 接口 中的方法xin.bluesky.leiothrix.worker.api.DatabasePageDataHandler

handle(ChannelHandlerContext, String) - 类 中的方法xin.bluesky.leiothrix.worker.msghandler.AcquireTaskResponseHandler

handle(ChannelHandlerContext, String) - 类 中的方法xin.bluesky.leiothrix.worker.msghandler.ServerChangedHandler

handle(ChannelHandlerContext, String) - 类 中的方法xin.bluesky.leiothrix.worker.msghandler.TaskCancelHandler

handle(ChannelHandlerContext, String) - 接口 中的方法xin.bluesky.leiothrix.worker.ServerMessageHandler

I

init(WorkerConfiguration) - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.SettingInit

isFree() - 类 中的方法xin.bluesky.leiothrix.worker.executor.TaskExecutor

isMonitor() - 类 中的方法xin.bluesky.leiothrix.worker.background.ResourceMonitor

isReschedule() - 类 中的方法xin.bluesky.leiothrix.worker.executor.TaskExecutor

isRunning() - 类 中的方法xin.bluesky.leiothrix.worker.WorkerProcessor

L

logger - 类 中的静态变量xin.bluesky.leiothrix.worker.executor.ProcessorAnnouncer

M

main(String[]) - 类 中的静态方法xin.bluesky.leiothrix.worker.executor.ExecutorsPoolTry

P

ProcessorAnnouncer - xin.bluesky.leiothrix.worker.executor中的类

进程广播者.当进程启动的时候,需要通知server进行增加计数;当进程关闭的时候,同样也要通知server进行扣减计数.

ProcessorAnnouncer() - 类 的构造器xin.bluesky.leiothrix.worker.executor.ProcessorAnnouncer

putPartitionTaskWrapper(PartitionTaskWrapper) - 类 中的静态方法xin.bluesky.leiothrix.worker.executor.TaskContainer

R

reducePressure() - 类 中的方法xin.bluesky.leiothrix.worker.WorkerProcessor

reportProgress(PartitionTaskProgress) - 类 中的方法xin.bluesky.leiothrix.worker.report.WorkerProgressReporter

reschedule() - 类 中的方法xin.bluesky.leiothrix.worker.executor.TaskExecutor

rescheduleExecutor(int) - 类 中的方法xin.bluesky.leiothrix.worker.executor.ExecutorsPool

ResourceMonitor - xin.bluesky.leiothrix.worker.background中的类

ResourceMonitor() - 类 的构造器xin.bluesky.leiothrix.worker.background.ResourceMonitor

run() - 类 中的方法xin.bluesky.leiothrix.worker.background.ResourceMonitor

run() - 类 中的方法xin.bluesky.leiothrix.worker.background.ShutdownHook

run() - 类 中的方法xin.bluesky.leiothrix.worker.executor.TaskExecutor

run() - 类 中的方法xin.bluesky.leiothrix.worker.report.WorkerProgressReporter

S

send(Object) - 类 中的静态方法xin.bluesky.leiothrix.worker.client.ServerChannel

serverChanged(List<String>) - 类 中的静态方法xin.bluesky.leiothrix.worker.client.ServerChannel

server发生变化时,与内存中的server列表同步.

ServerChangedHandler - xin.bluesky.leiothrix.worker.msghandler中的类

ServerChangedHandler() - 类 的构造器xin.bluesky.leiothrix.worker.msghandler.ServerChangedHandler

ServerChannel - xin.bluesky.leiothrix.worker.client中的类

ServerChannel.ServerChannelPoolHandler - xin.bluesky.leiothrix.worker.client中的类

ServerChannelInboundHandler - xin.bluesky.leiothrix.worker.msghandler中的类

ServerChannelInboundHandler() - 类 的构造器xin.bluesky.leiothrix.worker.msghandler.ServerChannelInboundHandler

ServerChannelPoolHandler() - 类 的构造器xin.bluesky.leiothrix.worker.client.ServerChannel.ServerChannelPoolHandler

ServerMessageHandler - xin.bluesky.leiothrix.worker中的接口

setChannelPool(SimpleChannelPool) - 类 中的方法xin.bluesky.leiothrix.worker.client.ChannelPool

setChannelStatus(ChannelStatus) - 类 中的方法xin.bluesky.leiothrix.worker.client.ChannelPool

setConfiguration(WorkerConfiguration) - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.Settings

setDatabasePageDataHandler(DatabasePageDataHandler) - 类 中的方法xin.bluesky.leiothrix.worker.conf.WorkerConfiguration

setIp(String) - 类 中的方法xin.bluesky.leiothrix.worker.client.ChannelPool

setRangePageSize(int) - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.Settings

setServerPort(Integer) - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.Settings

setServersIp(String[]) - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.Settings

setTaskId(String) - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.Settings

setThreadNumFactor(int) - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.Settings

SettingInit - xin.bluesky.leiothrix.worker.conf中的类

SettingInit() - 类 的构造器xin.bluesky.leiothrix.worker.conf.SettingInit

Settings - xin.bluesky.leiothrix.worker.conf中的类

Settings() - 类 的构造器xin.bluesky.leiothrix.worker.conf.Settings

setWaitTimeAfterReducePressure(int) - 类 中的方法xin.bluesky.leiothrix.worker.background.ResourceMonitor

setWorkerIp(String) - 类 中的静态方法xin.bluesky.leiothrix.worker.conf.Settings

shutdown() - 类 中的静态方法xin.bluesky.leiothrix.worker.client.ServerChannel

shutdown() - 类 中的方法xin.bluesky.leiothrix.worker.executor.ExecutorsPool

shutdown() - 类 中的方法xin.bluesky.leiothrix.worker.executor.ExecutorsPoolTry

shutdown() - 类 中的方法xin.bluesky.leiothrix.worker.report.WorkerProgressReporter

shutdown() - 类 中的方法xin.bluesky.leiothrix.worker.WorkerProcessor

ShutdownHook - xin.bluesky.leiothrix.worker.background中的类

在worker进程关闭的时候,很可能由于各种原因导致不能被正常KILL(比如内存溢出),此时ShutdownHook做不了太多的事情, 所以没有调用WorkerProcessor.shutdown()方法,只要尽量保证把这个关闭信息告诉server,就够了, 其余在WorkerProcessor.shutdown()中做的进程内的清理动作,即使没能做成功,影响的也是进程内的事情,手工KILL -9就好了

ShutdownHook() - 类 的构造器xin.bluesky.leiothrix.worker.background.ShutdownHook

start() - 类 中的方法xin.bluesky.leiothrix.worker.background.ResourceMonitor

start() - 类 中的方法xin.bluesky.leiothrix.worker.report.WorkerProgressReporter

start() - 类 中的方法xin.bluesky.leiothrix.worker.WorkerProcessor

Status - xin.bluesky.leiothrix.worker.executor中的枚举

submit(TaskExecutor) - 类 中的方法xin.bluesky.leiothrix.worker.executor.ExecutorsPool

submit(ExecutorsPoolTry.Task) - 类 中的方法xin.bluesky.leiothrix.worker.executor.ExecutorsPoolTry

T

takePartitionTaskWrapper(long, TimeUnit) - 类 中的静态方法xin.bluesky.leiothrix.worker.executor.TaskContainer

TaskCancelHandler - xin.bluesky.leiothrix.worker.msghandler中的类

TaskCancelHandler() - 类 的构造器xin.bluesky.leiothrix.worker.msghandler.TaskCancelHandler

TaskContainer - xin.bluesky.leiothrix.worker.executor中的类

TaskExecutor - xin.bluesky.leiothrix.worker.executor中的类

TaskExecutor(WorkerProgressReporter, CountDownLatch) - 类 的构造器xin.bluesky.leiothrix.worker.executor.TaskExecutor

toString() - 类 中的方法xin.bluesky.leiothrix.worker.client.ChannelPool

V

valueOf(String) - 枚举 中的静态方法xin.bluesky.leiothrix.worker.client.ChannelStatus

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

valueOf(String) - 枚举 中的静态方法xin.bluesky.leiothrix.worker.executor.Status

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

valueOf(String) - 枚举 中的静态方法xin.bluesky.leiothrix.worker.WorkerProcessor.Status

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

values() - 枚举 中的静态方法xin.bluesky.leiothrix.worker.client.ChannelStatus

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

values() - 枚举 中的静态方法xin.bluesky.leiothrix.worker.executor.Status

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

values() - 枚举 中的静态方法xin.bluesky.leiothrix.worker.WorkerProcessor.Status

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

W

WorkerConfiguration - xin.bluesky.leiothrix.worker.conf中的类

WorkerConfiguration() - 类 的构造器xin.bluesky.leiothrix.worker.conf.WorkerConfiguration

WorkerProcessor - xin.bluesky.leiothrix.worker中的类

WorkerProcessor(WorkerConfiguration) - 类 的构造器xin.bluesky.leiothrix.worker.WorkerProcessor

WorkerProcessor.Status - xin.bluesky.leiothrix.worker中的枚举

WorkerProgressReporter - xin.bluesky.leiothrix.worker.report中的类

WorkerProgressReporter() - 类 的构造器xin.bluesky.leiothrix.worker.report.WorkerProgressReporter

X

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

xin.bluesky.leiothrix.worker.api - 程序包 xin.bluesky.leiothrix.worker.api

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

xin.bluesky.leiothrix.worker.client - 程序包 xin.bluesky.leiothrix.worker.client

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

xin.bluesky.leiothrix.worker.executor - 程序包 xin.bluesky.leiothrix.worker.executor

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

xin.bluesky.leiothrix.worker.report - 程序包 xin.bluesky.leiothrix.worker.report

A C D E G H I L M P R S T V W X