入力されたレコードに対して，抽出対象条件の判定をします。

抽出対象条件とは，抽出対象のレコードを取捨選択するための条件の一つです。抽出対象条件は，レコード抽出定義のtargetrecordタグで指定します。

抽出対象条件には，レコード条件とフィールド条件を指定します。

• レコード条件
  recordタグで，抽出対象のレコード名を指定します。
  
• フィールド条件
  fieldタグで，抽出対象のレコードのフィールド名，比較演算記号，および条件値を指定します。
  

例えば，レコード名がR1，フィールド名がF1，フィールド値がTAROという条件を指定したい場合には，レコード条件のレコード名には「source="R1"」，フィールド条件には「source="F1" condition="eq" value="TARO"」と指定します。

抽出対象条件の判定では，レコード抽出定義で定義した抽出対象条件に従って，レコード条件の判定，およびフィールド条件の判定が行われます。抽出対象条件の判定の流れを次に示します。

1. レコード条件の判定
   入力されたレコードのレコード名が，レコード条件に指定したレコード名と一致するかどうかを判定します。
   
   • レコード条件に一致したレコード
     フィールド条件の判定の処理へ進みます。
     
   • レコード条件に一致しなかったレコード
     一致しなかったレコードは，そのまま出力されて，次のコールバックに渡されます。
     
2. フィールド条件の判定
   レコード条件に一致したレコードのフィールド値が，フィールド条件に指定したフィールド値と一致するかどうかを判定します。
   
   • フィールド条件に一致したレコード
     抽出対象条件が成立して，抽出条件の判定の処理へ進みます。抽出条件の判定の処理については，「(2)　抽出条件の判定」を参照してください。
     
   • フィールド条件に一致しなかったレコード
     一致しなかったレコードは，そこで破棄されます。
     

抽出対象条件が成立したレコードに対して，抽出条件の判定をします。

抽出条件とは，抽出対象のレコードを取捨選択するための条件の一つです。抽出条件は，レコード抽出定義のextractionタグで指定します。

抽出条件には，レコードバッファーに保持するレコードの上限値や，レコード間条件を指定します。レコード間条件には，レコードの入力順序と，レコード間でフィールド値を比較するためのフィールド値を指定します。レコード間条件は，targetsタグで指定します。

抽出条件の判定では，レコード抽出定義で定義した抽出条件に従って，レコード間条件の判定が行われます。レコード間条件に一致したレコードは，抽出条件が成立するまでレコードバッファーに保持されます。抽出条件の判定の流れを次に示します。

1. レコード間条件の判定
   抽出対象条件が成立したレコードに対して，レコード間条件で指定した次の内容と一致するかどうかを判定します。
   
   • レコードの入力順序が一致するかどうか。^※
   • レコード間のフィールド値が一致するかどうか。^※

   注※

   レコード内の時刻情報が同一である複数のレコードが入力された場合，抽出条件はレコードの入力順序で判定します。

   これらの条件に一致したレコードはレコードバッファーに保持され，一致しなかったレコードはそこで破棄されます。
   
2. レコードバッファーに保持
   レコード間条件に一致したレコードは，レコードバッファーに保持され，レコード間条件で指定したすべてのレコードがそろって抽出条件が成立すると，抽出レコード生成の処理へ進みます。抽出レコード生成の処理については，「(3)　抽出レコード生成」を参照してください。
   

レコードの入力順序を指定している場合のレコード保持と破棄の流れの例を次の図に示します。

図11-15　レコードの入力順序を指定している場合のレコード保持と破棄の流れの例

この例では，レコードの入力順序をレコードA→レコードB→レコードCと指定しています。このため，入力されたレコードは次のように保持，または破棄されます。

• 処理1：レコードバッファー内にレコードがない状態で入力されたレコードBは，入力順序に一致しないため破棄されます。
• 処理2：レコードバッファー内にレコードがない状態で入力されたレコードAは，入力順序に一致するため保持されます。
• 処理3：レコードAのあとに入力されたレコードCは，入力順序に一致しないため破棄されます。
• 処理4：レコードAのあとに入力されたレコードBは，入力順序に一致するため保持されます。
• 処理5：レコードAとレコードBのあとに入力されたレコードCは，入力順序に一致するため保持されます。レコードA→レコードB→レコードCの順序でレコードが入力され，すべてのレコードがそろうため，ここで抽出条件が成立します。

レコードを破棄した場合，破棄したレコード数は，アダプタートレースに出力されます。アダプタートレースについては，「6.3.3　アダプタートレースの詳細」を参照してください。

抽出条件の判定では，レコード内の時刻情報が逆転した場合や，レコードバッファーに保持しているレコードがタイムアウトした場合などにもレコードを破棄します。それぞれの内容について，次に説明します。

• レコード内の時刻情報が逆転した場合
  レコード内の時刻情報の逆転が発生したレコードが入力された場合には，レコードを破棄します。
  
• レコードバッファーに保持しているレコードがタイムアウトした場合
  レコードの抽出では，レコードバッファーに保持しているレコードがタイムアウトする条件として，レコードの生存時間を指定できます。レコードの生存時間は，extractionタグのtimelimit属性で指定します。
  指定した生存時間が経過しても抽出条件が成立していない場合には，タイムアウトと見なして，レコードバッファーに保持されていたレコードを破棄します。
  このとき，extractionsタグのtimeout属性でタイムアウトレコードの出力を指定していると，レコードバッファーに保持されていたレコードのうち，最初のレコードだけを出力できます。
  タイムアウト時に出力されるレコードのことをタイムアウトレコードといます。タイムアウトレコードには，extractionタグのname属性で指定した抽出条件名が入力されたフィールドが追加されます。
  タイムアウト時のレコードの処理の流れを次の図に示します。
  

  図11-16　タイムアウト時のレコードの処理の流れ

  

  この例の条件は次のとおりです。
  
  • レコードA，レコードB，レコードCの三つがそろうと，抽出条件をすべて満たして，抽出レコード生成の処理へ進むことができる。
  • タイムアウトした場合には，タイムアウトレコードを出力する。
  • レコードCの入力待機中にタイムアウトした。
  このため，レコードBは破棄され，レコードAはタイムアウトレコードとして出力されます。
  
• レコードバッファーに保持するレコード数の上限値を超えた場合
  レコードの抽出では，レコードバッファーに保持するレコード数を管理するために，保持するレコード数の上限値を指定できます。保持するレコード数の上限値は，extractionsタグのsize属性で指定します。上限値を超えた場合には，レコードバッファーに保持しているすべてのレコードを破棄します。
  
• 同一レコードが入力された場合
  レコードの抽出では，同一の抽出対象条件を満たし，かつレコード間条件に指定したフィールドの値が等しいレコードは，同一レコードと見なします。同一レコードが入力された場合には，extractionsタグのsamerecord属性で指定した内容に従って，次の処理が行われます。
  
  • samerecord属性でoverwriteを指定した場合
    同一レコードと見なされた既存のレコードが，レコードバッファーのどの位置にあるかによって処理が異なります。
    最も後ろのレコードの場合，入力されたレコードで，レコードバッファーに保持していた既存のレコードを上書きします。ほかのレコードの場合，レコードバッファーに保持していた既存のレコードをすべて破棄し，入力されたレコードを保持します。
    
  • samerecord属性でdeleteを指定した場合
    入力されたレコードを破棄します。
    
  次の図に示す例を使用して，同一レコードが入力された場合の処理について説明します。
  

  図11-17　同一レコードが入力された場合の処理

  

  この例の条件は次のとおりです。
  
  • レコードA，レコードB，レコードCの三つがそろうと，抽出条件をすべて満たして，抽出レコード生成の処理へ進むことができる。
  • samerecord属性でoverwriteを指定している。
  • レコードCの入力待機中に，レコードA，またはレコードBが入力された。
  この条件の場合，レコードAとレコードBのどちらが入力されるかによって，次のように処理が異なります。
  
  • レコードAの場合
    レコードバッファーに保持していた既存のレコードAとレコードBを破棄し，入力されたレコードAを保持します。
    
  • レコードBの場合
    入力されたレコードBで，レコードバッファーに保持していた既存のレコードBを上書きします。
    

抽出レコード生成では，抽出条件が成立したレコードを結合して，抽出レコードを生成します。抽出レコード生成の流れを次に示します。

1. 結合するレコードの選択
   抽出条件が成立したレコードの中から，抽出レコードとして結合するレコードを選択します。結合するレコードは，selectタグのsource属性で指定します。
   
2. 抽出レコードの生成
   手順1.で選択したレコードを結合して，抽出レコードを生成します。
   

生成される抽出レコードには，extractionタグのname属性で指定した抽出条件名が入力されたフィールドが追加されます。

• 抽出条件名が入力されるフィールド名：「condition」
• ほかのフィールド：「<抽出対象レコード名>_<フィールド名>」

抽出レコードの例を次の図に示します。

図11-18　抽出レコードの例

この例では，レコードAとレコードCを結合して，抽出レコードとして，新たなレコードEが生成されます。