|
|||||||||
前のクラス 次のクラス | フレームあり フレームなし | ||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
java.lang.Objectokuyama.base.job.AbstractHelper
okuyama.imdst.helper.AbstractMasterManagerHelper
public abstract class AbstractMasterManagerHelper
MasterNodeのHelperが継承するクラス.
共通的な処理とネットワークIOのキューイング処理の仲介処理を行う
フィールドの概要 | |
---|---|
protected static java.util.concurrent.ConcurrentHashMap |
keyNodeConnectPool
|
protected static boolean |
recoverProcessed
|
クラス okuyama.base.job.AbstractHelper から継承されたフィールド |
---|
END, ERR, ERROR, helperConfigMap, helperParamShareMap, RUN, status, SUCCESS, WAIT |
コンストラクタの概要 | |
---|---|
AbstractMasterManagerHelper()
|
メソッドの概要 | |
---|---|
protected void |
addKeyNodeCacheConnectionPool(KeyNodeConnector keyNodeConnector)
使用済みの接続をPoolに戻す. |
protected boolean |
checkConnectionEffective(java.lang.String nodeInfo,
java.lang.Long time)
ノードとの接続プールが有効か確認 |
protected java.lang.String[] |
execNodePing(java.lang.String nodeName,
int port,
ILogger logger)
|
protected java.lang.String[] |
execNodePing(java.lang.String nodeName,
int port,
ILogger logger,
int deadCount)
ノードに対して生存確認用のPingを行う. |
protected void |
execNodeUseEnd(java.lang.String nodeInfo)
ノードに対するアクセス終了をマーク |
protected void |
executeKeyNodeOptimization(boolean flg)
|
protected KeyNodeConnector |
getActiveConnection(java.lang.String connectionName)
ConnectionPoolが作りだしたコネクションを使用する. |
protected java.util.HashMap |
getConsistentHashMoveData()
|
protected int |
getNodeUseStatus(java.lang.String nodeInfo)
指定ノードの使用状況を取得 返却値は現在の使用数をあらわす |
protected int |
getNowConnectionPoolCount()
|
protected boolean |
getNowNodeDataOptimization()
|
protected boolean |
getRecoverProcessed()
|
protected boolean |
isExecuteKeyNodeOptimization()
|
protected boolean |
isNodeArrival(java.lang.String nodeInfo)
ノードの生存を確認 |
protected void |
removeConsistentHashMoveData()
|
protected void |
removeNodeWaitStatus(java.lang.String nodeInfo)
ノードの一時停止を解除. |
protected void |
setActiveConnection(java.lang.String connectionName,
KeyNodeConnector keyNodeConnector)
データノードとのコネクションをセットする. |
protected void |
setArriveNode(java.lang.String nodeInfo)
ノードの復帰を登録 |
protected void |
setConsistentHashMoveData(java.util.HashMap map)
|
protected void |
setDeadNode(java.lang.String nodeInfo,
int setPoint,
java.lang.Throwable te)
ノードの停止を登録 |
protected void |
setDeadNode(java.lang.String nodeInfo,
int setPoint,
java.lang.Throwable te,
boolean reportMasterNode)
ノードの停止を登録 |
protected void |
setNodeWaitStatus(java.lang.String nodeInfo)
ノードの一時停止を要求. |
protected void |
setNowNodeDataOptimization(boolean flg)
|
protected void |
setRecoverNode(boolean recoverMode,
java.lang.String nodeInfo)
ノードのリカバリーの開始、終了をスレーブのMasterNodeへ送信 |
protected void |
setRecoverProcessed(boolean flg)
|
protected void |
setRecoverSuccess(java.lang.String nodeInfo)
ノードのリカバリーの終了通知とDataNode起動をスレーブのMasterNodeへ送信. |
クラス java.lang.Object から継承されたメソッド |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
フィールドの詳細 |
---|
protected static java.util.concurrent.ConcurrentHashMap keyNodeConnectPool
protected static boolean recoverProcessed
コンストラクタの詳細 |
---|
public AbstractMasterManagerHelper()
メソッドの詳細 |
---|
protected void setRecoverProcessed(boolean flg)
protected boolean getRecoverProcessed()
protected boolean isNodeArrival(java.lang.String nodeInfo)
nodeInfo
- 確認対象のノード情報protected void setDeadNode(java.lang.String nodeInfo, int setPoint, java.lang.Throwable te)
nodeInfo
- 対象のノード情報setPoint
- te
- protected void setDeadNode(java.lang.String nodeInfo, int setPoint, java.lang.Throwable te, boolean reportMasterNode)
nodeInfo
- 対象のノード情報setPoint
- te
- reportMasterNode
- protected void setArriveNode(java.lang.String nodeInfo)
nodeInfo
- 対象のノード情報protected void setRecoverNode(boolean recoverMode, java.lang.String nodeInfo)
recoverMode
- protected void setRecoverSuccess(java.lang.String nodeInfo)
recoverMode
- protected boolean checkConnectionEffective(java.lang.String nodeInfo, java.lang.Long time)
nodeInfo
- 対象のノード情報
protected void setNodeWaitStatus(java.lang.String nodeInfo)
nodeInfo
- 停止対象ノードprotected void removeNodeWaitStatus(java.lang.String nodeInfo)
nodeInfo
- 解除対象ノードprotected void execNodeUseEnd(java.lang.String nodeInfo)
protected int getNodeUseStatus(java.lang.String nodeInfo)
protected java.lang.String[] execNodePing(java.lang.String nodeName, int port, ILogger logger)
protected java.lang.String[] execNodePing(java.lang.String nodeName, int port, ILogger logger, int deadCount)
nodeName
- ノード名port
- ポート番号logger
- ロガーdeadCount
- Deadとみなす回数
protected void setActiveConnection(java.lang.String connectionName, KeyNodeConnector keyNodeConnector)
protected void addKeyNodeCacheConnectionPool(KeyNodeConnector keyNodeConnector)
protected void executeKeyNodeOptimization(boolean flg)
protected boolean isExecuteKeyNodeOptimization()
protected java.util.HashMap getConsistentHashMoveData()
protected void setConsistentHashMoveData(java.util.HashMap map)
protected void removeConsistentHashMoveData()
protected void setNowNodeDataOptimization(boolean flg)
protected boolean getNowNodeDataOptimization()
protected KeyNodeConnector getActiveConnection(java.lang.String connectionName)
protected int getNowConnectionPoolCount()
|
|||||||||
前のクラス 次のクラス | フレームあり フレームなし | ||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |