nablarch.etl

Class FileItemReader

java.lang.Object

javax.batch.api.chunk.AbstractItemReader

nablarch.etl.FileItemReader

All Implemented Interfaces:

javax.batch.api.chunk.ItemReader

@Named
 @Dependent
public class FileItemReader
extends javax.batch.api.chunk.AbstractItemReader

入力ファイルからJavaオブジェクトへ変換を行うItemReader実装クラス。

本実装ではチェックポイントはサポートしない。このため、restart時にはファイルの先頭から処理を再開する。

Constructor Summary

Constructors

Constructor and Description
FileItemReader(javax.batch.runtime.context.JobContext jobContext, javax.batch.runtime.context.StepContext stepContext, StepConfig stepConfig, java.io.File inputFileBasePath, ProgressManager progressManager) コンストラクタ。

Method Summary

Modifier and Type	Method and Description
void	close()
void	open(java.io.Serializable checkpoint) 入力ファイルを開き、ObjectMapperを生成する。
java.lang.Object	readItem()

Methods inherited from class javax.batch.api.chunk.AbstractItemReader

checkpointInfo

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FileItemReader

@Inject
public FileItemReader(javax.batch.runtime.context.JobContext jobContext,
                              javax.batch.runtime.context.StepContext stepContext,
                              StepConfig stepConfig,
                              java.io.File inputFileBasePath,
                              ProgressManager progressManager)

コンストラクタ。

Parameters:

jobContext - JobContext

stepContext - StepContext

stepConfig - ステップの設定

inputFileBasePath - 入力ファイルの配置ディレクトリ

progressManager - 進捗状況を管理するBean

Method Detail

open

public void open(java.io.Serializable checkpoint)
          throws java.lang.Exception

入力ファイルを開き、ObjectMapperを生成する。

Specified by:

open in interface javax.batch.api.chunk.ItemReader

Overrides:

open in class javax.batch.api.chunk.AbstractItemReader

Throws:

java.lang.Exception

readItem

public java.lang.Object readItem()
                          throws java.lang.Exception

Specified by:

readItem in interface javax.batch.api.chunk.ItemReader

Specified by:

readItem in class javax.batch.api.chunk.AbstractItemReader

Throws:

java.lang.Exception

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface javax.batch.api.chunk.ItemReader

Overrides:

close in class javax.batch.api.chunk.AbstractItemReader

Throws:

java.lang.Exception