jp.terasoluna.fw.batch.core
クラス AbstractCollector<T extends JobContext>

java.lang.Object
  上位を拡張 jp.terasoluna.fw.batch.core.AbstractCollector<T>
型パラメータ:
T - ジョブコンテクストのサブクラス
すべての実装されたインタフェース:
Collector<T>
直系の既知のサブクラス:
IBatisDbCollectorImpl, JobRequestInfoCollector, ListPropertyCollector, StandardFileCollector, StringArrayPropertyCollector

public abstract class AbstractCollector<T extends JobContext>
extends java.lang.Object
implements Collector<T>

コレクター抽象クラス。

対象データ取得処理を開始する。
対象データ取得処理はこのAbstract クラスを実装したクラスにて行う。

関連項目:
IBatisDbCollectorImpl, JobRequestInfoCollector, ListPropertyCollector, StringArrayPropertyCollector

フィールドの概要
private  CollectedDataHandlerFactory collectedDataHandlerFactory
          対象データハンドラ。
private static Log log
          ログインスタンス。
 
コンストラクタの概要
AbstractCollector()
           
 
メソッドの概要
 CollectorResult collect(T jobContext, WorkQueue workQueue, JobStatus jobStatus)
          対象データ取得処理を開始する。
protected abstract  CollectorResult doCollect(T jobContext, CollectedDataHandler collectedDataHandler, JobStatus jobStatus)
          対象データを取得する。
 void setCollectedDataHandlerFactory(CollectedDataHandlerFactory collectedDataHandlerFactory)
          収集データ処理ハンドラを設定する。
private  void writeEndLog(JobStatus jobStatus)
          AbstractCollectorの終了ログを出力する。
private  void writeStartLog(JobStatus jobStatus)
          AbstractCollectorの開始ログを出力する。
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

log

private static final Log log
ログインスタンス。


collectedDataHandlerFactory

private CollectedDataHandlerFactory collectedDataHandlerFactory
対象データハンドラ。

コンストラクタの詳細

AbstractCollector

public AbstractCollector()
メソッドの詳細

collect

public CollectorResult collect(T jobContext,
                               WorkQueue workQueue,
                               JobStatus jobStatus)
対象データ取得処理を開始する。

定義:
インタフェース Collector<T extends JobContext> 内の collect
パラメータ:
jobContext - ジョブコンテクスト
workQueue - ワークキュー
jobStatus - ジョブステータス
戻り値:
コレクタの処理結果

setCollectedDataHandlerFactory

public void setCollectedDataHandlerFactory(CollectedDataHandlerFactory collectedDataHandlerFactory)
収集データ処理ハンドラを設定する。

パラメータ:
collectedDataHandlerFactory - 収集したデータを処理するハンドラ

doCollect

protected abstract CollectorResult doCollect(T jobContext,
                                             CollectedDataHandler collectedDataHandler,
                                             JobStatus jobStatus)
対象データを取得する。

パラメータ:
jobContext - ジョブコンテクスト
collectedDataHandler - 収集したデータを処理するハンドラ
jobStatus - ジョブステータス
戻り値:
コレクタの処理結果

writeStartLog

private void writeStartLog(JobStatus jobStatus)
AbstractCollectorの開始ログを出力する。

パラメータ:
jobStatus - ジョブステータス

writeEndLog

private void writeEndLog(JobStatus jobStatus)
AbstractCollectorの終了ログを出力する。

パラメータ:
jobStatus - ジョブステータス