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

クラス AvroItemWriter<T>

java.lang.ObjectSE
org.springframework.batch.item.ItemStreamSupport
org.springframework.batch.item.support.AbstractItemStreamItemWriter<T>
org.springframework.batch.item.avro.AvroItemWriter<T>
実装されているすべてのインターフェース:
ItemStream、ItemStreamWriter<T>、ItemWriter<T>
public class AvroItemWriter<T> extends AbstractItemStreamItemWriter<T>
Avro を使用してデータを WritableResource に直列化する ItemWriter。

これは、失敗時の再起動をサポートしません。

このライターはスレッドセーフではありません。

導入:
4.2
作成者:
David Turanski, Mahmoud Ben Hassine

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

    • AvroItemWriter

      public AvroItemWriter(org.springframework.core.io.WritableResource resource, org.springframework.core.io.Resource schema, ClassSE<T> clazz)
      パラメーター:
      resource - オブジェクトが直列化される WritableResource。
      schema - Avro スキーマを含む Resource。
      clazz - 直列化するデータ型。

    • AvroItemWriter

      public AvroItemWriter(org.springframework.core.io.WritableResource resource, ClassSE<T> clazz)
      このコンストラクターは、Avro スキーマを埋め込まない ItemWriter を作成します。
      パラメーター:
      resource - オブジェクトが直列化される WritableResource。
      clazz - 直列化するデータ型。

  • メソッドの詳細

    • write

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

    • open

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

    • close

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