okuyama.imdst.helper
クラス KeyNodeWatchHelper

java.lang.Object
  上位を拡張 okuyama.base.job.AbstractHelper
      上位を拡張 okuyama.imdst.helper.AbstractMasterManagerHelper
          上位を拡張 okuyama.imdst.helper.KeyNodeWatchHelper
すべての実装されたインタフェース:
java.lang.Runnable

public class KeyNodeWatchHelper
extends AbstractMasterManagerHelper

KeyNodeの監視を行うHelperクラス

作成者:
T.Okuyama

フィールドの概要
 
クラス okuyama.imdst.helper.AbstractMasterManagerHelper から継承されたフィールド
keyNodeConnectPool, recoverProcessed
 
クラス okuyama.base.job.AbstractHelper から継承されたフィールド
END, ERR, ERROR, helperConfigMap, helperParamShareMap, RUN, status, SUCCESS, WAIT
 
コンストラクタの概要
KeyNodeWatchHelper()
           
 
メソッドの概要
 void endHelper()
          Helper後処理.
 java.lang.String executeHelper(java.lang.String optionParam)
          Jobメイン処理定義.
 void initHelper(java.lang.String initValue)
          初期化メソッド定義.
protected  boolean nodeDataRecover(java.lang.String nodeInfo, java.lang.String masterNodeInfo, boolean noDataCheck, ILogger logger)
          ダウン状態から復帰したノードに対して、ペアーのノードのデータをコピーする.
protected  boolean nodeDataRecover(java.lang.String nodeInfo, java.lang.String masterNodeInfo, ILogger logger)
          ダウン状態から復帰したノードに対して、ペアーのノードのデータをコピーする.
 
クラス okuyama.imdst.helper.AbstractMasterManagerHelper から継承されたメソッド
addKeyNodeCacheConnectionPool, checkConnectionEffective, execForceShutdownNode, execNodePing, execNodePing, execNodeUseEnd, executeKeyNodeOptimization, finishDynamicDataRemoveProcess, getActiveConnection, getConsistentHashMoveData, getNodeArrivalStatus, getNodeUseStatus, getNowConnectionPoolCount, getNowNodeDataOptimization, getRecoverProcessed, isExecuteKeyNodeOptimization, isNodeArrival, removeConsistentHashMoveData, removeNodeWaitStatus, reportDeadNode, sendExecuteMethodReportQueue, sendRecoverPassStatus, setActiveConnection, setArriveNode, setConsistentHashMoveData, setDeadNode, setDeadNode, setNodeWaitStatus, setNowNodeDataOptimization, setRecoverNode, setRecoverProcessed, setRecoverSuccess, stopRecoverDataOutputOperation
 
クラス okuyama.base.job.AbstractHelper から継承されたメソッド
addParameterQueue, addSmallSizeParameterQueue, addSpecificationParameterQueue, addSpecificationParameterQueue, getConfig, getHelperShareParam, getName, getParameterQueueSize, getParameters, getPropertiesValue, getReboot, getReturnParameter, getStatus, getThreadEnd, getUseCount, initialize, isJobFileChange, pollParameterQueue, pollSpecificationParameterQueue, reloadJobFileParameter, removeHelperShareParam, run, setConfig, setHelperShareParam, setName, setParameters, setReboot, setReturnParameter, sizeHelperShareParam
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

コンストラクタの詳細

KeyNodeWatchHelper

public KeyNodeWatchHelper()
メソッドの詳細

initHelper

public void initHelper(java.lang.String initValue)
初期化メソッド定義.

定義:
クラス AbstractHelper 内の initHelper
パラメータ:
initValue -

executeHelper

public java.lang.String executeHelper(java.lang.String optionParam)
                               throws BatchException
Jobメイン処理定義.

定義:
クラス AbstractHelper 内の executeHelper
パラメータ:
optionParam -
戻り値:
String
例外:
BatchException

endHelper

public void endHelper()
Helper後処理.

定義:
クラス AbstractHelper 内の endHelper

nodeDataRecover

protected boolean nodeDataRecover(java.lang.String nodeInfo,
                                  java.lang.String masterNodeInfo,
                                  ILogger logger)
                           throws BatchException
ダウン状態から復帰したノードに対して、ペアーのノードのデータをコピーする.
コピー元のデータをコピー先へ.
本メソッドを呼び出す前に必ず両ノードの使用を一時中断していること

パラメータ:
コピー先ノード(予定) -
コピー元ノード(予定) -
戻り値:
boolean 成否
例外:
BatchException

nodeDataRecover

protected boolean nodeDataRecover(java.lang.String nodeInfo,
                                  java.lang.String masterNodeInfo,
                                  boolean noDataCheck,
                                  ILogger logger)
                           throws BatchException
ダウン状態から復帰したノードに対して、ペアーのノードのデータをコピーする.
コピー元のデータをコピー先へ.
本メソッドを呼び出す前に必ず両ノードの使用を一時中断していること

パラメータ:
コピー先ノード(予定) -
コピー元ノード(予定) -
戻り値:
boolean 成否
例外:
BatchException