インターフェース ItemReader<T>
- すべての既知のサブインターフェース:
ItemStreamReader<T>
、PeekableItemReader<T>
、ResourceAwareItemReaderItemStream<T>
- すべての既知の実装クラス:
AbstractCursorItemReader
、AbstractItemCountingItemStreamItemReader
、AbstractItemStreamItemReader
、AbstractPaginatedDataItemReader
、AbstractPagingItemReader
、AmqpItemReader
、AvroItemReader
、BlockingQueueItemReader
、CompositeItemReader
、FlatFileItemReader
、ItemReaderAdapter
、IteratorItemReader
、JdbcCursorItemReader
、JdbcPagingItemReader
、JmsItemReader
、JpaCursorItemReader
、JpaPagingItemReader
、JsonItemReader
、KafkaItemReader
、LdifReader
、ListItemReader
、MappingLdifReader
、MongoCursorItemReader
、MongoItemReader
、MongoPagingItemReader
、MultiResourceItemReader
、Neo4jItemReader
、RedisItemReader
、RepositoryItemReader
、ResourcesItemReader
、SingleItemPeekableItemReader
、StaxEventItemReader
、StoredProcedureItemReader
、SupplierItemReader
、SynchronizedItemReader
、SynchronizedItemStreamReader
- 関数インターフェース:
- これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
データを提供するための戦略インターフェース。
実装はステートフルであることが期待され、バッチごとに複数回呼び出されます。
実装はスレッドセーフである必要はなく、
非同期バッチでトランザクションをサポートする必要があるため、より豊かなインターフェース(先読みやプレビューなど)は実現できません。
実装はステートフルであることが期待され、バッチごとに複数回呼び出されます。
read()
を呼び出すたびに異なる値が返され、最後にすべての入力データがなくなると null
が返されます。実装はスレッドセーフである必要はなく、
ItemReader
のクライアントはこれが事実であることを認識する必要があります。非同期バッチでトランザクションをサポートする必要があるため、より豊かなインターフェース(先読みやプレビューなど)は実現できません。
- 導入:
- 1.0
- 作成者:
- Rob Harrop, Dave Syer, Lucas Ward, Mahmoud Ben Hassine, Taeik Lim
メソッドのサマリー
メソッドの詳細
read
@Nullable T read() throws ExceptionSE, UnexpectedInputException, ParseException, NonTransientResourceException入力データの一部を読み取り、次のデータに進みます。実装は、入力データセットの最後にnull
を返す必要があります。トランザクション設定では、最初の呼び出しがロールバックされたトランザクション内にあった場合、呼び出し元は連続した呼び出し(またはそれ以外)から同じアイテムを 2 回取得する場合があります。- 戻り値:
- T 処理するアイテム、またはデータソースが使い果たされた場合は
null
- 例外:
ParseException
- 現在のレコードの解析に問題がある場合 (しかし、次のものはまだ有効かもしれません)NonTransientResourceException
- 基礎となるリソースに致命的な例外がある場合。この例外をスローした後、実装は後続の read 呼び出しから null を返すように努める必要があります。UnexpectedInputException
- 入力データに未分類の問題がある場合。潜在的に一時的であると想定します。後続の読み取り呼び出しは成功する可能性があります。ExceptionSE
- 特定のエラーがない場合。