コンストラクターの詳細

• 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(java.lang.String schemaString)

  文字列から Avro Schema を構成します。

  パラメーター:

  schemaString - スキーマ文字列。

  戻り値:

  ビルダーの現在のインスタンス。

• type

  public AvroItemReaderBuilder<T> type(java.lang.Class<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(java.lang.String name)

  ExecutionContext 内でキーを計算するために使用される名前。saveState(boolean) が true に設定されている場合は必須です。

  パラメーター:

  name - リーダーインスタンスの名前

  戻り値:

  ビルダーの現在のインスタンス。

  関連事項:

  ItemStreamSupport.setName(String)

• maxItemCount

  public AvroItemReaderBuilder<T> maxItemCount(int maxItemCount)

  読み込むアイテムの最大数を設定します。

  パラメーター:

  maxItemCount - 読み込む最大アイテム

  戻り値:

  ビルダーの現在のインスタンス。

  関連事項:

  AbstractItemCountingItemStreamItemReader.setMaxItemCount(int)

• currentItemCount

  public AvroItemReaderBuilder<T> currentItemCount(int currentItemCount)

  現在のアイテムのインデックス。再起動時に使用して、どこから開始するかを示します。

  パラメーター:

  currentItemCount - 現在のインデックス

  戻り値:

  メソッド連鎖のためのこのインスタンス

  関連事項:

  AbstractItemCountingItemStreamItemReader.setCurrentItemCount(int)

• build

  public AvroItemReader<T> build()

  AvroItemReader のインスタンスをビルドします。

  戻り値:

  インスタンス ;