okuyama.imdst.helper
クラス MasterManagerHelper

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

public class MasterManagerHelper
extends AbstractMasterManagerHelper

MasterNodeのメイン実行部分

作成者:
T.Okuyama

フィールドの概要
 
クラス okuyama.imdst.helper.AbstractMasterManagerHelper から継承されたフィールド
keyNodeConnectPool, recoverProcessed
 
クラス okuyama.base.job.AbstractHelper から継承されたフィールド
END, ERR, ERROR, helperConfigMap, helperParamShareMap, RUN, status, SUCCESS, WAIT
 
コンストラクタの概要
MasterManagerHelper()
           
 
メソッドの概要
 void endHelper()
          Helper後処理.
 java.lang.String executeHelper(java.lang.String optionParam)
          executeHelper.
 void initHelper(java.lang.String initValue)
          initHelper.
 java.lang.String[] insertKeyPairTag(java.lang.String keyStr, java.lang.String tagStr, java.lang.String transactionCode)
          KeyへTagの紐付けのみ行う.
 java.lang.String[] setKeyValue(java.lang.String keyStr, java.lang.String tagStr, java.lang.String transactionCode, java.lang.String dataStr)
          Key-Valueを保存する.
 java.lang.String[] setKeyValue(java.lang.String keyStr, java.lang.String tagStr, java.lang.String transactionCode, java.lang.String dataStr, boolean fixPrefix)
          Key-Valueを保存する.
 
クラス 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
 

コンストラクタの詳細

MasterManagerHelper

public MasterManagerHelper()
メソッドの詳細

initHelper

public void initHelper(java.lang.String initValue)
クラス AbstractHelper の記述:
initHelper.
ユーザHelper実装部分.

定義:
クラス AbstractHelper 内の initHelper

executeHelper

public java.lang.String executeHelper(java.lang.String optionParam)
                               throws BatchException
クラス AbstractHelper の記述:
executeHelper.
ユーザHelper実装部分.

定義:
クラス AbstractHelper 内の executeHelper
戻り値:
String 実行結果
例外:
BatchException

endHelper

public void endHelper()
Helper後処理.

定義:
クラス AbstractHelper 内の endHelper

setKeyValue

public java.lang.String[] setKeyValue(java.lang.String keyStr,
                                      java.lang.String tagStr,
                                      java.lang.String transactionCode,
                                      java.lang.String dataStr)
                               throws BatchException
Key-Valueを保存する.
処理フロー.
1.DataDispatcherに依頼してTagの保存先を問い合わせる。Tag情報を全保存する
2.DataDispatcherに依頼してKeyの保存先を問い合わせる。Tag情報を保存する
3.結果文字列の配列を作成(成功時は処理番号"1"と"true"、失敗時は処理番号"1"と"false")

パラメータ:
keyStr - key値の文字列
tagStr - tag値の文字列
isr - クライアントからのインプット
戻り値:
String[] 結果
例外:
BatchException

setKeyValue

public java.lang.String[] setKeyValue(java.lang.String keyStr,
                                      java.lang.String tagStr,
                                      java.lang.String transactionCode,
                                      java.lang.String dataStr,
                                      boolean fixPrefix)
                               throws BatchException
Key-Valueを保存する.
処理フロー.
1.DataDispatcherに依頼してTagの保存先を問い合わせる。Tag情報を全保存する
2.DataDispatcherに依頼してKeyの保存先を問い合わせる。Tag情報を保存する
3.結果文字列の配列を作成(成功時は処理番号"1"と"true"、失敗時は処理番号"1"と"false")

パラメータ:
keyStr - key値の文字列
tagStr - tag値の文字列
transactionCode - トランザクションコード
dataStr - value値の文字列
fixPrefix - 既にIsolation処理を完了している指定
戻り値:
String[] 結果
例外:
BatchException

insertKeyPairTag

public java.lang.String[] insertKeyPairTag(java.lang.String keyStr,
                                           java.lang.String tagStr,
                                           java.lang.String transactionCode)
                                    throws BatchException
KeyへTagの紐付けのみ行う.
処理フロー.

パラメータ:
keyStr - key値の文字列
tagStr - tag値の文字列
戻り値:
String[] 結果
例外:
BatchException