Oga.pipe2説明書

= これは何？ = Unixのパイプの機能をJavaで実装したもの. http://d.hatena.ne.jp/m-hiyama/20071214/1197598785 を参考にしてBlockingQueueを用いて作られているので、 各処理は並列に実行される.

おもにタブ区切りテキストファイル形式のテーブルデータを処理するために用いられる.

= 使い方 =

インストール
1. subversionリポジトリよりダウンロード svn co http://rgm2.lab.nig.ac.jp/svn/repos/ogaBase

2. maven2にて管理されているので、以下のコマンドでddbj_lib/targetディレクトリの下にjarが作られる. 先にMavenの使い方を参照して$HOME/.m2/settings.xmlを作成すること. cd ogaBase mvn package mvn assembly:assembly -DdescriptorId=jar-with-dependencies

実行方法
ライブラリですので単体では使えません.

ライブラリの使い方
使用例は以下のとおり.


 * 1) PipeLineオブジェクトのコンストラクタにoga.pipe2.Inオブジェクト、oga.pipe2.Outオブジェクトを指定する.
 * 2) * Inオブジェクトがデータの流入元、Outオブジェクトがデータの流出先を表す.
 * 3) pl.addメソッドを使ってパイプにFilterを順に挿入する. addの引数に、oga.pipe2.filter.Filterオブジェクトを指定すればよい.
 * 4) * Filterオブジェクトにパラメータを設定するやり方は上記の例を参照のこと.
 * 5) 最後にplのstartを呼ぶと、全てのFilterが並列に実行される.

= 内部構造と拡張方法 =

In, Out, Filterクラスの実クラスを書けば良い. 詳細はjavadocを参照してください.

http://rgm3.lab.nig.ac.jp/Repository2/ogaBase/apidocs/