パッケージ org.springframework.batch.item.redis

クラス RedisItemReader<K,V>

java.lang.ObjectSE
org.springframework.batch.item.redis.RedisItemReader<K,V>
型パラメーター:
K - 鍵の種類
V - 値の種類
実装されたすべてのインターフェース:
ItemReader<V>、ItemStream、ItemStreamReader<V>
public class RedisItemReader<K,V> extends ObjectSE implements 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 のストリームを開きます。
    V
    read()
    入力データの一部を読み取り、次のデータに進みます。

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

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

    インターフェース org.springframework.batch.item.ItemStream から継承されたメソッド

    update

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

    • RedisItemReader

      public RedisItemReader(org.springframework.data.redis.core.RedisTemplate<K,V> redisTemplate, org.springframework.data.redis.core.ScanOptions scanOptions)

  • メソッドの詳細

    • open

      public void open(ExecutionContext executionContext) throws ItemStreamException
      インターフェースからコピーされた説明: ItemStream
      提供された ExecutionContext のストリームを開きます。
      次で指定:
      インターフェース ItemStream の open 
      パラメーター:
      executionContext - 現在のステップの ExecutionContext 再起動時のステップの最後の実行からの executionContext になります。
      例外:
      ItemStreamException

    • read

      public V read() throws ExceptionSE
      インターフェースからコピーされた説明: ItemReader
      入力データの一部を読み取り、次のデータに進みます。実装は、入力データセットの最後に null を返す必要があります。トランザクション設定では、最初の呼び出しがロールバックされたトランザクション内にあった場合、呼び出し元は連続した呼び出し（またはそれ以外）から同じアイテムを 2 回取得する場合があります。
      次で指定:
      インターフェース ItemReader<K> の read 
      戻り値:
      T 処理するアイテム、またはデータソースが使い果たされた場合は null 
      例外:
      ParseException - 現在のレコードの解析に問題がある場合 (しかし、次のものはまだ有効かもしれません)
      NonTransientResourceException - 基礎となるリソースに致命的な例外がある場合。この例外をスローした後、実装は後続の read 呼び出しから null を返すように努める必要があります。
      UnexpectedInputException - 入力データに未分類の問題がある場合。潜在的に一時的であると想定します。後続の読み取り呼び出しは成功する可能性があります。
      ExceptionSE - 特定のエラーがない場合。

    • close

      public void close() throws ItemStreamException
      インターフェースからコピーされた説明: ItemStream
      ストリームの動作にリソースが必要な場合、ここで破棄する必要があります。このメソッドが呼び出されると、他のすべてのメソッド（open を除く）は例外をスローする場合があります。
      次で指定:
      インターフェース ItemStream の close 
      例外:
      ItemStreamException