クラス RedisItemReader<K,V>
java.lang.ObjectSE
org.springframework.batch.item.redis.RedisItemReader<K,V>
- 型パラメーター:
K
- 鍵の種類V
- 値の種類
- 実装されたすべてのインターフェース:
ItemReader<V>
、ItemStream
、ItemStreamReader<V>
Spring Data Redis をベースとした Redis 用アイテムリーダー。
RedisTemplate
を使用してデータをクエリします。ユーザーは、クエリするキーのセットを指定するために ScanOptions
を提供する必要があります。この実装はスレッドセーフではなく、再起動できません。
- 導入:
- 5.1
- 作成者:
- Mahmoud Ben Hassine
コンストラクターのサマリー
コンストラクター説明RedisItemReader
(org.springframework.data.redis.core.RedisTemplate<K, V> redisTemplate, org.springframework.data.redis.core.ScanOptions scanOptions) メソッドのサマリー
修飾子と型メソッド説明void
close()
ストリームの動作にリソースが必要な場合、ここで破棄する必要があります。void
open
(ExecutionContext executionContext) 提供されたExecutionContext
のストリームを開きます。read()
入力データの一部を読み取り、次のデータに進みます。クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.batch.item.ItemStream から継承されたメソッド
update
コンストラクターの詳細
RedisItemReader
メソッドの詳細
open
インターフェースからコピーされた説明:ItemStream
提供されたExecutionContext
のストリームを開きます。- 次で指定:
- インターフェース
ItemStream
のopen
- パラメーター:
executionContext
- 現在のステップのExecutionContext
。再起動時のステップの最後の実行からの executionContext になります。- 例外:
ItemStreamException
read
インターフェースからコピーされた説明:ItemReader
入力データの一部を読み取り、次のデータに進みます。実装は、入力データセットの最後にnull
を返す必要があります。トランザクション設定では、最初の呼び出しがロールバックされたトランザクション内にあった場合、呼び出し元は連続した呼び出し(またはそれ以外)から同じアイテムを 2 回取得する場合があります。- 次で指定:
- インターフェース
ItemReader<K>
のread
- 戻り値:
- T 処理するアイテム、またはデータソースが使い果たされた場合は
null
- 例外:
ParseException
- 現在のレコードの解析に問題がある場合 (しかし、次のものはまだ有効かもしれません)NonTransientResourceException
- 基礎となるリソースに致命的な例外がある場合。この例外をスローした後、実装は後続の read 呼び出しから null を返すように努める必要があります。UnexpectedInputException
- 入力データに未分類の問題がある場合。潜在的に一時的であると想定します。後続の読み取り呼び出しは成功する可能性があります。ExceptionSE
- 特定のエラーがない場合。
close
インターフェースからコピーされた説明:ItemStream
ストリームの動作にリソースが必要な場合、ここで破棄する必要があります。このメソッドが呼び出されると、他のすべてのメソッド(open を除く)は例外をスローする場合があります。- 次で指定:
- インターフェース
ItemStream
のclose
- 例外:
ItemStreamException