jp.terasoluna.fw.batch.standard
クラス Chunker

java.lang.Object
  上位を拡張 jp.terasoluna.fw.batch.standard.Chunker
すべての実装されたインタフェース:
CollectedDataHandler

public class Chunker
extends java.lang.Object
implements CollectedDataHandler

処理対象データを指定されたサイズ分まとめて、チャンクを作成するクラス。


フィールドの概要
private  int chunkSize
          チャンクサイズ。
private  Chunk currentChunk
          作成中のチャンク。
private  JobContext jobContext
          ジョブコンテクスト。
private  WorkQueue queue
          キュー。
 
コンストラクタの概要
Chunker(WorkQueue queue, int chunkSize, JobContext jobContext)
          コンストラクタ。
 
メソッドの概要
 void close()
          クローズ処理を行う。
 void handle(java.lang.Object row, int index)
          処理対象データをキューに追加する。
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

queue

private WorkQueue queue
キュー。


chunkSize

private int chunkSize
チャンクサイズ。


currentChunk

private Chunk currentChunk
作成中のチャンク。


jobContext

private JobContext jobContext
ジョブコンテクスト。

コンストラクタの詳細

Chunker

public Chunker(WorkQueue queue,
               int chunkSize,
               JobContext jobContext)
コンストラクタ。

パラメータ:
queue - ワークキュー
chunkSize - チャンクサイズ
jobContext - ジョブコンテクスト
メソッドの詳細

handle

public void handle(java.lang.Object row,
                   int index)
処理対象データをキューに追加する。

定義:
インタフェース CollectedDataHandler 内の handle
パラメータ:
row - 処理対象データ
index - 処理対象データのインデックス

close

public void close()
クローズ処理を行う。

定義:
インタフェース CollectedDataHandler 内の close