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

クラス KeyValueItemWriter<K,V>

java.lang.ObjectSE
org.springframework.batch.item.KeyValueItemWriter<K,V>
実装されたすべてのインターフェース:
ItemWriter<V>, org.springframework.beans.factory.InitializingBean
既知の直属サブクラス
KafkaItemWriter, RedisItemWriter
public abstract class KeyValueItemWriter<K,V> extends ObjectSE implements ItemWriter<V>, org.springframework.beans.factory.InitializingBean
Converter を使用してキー値ストアに書き込み、アイテムからキーを派生させる ItemWriter を実装する基本クラス
導入:
2.2
作成者:
David Turanski, Mahmoud Ben Hassine

  • フィールドのサマリー

    フィールド
    修飾子と型
    フィールド
    説明
    protected boolean
    delete
    protected org.springframework.core.convert.converter.Converter<V,K>
    itemKeyMapper

  • コンストラクターの概要

    コンストラクター
    コンストラクター
    説明
    KeyValueItemWriter()

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    afterPropertiesSet()
    protected void
    flush()
    アイテムを Key/Value ストアにフラッシュします。
    protected abstract void
    init()
    afterPropertiesSet() フック
    void
    setDelete(boolean delete)
    アイテムライターに削除を実行させる削除フラグを設定します
    void
    setItemKeyMapper(org.springframework.core.convert.converter.Converter<V,K> itemKeyMapper)
    アイテムからキーを取得するために使用する Converter を設定します
    void
    write(Chunk<? extends V> items)
    指定されたデータ要素を処理します。
    protected abstract void
    writeKeyValue(K key, V value)
    サブクラスはこのメソッドを実装して、各アイテムをキー値ストアに書き込みます

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

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

  • フィールドの詳細

    • itemKeyMapper

      protected org.springframework.core.convert.converter.Converter<V,K> itemKeyMapper

    • delete

      protected boolean delete

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

    • KeyValueItemWriter

      public KeyValueItemWriter()

  • メソッドの詳細

    • write

      public void write(Chunk<? extends V> items) throws ExceptionSE
      インターフェースからコピーされた説明: ItemWriter
      指定されたデータ要素を処理します。通常の操作では null アイテムで呼び出されません。
      次で指定:
      インターフェース ItemWriter<K> の write 
      パラメーター:
      items - 書きこまれる項目。null であってはなりません。
      例外:
      ExceptionSE - エラーがある場合。フレームワークは例外をキャッチし、必要に応じて変換または再スローします。

    • flush

      protected void flush() throws ExceptionSE
      アイテムを Key/Value ストアにフラッシュします。
      例外:
      ExceptionSE - アイテムをフラッシュできない場合

    • writeKeyValue

      protected abstract void writeKeyValue(K key, V value)
      サブクラスはこのメソッドを実装して、各アイテムをキー値ストアに書き込みます
      パラメーター:
      key - キー
      value - アイテム

    • init

      protected abstract void init()
      afterPropertiesSet() フック

    • setItemKeyMapper

      public void setItemKeyMapper(org.springframework.core.convert.converter.Converter<V,K> itemKeyMapper)
      アイテムからキーを取得するために使用する Converter を設定します
      パラメーター:
      itemKeyMapper - アイテムからキーを取得するために使用される Converter。

    • setDelete

      public void setDelete(boolean delete)
      アイテムライターに削除を実行させる削除フラグを設定します
      パラメーター:
      delete - true の場合、ItemWriter は削除を実行し、false の場合、削除を実行しません。

    • afterPropertiesSet

      public void afterPropertiesSet() throws ExceptionSE
      次で指定:
      インターフェース org.springframework.beans.factory.InitializingBean の afterPropertiesSet 
      例外:
      ExceptionSE