クラス SingleItemPeekableItemReader<T>

方法の詳細

• setDelegate

  public void setDelegate(ItemReader<T> delegate)

  デリゲートとして使用するアイテムリーダー。アイテムはデリゲートから読み取られ、read() で呼び出し元に渡されます。

  パラメーター:

  delegate - 設定するデリゲート

• read

  @Nullable public T read() throws ExceptionSE, UnexpectedInputException, ParseException

  デリゲートから次のアイテムを取得します（すでにピークされているかどうかに関係なく）。

  次で指定:

  インターフェース ItemReader<T> 内の read 

  戻り値:

  T 処理するアイテム、またはデータソースが使い果たされた場合は null 

  例外:

  ParseException - 現在のレコードの解析に問題がある場合 (しかし、次のものはまだ有効かもしれません)

  NonTransientResourceException - 基礎となるリソースに致命的な例外がある場合。この例外をスローした後、実装は後続の read 呼び出しから null を返すように努める必要があります。

  UnexpectedInputException - 入力データに未分類の問題がある場合。潜在的に一時的であると想定します。後続の読み取り呼び出しは成功する可能性があります。

  ExceptionSE - 特定のエラーがない場合。

  関連事項:

  • ItemReader.read()

• peek

  @Nullable public T peek() throws ExceptionSE, UnexpectedInputException, ParseException

  次の項目を確認し、デリゲートが ItemStream の場合、状態が update(ExecutionContext) への次の呼び出しのために保存されることを確認します。

  次で指定:

  インターフェース PeekableItemReader<T> 内の peek 

  戻り値:

  次のアイテム（ない場合は null）。

  例外:

  ExceptionSE - 問題がある場合

  UnexpectedInputException

  ParseException

  関連事項:

  • PeekableItemReader.peek()

• close

  public void close() throws ItemStreamException

  デリゲートが ItemStream の場合は、呼び出しを渡すだけです。それ以外の場合は、ピークキャッシュをリセットします。

  次で指定:

  インターフェース ItemStream 内の close 

  例外:

  ItemStreamException - 問題がある場合

  関連事項:

  • ItemStream.close()

• open

  public void open(ExecutionContext executionContext) throws ItemStreamException

  デリゲートが ItemStream の場合は、呼び出しを渡すだけです。それ以外の場合は、ピークキャッシュをリセットします。

  次で指定:

  インターフェース ItemStream 内の open 

  パラメーター:

  executionContext - 現在のコンテキスト

  例外:

  ItemStreamException - 問題がある場合

  関連事項:

  • ItemStream.open(ExecutionContext)

• update

  public void update(ExecutionContext executionContext) throws ItemStreamException

  キャッシュされたピークがある場合は、その時点から実行コンテキストの状態を取得します。キャッシュされたピークがない場合は、デリゲートを直接呼び出します。

  次で指定:

  インターフェース ItemStream 内の update 

  パラメーター:

  executionContext - 現在のコンテキスト

  例外:

  ItemStreamException - 問題がある場合

  関連事項:

  • ItemStream.update(ExecutionContext)