クラス Chunk<W>

java.lang.ObjectSE
org.springframework.batch.item.Chunk<W>
実装されたすべてのインターフェース:
SerializableSEIterableSE<W>

public class Chunk<W> extends ObjectSE implements IterableSE<W>, SerializableSE
処理されるアイテムのリストと、場合によってはスキップされる失敗したアイテムのリストのカプセル化。アイテムをスキップされたクライアントとしてマークするには、iterator() メソッドを使用してチャンクを反復処理する必要があります。障害が発生した場合は、イテレーターで Chunk.ChunkIterator.remove() を呼び出します。スキップされたアイテムは、チャンクを通じて利用できます。
導入:
2.0
作成者:
Dave Syer, Mahmoud Ben Hassine, Jinwoo Bae
関連事項:
  • ネストされたクラスのサマリー

    ネストされたクラス
    修飾子と型
    クラス
    説明
    class
    アイテムを動的に削除してスキップに追加するための Chunk.ChunkIterator.remove(Throwable) メソッドを提供するチャンク用の特別なイテレーター。
  • コンストラクターのサマリー

    コンストラクター
    コンストラクター
    説明
    Chunk(ListSE<? extends W> items)
    Chunk(ListSE<? extends W> items, ListSE<SkipWrapper<W>> skips)
    Chunk(W... items)
  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    add(W item)
    アイテムをチャンクに追加します。
    void
    addAll(ListSE<W> items)
    すべてのアイテムをチャンクに追加します。
    void
    アイテムをクリアして、完了したことを知らせます。
    void
    スキップリストのみをクリアします。
    boolean
    int
    boolean
    チャンクをクエリして、そのチャンクへの参照を保持することに関心を持っている人がいないかどうかを確認します。
    boolean
    boolean
    ソースデータが使い果たされているかどうかを示すフラグ。
    基になるアイテムの変更不可能なイテレータを取得します。
    static <W> Chunk<W>
    of(W... items)
    void
    setBusy(boolean busy)
    フラグが false にリセットされる前にチャンクがクリーンアップされないように、チャンクに関心を登録します。
    void
    このチャンクがストリームの終わりを表すことを示すフラグを設定します(処理するデータはこれ以上ありません)。
    void
    int
    void
    匿名スキップを登録します。

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, finalize, getClass, notify, notifyAll, wait, waitSE, waitSE

    インターフェース java.lang.IterableSE から継承されたメソッド

    forEachSE, spliterator
  • コンストラクターの詳細

  • メソッドの詳細

    • of

      @SafeVarargsSE public static <W> Chunk<W> of(W... items)
    • add

      public void add(W item)
      アイテムをチャンクに追加します。
      パラメーター:
      item - 追加するアイテム
    • addAll

      public void addAll(ListSE<W> items)
      すべてのアイテムをチャンクに追加します。
      パラメーター:
      items - 追加するアイテム
    • clear

      public void clear()
      アイテムをクリアして、完了したことを知らせます。
    • getItems

      public ListSE<W> getItems()
      戻り値:
      変更不可能なリストとして処理されるアイテムのコピー
    • getSkips

      public ListSE<SkipWrapper<W>> getSkips()
      戻り値:
      変更不可能なリストとしてのスキップのコピー
    • getErrors

      public ListSE<ExceptionSE> getErrors()
      戻り値:
      変更不可能なリストとしての匿名エラーのコピー
    • skip

      public void skip(ExceptionSE e)
      匿名スキップを登録します。個々のアイテムをスキップするには、Chunk.ChunkIterator.remove() を使用します。
      パラメーター:
      e - スキップを引き起こした例外
    • isEmpty

      public boolean isEmpty()
      戻り値:
      チャンクにアイテムがない場合は true
    • iterator

      public Chunk<W>.ChunkIterator iterator()
      基になるアイテムの変更不可能なイテレータを取得します。
      次で指定:
      インターフェース IterableSE<W>iterator 
      関連事項:
    • size

      public int size()
      戻り値:
      アイテムの数 (スキップを除く)
    • isEnd

      public boolean isEnd()
      ソースデータが使い果たされているかどうかを示すフラグ。
      戻り値:
      処理するデータがこれ以上ない場合は true
    • setEnd

      public void setEnd()
      このチャンクがストリームの終わりを表すことを示すフラグを設定します(処理するデータはこれ以上ありません)。
    • isBusy

      public boolean isBusy()
      チャンクをクエリして、そのチャンクへの参照を保持することに関心を持っている人がいないかどうかを確認します。
      戻り値:
      忙しい旗
    • setBusy

      public void setBusy(boolean busy)
      フラグが false にリセットされる前にチャンクがクリーンアップされないように、チャンクに関心を登録します。
      パラメーター:
      busy - 設定するフラグ
    • clearSkips

      public void clearSkips()
      スキップリストのみをクリアします。
    • getUserData

      public ObjectSE getUserData()
    • setUserData

      public void setUserData(ObjectSE userData)
    • toString

      public StringSE toString()
      オーバーライド:
      クラス ObjectSEtoString 
    • equals

      public boolean equals(ObjectSE obj)
      オーバーライド:
      クラス ObjectSEequalsSE 
    • hashCode

      public int hashCode()
      オーバーライド:
      クラス ObjectSEhashCode