public class AvroItemReader<T> extends AbstractItemCountingItemStreamItemReader<T>
Resource
からデータを逆直列化する ItemReader
。コンストラクターと説明 |
---|
AvroItemReader(org.springframework.core.io.Resource resource, java.lang.Class<T> clazz) |
AvroItemReader(org.springframework.core.io.Resource data, org.springframework.core.io.Resource schema) |
修飾子と型 | メソッドと説明 |
---|---|
protected void | doClose() AbstractItemCountingItemStreamItemReader.doOpen() で開いたリソースを閉じます。 |
protected void | doOpen() 入力の読み取りを開始するために必要なリソースを開きます。 |
protected T | doRead() 入力から次の項目を読み取ります。 |
void | setEmbeddedSchema(boolean embeddedSchema) 埋め込まれた Avro スキーマの読み取りを無効または有効にします。 |
close, getCurrentItemCount, isSaveState, jumpToItem, open, read, setCurrentItemCount, setMaxItemCount, setSaveState, update
getExecutionContextKey, setExecutionContextName, setName
public AvroItemReader(org.springframework.core.io.Resource resource, java.lang.Class<T> clazz)
resource
- Avro で直列化されたオブジェクトを含む Resource
clazz
- 逆直列化するデータ型。public AvroItemReader(org.springframework.core.io.Resource data, org.springframework.core.io.Resource schema)
data
- 読み込まれるデータを含む Resource
schema
- Avro スキーマを含む Resource
public void setEmbeddedSchema(boolean embeddedSchema)
embeddedSchema
- 入力に Avro スキーマが埋め込まれていない場合は、false に設定します。@Nullable protected T doRead() throws java.lang.Exception
AbstractItemCountingItemStreamItemReader
AbstractItemCountingItemStreamItemReader<T>
の doRead
null
java.lang.Exception
- サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします protected void doOpen() throws java.lang.Exception
AbstractItemCountingItemStreamItemReader
AbstractItemCountingItemStreamItemReader<T>
の doOpen
java.lang.Exception
- サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします protected void doClose() throws java.lang.Exception
AbstractItemCountingItemStreamItemReader
AbstractItemCountingItemStreamItemReader.doOpen()
で開いたリソースを閉じます。AbstractItemCountingItemStreamItemReader<T>
の doClose
java.lang.Exception
- サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします