nablarch.common.io

クラス FileRecordWriterHolder

java.lang.Object

nablarch.common.io.FileRecordWriterHolder

@Published(tag="architect")
public class FileRecordWriterHolder
extends java.lang.Object

FileRecordWriterのインスタンスをスレッド毎に管理するクラス。

スレッド毎に管理するFileRecordWriterインスタンスの生成及び取得、クローズ機能を持つ。

FileRecordWriterDisposeHandlerをハンドラとして設定する場合、 本クラスがスレッド上で管理するすべてのFileRecordWriterがFileRecordWriterDisposeHandlerにより自動的にクローズされるので、 業務アプリケーションで本クラスのclose(java.lang.String)メソッドを呼び出す必要はない。

close(String, String)及びclose(String)では、ThreadLocal.remove()の呼び出しを行わない。 スレッド上の値を削除するためには、closeAll()の呼び出しが必要となる。

関連項目:

FileRecordWriter

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
FileRecordWriterHolder()

メソッドのサマリー

修飾子とタイプ	メソッドと説明
static void	close(java.lang.String fileName) FilePathSettingから"output"という論理名で取得したベースパス配下のファイルに書き出しを行うFileRecordWriterをクローズし、 インスタンスをカレントスレッド上から削除する。
static void	close(java.lang.String basePathName, java.lang.String fileName) FilePathSettingに設定した論理名(論理ベースパス）配下のファイルに書き出しを行うFileRecordWriterをクローズし、 インスタンスをカレントスレッド上から削除する。
static void	closeAll() 本クラスがカレントスレッド上で管理している全てのFileRecordWriterのファイルストリームを クローズし、また、それら全てのFileRecordWriterをカレントスレッド上から削除する。
protected FileRecordWriter	createFileRecordWriter(java.lang.String dataFileBasePathName, java.lang.String dataFileName, java.lang.String layoutFileBasePathName, java.lang.String layoutFileName, int bufferSize) FileRecordWriterのインスタンスを生成する。
protected java.lang.String	createKey(java.lang.String basePathName, java.lang.String fileName) スレッドに保持するキーを生成する。
static FileRecordWriter	get(java.lang.String fileName) FilePathSettingから"output"という論理名で取得したベースパス配下のファイルに書き出しを行うFileRecordWriterを取得する。
static FileRecordWriter	get(java.lang.String basePathName, java.lang.String fileName) FilePathSettingに設定した論理名(論理ベースパス）配下のファイルに書き出しを行うFileRecordWriterを取得する。
static FileRecordWriterHolder	getInstance() 本クラスのインスタンスをSystemRepositoryより取得する。
static void	init() カレントスレッド上で開いたファイルを管理するための初期処理を行う。
static void	open(java.lang.String dataFileName, java.lang.String layoutFileName) FilePathSettingから"output"という論理名で取得したベースパス配下のファイルをオープンする。
static void	open(java.lang.String dataFileName, java.lang.String layoutFileName, int bufferSize) FilePathSettingから"output"という論理名で取得したベースパス配下のファイルをオープンする。
static void	open(java.lang.String dataFileBasePathName, java.lang.String dataFileName, java.lang.String layoutFileName) FilePathSettingに設定した論理名(論理ベースパス）配下のファイルをオープンする。
static void	open(java.lang.String dataFileBasePathName, java.lang.String dataFileName, java.lang.String layoutFileName, int bufferSize) FilePathSettingに設定した論理名(論理ベースパス）配下のファイルをオープンする。
static void	open(java.lang.String dataFileBasePathName, java.lang.String dataFileName, java.lang.String layoutFileBasePathName, java.lang.String layoutFileName) FilePathSettingに設定した論理名(論理ベースパス）配下のファイルをオープンする。
static void	open(java.lang.String dataFileBasePathName, java.lang.String dataFileName, java.lang.String layoutFileBasePathName, java.lang.String layoutFileName, int bufferSize) FilePathSettingに設定した論理名(論理ベースパス）配下のファイルをオープンする。
static void	write(java.util.Map<java.lang.String,?> record, java.lang.String fileName) FilePathSettingから"output"という論理名で取得したベースパス配下のデータファイルにレコードを出力する。
static void	write(java.util.Map<java.lang.String,?> record, java.lang.String basePathName, java.lang.String fileName) FilePathSettingに設定した論理名(論理ベースパス）配下のデータファイルにレコードを出力する。
static void	write(java.lang.String recordType, java.util.Map<java.lang.String,?> record, java.lang.String fileName) FilePathSettingから"output"という論理名で取得したベースパス配下のデータファイルにレコードを出力する。
static void	write(java.lang.String recordType, java.util.Map<java.lang.String,?> record, java.lang.String basePathName, java.lang.String fileName) 引数で指定したデータファイルにレコードを出力する。

クラスから継承されたメソッド java.lang.Object

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

コンストラクタの詳細

FileRecordWriterHolder

public FileRecordWriterHolder()

メソッドの詳細

getInstance

public static FileRecordWriterHolder getInstance()

本クラスのインスタンスをSystemRepositoryより取得する。

SystemRepositoryにインスタンスが存在しない場合は、クラスロード時に生成した本クラスのインスタンスを返却する。

戻り値:

本クラスのインスタンス

open

@Published
public static void open(java.lang.String dataFileName,
                                   java.lang.String layoutFileName)

FilePathSettingから"output"という論理名で取得したベースパス配下のファイルをオープンする。

このとき、フォーマット定義ファイルもFilePathSettingから"format"という論理名で取得したベースパス配下より読み込む。
また、バッファサイズには、デフォルトの値(8192B)が使用される。

パラメータ:

dataFileName - 書き込むデータファイルのファイル名

layoutFileName - フォーマット定義ファイルのファイル名

open

@Published
public static void open(java.lang.String dataFileName,
                                   java.lang.String layoutFileName,
                                   int bufferSize)

FilePathSettingから"output"という論理名で取得したベースパス配下のファイルをオープンする。

このとき、フォーマット定義ファイルもFilePathSettingから"format"という論理名で取得したベースパス配下より読み込む。
また、引数でデータファイルに書き込む際のバッファサイズを指定する。

パラメータ:

dataFileName - 書き込むデータファイルのファイル名

layoutFileName - フォーマット定義ファイルのファイル名

bufferSize - バッファサイズ

open

@Published
public static void open(java.lang.String dataFileBasePathName,
                                   java.lang.String dataFileName,
                                   java.lang.String layoutFileName)

FilePathSettingに設定した論理名(論理ベースパス）配下のファイルをオープンする。

このとき、フォーマット定義ファイルはFilePathSettingから"format"という論理名で取得したベースパス配下より読み込む。
また、データファイルに書き込む際のバッファサイズはデフォルト値(8192B)が使用される。

パラメータ:

dataFileBasePathName - 書き込むデータファイルのベースパスの論理名

dataFileName - 書き込むデータファイルのファイル名

layoutFileName - フォーマット定義ファイルのファイル名

open

@Published
public static void open(java.lang.String dataFileBasePathName,
                                   java.lang.String dataFileName,
                                   java.lang.String layoutFileName,
                                   int bufferSize)

FilePathSettingに設定した論理名(論理ベースパス）配下のファイルをオープンする。

このとき、フォーマット定義ファイルはFilePathSettingから"format"という論理名で取得したベースパス配下より読み込む。
また、引数でデータファイルに書き込む際のバッファサイズを指定する。

パラメータ:

dataFileBasePathName - 書き込むデータファイルのベースパスの論理名

dataFileName - 書き込むデータファイルのファイル名

layoutFileName - フォーマット定義ファイルのファイル名

bufferSize - バッファサイズ

init

public static void init()

カレントスレッド上で開いたファイルを管理するための初期処理を行う。

本処理を呼ばなかった場合、子スレッド側で開いたファイルは管理対象とならないため注意すること。

open

@Published
public static void open(java.lang.String dataFileBasePathName,
                                   java.lang.String dataFileName,
                                   java.lang.String layoutFileBasePathName,
                                   java.lang.String layoutFileName)

FilePathSettingに設定した論理名(論理ベースパス）配下のファイルをオープンする。

このとき、フォーマット定義ファイルはFilePathSettingから"format"という論理名で取得したベースパス配下より読み込む。 また、データファイルに書き込む際のバッファサイズはデフォルト値(8192B)が使用される。

パラメータ:

dataFileBasePathName - 書き込むデータファイルのベースパスの論理名

dataFileName - 書き込むデータファイルのファイル名

layoutFileBasePathName - フォーマット定義ファイルのベースパス論理名

layoutFileName - フォーマット定義ファイルのファイル名

open

@Published
public static void open(java.lang.String dataFileBasePathName,
                                   java.lang.String dataFileName,
                                   java.lang.String layoutFileBasePathName,
                                   java.lang.String layoutFileName,
                                   int bufferSize)

FilePathSettingに設定した論理名(論理ベースパス）配下のファイルをオープンする。

また、引数でデータファイルに書き込む際のバッファサイズと、FilePathSettingに設定したフォーマット定義ファイルの論理名を指定する。

パラメータ:

dataFileBasePathName - 書き込むデータファイルのベースパスの論理名

dataFileName - 書き込むデータファイルのファイル名

layoutFileBasePathName - フォーマット定義ファイルのベースパスの論理名

layoutFileName - フォーマット定義ファイルのファイル名

bufferSize - バッファサイズ

例外:

java.lang.IllegalArgumentException - bufferSize以外の引数がnullまたは空の場合

java.lang.IllegalStateException - カレントスレッド上のFileRecordWriterが既にオープンしている場合

write

@Published
public static void write(java.util.Map<java.lang.String,?> record,
                                    java.lang.String fileName)

FilePathSettingから"output"という論理名で取得したベースパス配下のデータファイルにレコードを出力する。

パラメータ:

record - ファイルに出力するレコード

fileName - 書き込むデータファイルのファイル名

write

@Published
public static void write(java.util.Map<java.lang.String,?> record,
                                    java.lang.String basePathName,
                                    java.lang.String fileName)

FilePathSettingに設定した論理名(論理ベースパス）配下のデータファイルにレコードを出力する。

パラメータ:

record - ファイルに出力するレコード

basePathName - 書き込むデータファイルのベースパスの論理名

fileName - 書き込むデータファイルのファイル名

write

@Published
public static void write(java.lang.String recordType,
                                    java.util.Map<java.lang.String,?> record,
                                    java.lang.String fileName)

FilePathSettingから"output"という論理名で取得したベースパス配下のデータファイルにレコードを出力する。

また、引数で出力するレコードのレコードタイプを指定する。

パラメータ:

recordType - 出力するレコードのレコードタイプ

record - ファイルに出力するレコード

fileName - 書き込むデータファイルのファイル名

write

@Published
public static void write(java.lang.String recordType,
                                    java.util.Map<java.lang.String,?> record,
                                    java.lang.String basePathName,
                                    java.lang.String fileName)

引数で指定したデータファイルにレコードを出力する。

パラメータ:

recordType - 出力するレコードのレコードタイプ

record - ファイルに出力するレコード

basePathName - 書き込むデータファイルのベースパスの論理名

fileName - 書き込むデータファイルのファイル名

createFileRecordWriter

protected FileRecordWriter createFileRecordWriter(java.lang.String dataFileBasePathName,
                                                  java.lang.String dataFileName,
                                                  java.lang.String layoutFileBasePathName,
                                                  java.lang.String layoutFileName,
                                                  int bufferSize)

FileRecordWriterのインスタンスを生成する。

パラメータ:

dataFileBasePathName - ベースパスの論理名

dataFileName - 書き込むデータファイルのファイル名

layoutFileName - レイアウトファイル名

layoutFileBasePathName - レイアウトファイルの配置ディレクトリの論理名

bufferSize - ファイル読み込み時のバッファサイズ

戻り値:

FileRecordWriterのインスタンス

createKey

protected java.lang.String createKey(java.lang.String basePathName,
                                     java.lang.String fileName)

スレッドに保持するキーを生成する。

パラメータ:

basePathName - ベースパスの論理名

fileName - 書き込むデータファイルのファイル名

戻り値:

キー

例外:

java.lang.IllegalArgumentException - basePathNameに"&"が含まれていなかった場合

get

public static FileRecordWriter get(java.lang.String fileName)

FilePathSettingから"output"という論理名で取得したベースパス配下のファイルに書き出しを行うFileRecordWriterを取得する。

パラメータ:

fileName - 書き込むデータファイルのファイル名

戻り値:

FileRecordWriter

get

public static FileRecordWriter get(java.lang.String basePathName,
                                   java.lang.String fileName)

FilePathSettingに設定した論理名(論理ベースパス）配下のファイルに書き出しを行うFileRecordWriterを取得する。

パラメータ:

basePathName - 書き込むデータファイルのベースパスの論理名

fileName - 書き込むデータファイルのファイル名

戻り値:

FileRecordWriter

例外:

java.lang.IllegalArgumentException - カレントスレッド上のFileRecordWriterが閉じている場合

close

public static void close(java.lang.String fileName)

FilePathSettingから"output"という論理名で取得したベースパス配下のファイルに書き出しを行うFileRecordWriterをクローズし、 インスタンスをカレントスレッド上から削除する。

パラメータ:

fileName - 書き込むデータファイルのファイル名

close

public static void close(java.lang.String basePathName,
                         java.lang.String fileName)

FilePathSettingに設定した論理名(論理ベースパス）配下のファイルに書き出しを行うFileRecordWriterをクローズし、 インスタンスをカレントスレッド上から削除する。

パラメータ:

basePathName - 書き込むデータファイルのベースパスの論理名

fileName - 書き込むデータファイルのファイル名

closeAll

public static void closeAll()

本クラスがカレントスレッド上で管理している全てのFileRecordWriterのファイルストリームを クローズし、また、それら全てのFileRecordWriterをカレントスレッド上から削除する。