クラス AvroItemReader<T>
java.lang.ObjectSE
org.springframework.batch.item.ItemStreamSupport
org.springframework.batch.item.support.AbstractItemStreamItemReader<T>
org.springframework.batch.item.support.AbstractItemCountingItemStreamItemReader<T>
org.springframework.batch.item.avro.AvroItemReader<T>
- 実装されたすべてのインターフェース:
ItemReader<T>、ItemStream、ItemStreamReader<T>
- 導入:
- 4.2
- 作成者:
- David Turanski, Mahmoud Ben Hassine, Song JaeGeun
コンストラクターのサマリー
コンストラクターコンストラクター説明AvroItemReader(org.springframework.core.io.Resource resource, ClassSE<T> clazz) AvroItemReader(org.springframework.core.io.Resource data, org.springframework.core.io.Resource schema) メソッドのサマリー
修飾子と型メソッド説明protected voiddoClose()AbstractItemCountingItemStreamItemReader.doOpen()で開いたリソースを閉じます。protected voiddoOpen()入力の読み取りを開始するために必要なリソースを開きます。protected TdoRead()入力から次の項目を読み取ります。voidsetEmbeddedSchema(boolean embeddedSchema) 埋め込まれた Avro スキーマの読み取りを無効または有効にします。クラス org.springframework.batch.item.support.AbstractItemCountingItemStreamItemReader から継承されたメソッド
close, getCurrentItemCount, isSaveState, jumpToItem, open, read, setCurrentItemCount, setMaxItemCount, setSaveState, updateクラス org.springframework.batch.item.ItemStreamSupport から継承されたメソッド
getExecutionContextKey, getName, setExecutionContextName, setName
コンストラクターの詳細
AvroItemReader
- パラメーター:
resource- Avro で直列化されたオブジェクトを含むResourceclazz- 逆直列化するデータ型。
AvroItemReader
public AvroItemReader(org.springframework.core.io.Resource data, org.springframework.core.io.Resource schema) - パラメーター:
data- 読み込まれるデータを含むResourceschema- Avro スキーマを含むResource
メソッドの詳細
setEmbeddedSchema
public void setEmbeddedSchema(boolean embeddedSchema) 埋め込まれた Avro スキーマの読み取りを無効または有効にします。デフォルトでは true。- パラメーター:
embeddedSchema- 入力に Avro スキーマが埋め込まれていない場合は、false に設定します。
doRead
クラスからコピーされた説明:AbstractItemCountingItemStreamItemReader入力から次の項目を読み取ります。- 次で指定:
- クラス
AbstractItemCountingItemStreamItemReader<T>のdoRead - 戻り値:
- データソースが使い果たされた場合、アイテムまたは
null - 例外:
ExceptionSE- サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします
doOpen
クラスからコピーされた説明:AbstractItemCountingItemStreamItemReader入力の読み取りを開始するために必要なリソースを開きます。- 次で指定:
- クラス
AbstractItemCountingItemStreamItemReader<T>のdoOpen - 例外:
ExceptionSE- サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします
doClose
クラスからコピーされた説明:AbstractItemCountingItemStreamItemReaderAbstractItemCountingItemStreamItemReader.doOpen()で開いたリソースを閉じます。- 次で指定:
- クラス
AbstractItemCountingItemStreamItemReader<T>のdoClose - 例外:
ExceptionSE- サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします