<adp:OutputAdaptorDefinition name="OutputAdaptor1" charCode="MS932" lineFeed="CR_LF">
 
    <!-- 受信用CB定義 -->
    <cb:ReceiveCBDefinition class="jp.co.Hitachi.soft.sdp.adaptor.callback.sendreceive.ReceiveCBImpl" name="receiver">
        <cb:streamInfo name="QUERY" querygroup="Inprocess_QueryGroupTest"/>
    </cb:ReceiveCBDefinition>
 
    <!-- データ編集用CB定義 -->
    <cb:DataEditCBDefinition class="jp.co.Hitachi.soft.sdp.adaptor.callback.dataedit.mapping.OutputMappingCBImpl" name="editor1">
        <!-- マッピング定義 -->
        <map:MappingDefinition ioType="OUTPUT">
            <map:source>
                <map:streams>
                    <map:stream name="QUERY" querygroup="Inprocess_QueryGroupTest">
                        <map:column name="sendip"      type="STRING"/>
                        <map:column name="subtime"     type="LONG"/>
                    </map:stream>
                </map:streams>
            </map:source>
            <map:target/>
            <map:intermediate>
                <map:mappings source="QUERY" querygroup="Inprocess_QueryGroupTest" target="RECORD1">
                    <map:map source="sendip"      target="SEND_IP"/>
                    <map:map source="subtime"     target="SUBTIME"/>
                </map:mappings>
            </map:intermediate>
        </map:MappingDefinition>
    </cb:DataEditCBDefinition>
 
    <!-- データ編集用CB定義 -->
    <cb:DataEditCBDefinition class="jp.co.Hitachi.soft.sdp.adaptor.callback.dataedit.mapping.InputMappingCBImpl" name="editor2">
        <!-- マッピング定義 -->
        <map:MappingDefinition ioType="OUTPUT">
            <map:source/>
            <map:target>
                <map:records>
                    <map:record name="RECORD2" >
                        <map:field name="SEND_IP"        type="STRING"/>
                        <map:field name="SUBTIME"        type="LONG"/>
                        <map:field name="GET_TUPLE_TIME" type="TIMESTAMP"/>
                    </map:record>
                </map:records>
            </map:target>
            <map:intermediate>
                <map:mappings source="RECORD1" target="RECORD2">
                    <map:map source="SEND_IP"        target="SEND_IP"/>
                    <map:map source="SUBTIME"        target="SUBTIME"/>
                    <map:map function="getTupleTime" target="GET_TUPLE_TIME"/>
                </map:mappings>
            </map:intermediate>
        </map:MappingDefinition>
    </cb:DataEditCBDefinition>
 
    <cb:OutputCBDefinition class="jp.co.Hitachi.soft.sdp.adaptor.callback.io.dashboard.DashboardOutputCBImpl" name="outputer">
        <!-- ダッシュボード出力コネクタ定義 -->
        <docon:DashboardOutputConnectorDefinition Record="RECORD2">
            <docon:RecordHoldTime DateReference="LAST_UPDATE" RecordTime="0" DateFieldPosition="3" />
            <docon:DataProcessingDefinition Name="HistoryRecorder">
                <docon:HistoryRecorder/>
            </docon:DataProcessingDefinition>
        </docon:DashboardOutputConnectorDefinition>
    </cb:OutputCBDefinition>
 
</adp:OutputAdaptorDefinition>

この記述例では，ストリームデータの集計・分析結果のデータを出力アダプター「OutputAdaptor1」でダッシュボードへ出力します。

出力アダプター「OutputAdaptor1」では，次の表に示す処理を実施します。なお，括弧内は，アダプター構成定義ファイル内での定義名です。

コールバックの種類	コールバックでの処理
受信用コールバック（受信用CB定義）	タプル受信（出力ストリーム定義）
編集用コールバック（編集用CB定義）	レコードとストリーム間のマッピング（マッピング定義）
	レコード間のマッピング（マッピング定義）
	フォーマット変換（フォーマット変換定義）
送信用コールバック（送信用CB定義）	ダッシュボードへの出力（ダッシュボード出力コネクター定義）

出力アダプター「OutputAdaptor1」の各定義での定義内容を次に示します。

• 出力ストリーム定義の内容
  クエリグループ「Inprocess_QueryGroupTest」の出力ストリーム「QUERY」からタプルを受信して，共通形式レコードに変換します。
  
• マッピング定義の内容
  レコードとストリーム間のマッピングで，出力ストリームの形式に対応した共通形式レコードと，フォーマット変換で入力する共通形式レコードとを関連づけます。
  また，レコードの間のマッピングで，rstreamの最新の結果がどのレコードかがわかるように，タプルの時刻を取得（mapタグのfunction属性にgetTupleTimeを指定）して共通形式レコードに出力します。
  
• フォーマット変換定義の内容
  マッピングで出力された共通形式レコードを出力形式レコードに変換します。
  
• ダッシュボード出力コネクター定義の内容
  フォーマット変換で出力された出力形式レコードに対し，レコード保持期間（RecordHoldTimeタグのRecordTime属性）に0を設定し，最新の結果以外のレコードをすべて削除するようにします。
  
• アダプター構成定義ファイルで指定するストリーム名
  アダプター構成定義ファイルで指定するストリーム名は，クエリ定義ファイルで指定した内容と合わせてください。
  
  • 入力ストリームの場合
    クエリ定義ファイルのregister stream句で指定したストリーム名「STREAM」が，アダプター構成定義ファイルで指定する入力ストリーム名となります。
    
  • 出力ストリームの場合
    クエリ定義ファイルのregister query句で指定したクエリ名「QUERY」が，アダプター構成定義ファイルで指定する出力ストリーム名となります。
    
  この記述例の場合のクエリ定義ファイルを次に示します。この定義ファイルでは，送信先IPアドレス（sendip）ごとに，直近1分間の中での送受信時間（subtime）の最大値を求め，その結果をrstreamで出力する処理を記述しています。
  

  register stream STREAM(sendip VARCHAR(15),receiveip VARCHAR(15),sendport INT,receiveport INT,uri VARCHAR(255),subtime BIGINT,times TIMESTAMP(9));
   
  register query QUERY rstream(
    select STREAM.sendip as sendip, max(STREAM.subtime) as subtime
    from STREAM[RANGE 1 MINUTE]
    group by STREAM.sendip);

  クエリの定義については，マニュアル「uCosminexus Stream Data Platform - Application Framework アプリケーション開発ガイド」を参照してください。