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

クラス AvroItemReaderBuilder<T>

java.lang.ObjectSE
org.springframework.batch.item.avro.builder.AvroItemReaderBuilder<T>
public class AvroItemReaderBuilder<T> extends ObjectSE
AvroItemReader のビルダー実装。
導入:
4.2
作成者:
David Turanski, Mahmoud Ben Hassine

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

    • AvroItemReaderBuilder

      public AvroItemReaderBuilder()

  • メソッドの詳細

    • resource

      public AvroItemReaderBuilder<T> resource(org.springframework.core.io.Resource resource)
      Avro 直列化オブジェクトを含む Resource を構成します。
      パラメーター:
      resource - 既存のリソース。
      戻り値:
      ビルダーの現在のインスタンス。

    • schema

      public AvroItemReaderBuilder<T> schema(org.springframework.core.io.Resource schema)
      Resource から Avro Schema を構成します。
      パラメーター:
      schema - 既存のスキーマリソース。
      戻り値:
      ビルダーの現在のインスタンス。

    • schema

      public AvroItemReaderBuilder<T> schema(StringSE schemaString)
      文字列から Avro Schema を構成します。
      パラメーター:
      schemaString - スキーマ文字列。
      戻り値:
      ビルダーの現在のインスタンス。

    • type

      public AvroItemReaderBuilder<T> type(ClassSE<T> type)
      デシリアライズする型を構成します。
      パラメーター:
      type - デシリアライズされるクラス。
      戻り値:
      ビルダーの現在のインスタンス。

    • embeddedSchema

      public AvroItemReaderBuilder<T> embeddedSchema(boolean embeddedSchema)
      埋め込まれた Avro スキーマの読み取りを無効または有効にします。デフォルトでは true。
      パラメーター:
      embeddedSchema - 入力に Avro スキーマが含まれていない場合は、false に設定します。
      戻り値:
      ビルダーの現在のインスタンス。

    • saveState

      public AvroItemReaderBuilder<T> saveState(boolean saveState)
      再起動のために ItemStreamSupport の状態を ExecutionContext 内に保持する必要があるかどうかを構成します。
      パラメーター:
      saveState - デフォルトは true
      戻り値:
      ビルダーの現在のインスタンス。

    • name

      public AvroItemReaderBuilder<T> name(StringSE name)
      ExecutionContext 内でキーを計算するために使用される名前。saveState(boolean) が true に設定されている場合は必須です。
      パラメーター:
      name - リーダーインスタンスの名前
      戻り値:
      ビルダーの現在のインスタンス。
      関連事項:

    • maxItemCount

      public AvroItemReaderBuilder<T> maxItemCount(int maxItemCount)
      読み込むアイテムの最大数を設定します。
      パラメーター:
      maxItemCount - 読み込む最大アイテム
      戻り値:
      ビルダーの現在のインスタンス。
      関連事項:

    • currentItemCount

      public AvroItemReaderBuilder<T> currentItemCount(int currentItemCount)
      現在のアイテムのインデックス。再起動時に使用して、どこから開始するかを示します。
      パラメーター:
      currentItemCount - 現在のインデックス
      戻り値:
      メソッド連鎖のためのこのインスタンス
      関連事項:

    • build

      public AvroItemReader<T> build()
      AvroItemReader のインスタンスをビルドします。
      戻り値:
      インスタンス ;