ストリームデータ処理基盤 uCosminexus Stream Data Platform - Application Framework アプリケーション開発ガイド
カスタムアダプターがSDPサーバに対してタプルを送信するために使用するインタフェースです。
タプルを送信するには,putメソッドを使用します。putメソッドには,複数のタプルをまとめて送信するメソッドと,単一のタプルを送信するメソッドの2種類があります。
StreamInputインタフェースのメソッド一覧を次の表に示します。
戻り値 | メソッド名 | 機能 |
---|---|---|
void | close() | 入力ストリームとの接続を閉じます。 |
int | getFreeQueueSize() | 入力ストリームキューの空きサイズを取得します。 |
int | getMaxQueueSize() | 入力ストリームキューの最大サイズを取得します。 |
boolean | isStarted() | データソースモードの場合に,入力ストリームが新たなストリームデータの受付を開始しているかどうかを確認します。 |
void | put(ArrayList<StreamTuple> tuple_list) | 複数のタプルを送信します。 |
void | put(StreamTuple tuple) | 単一のタプルを送信します。 |
void | putEnd() | 入力ストリームに対して,ストリームデータ入力が終了したことを通知します。 このメソッドによって入力完了を通知したあと,クエリグループの再開前にputメソッドやputEndメソッドを実行した場合は,例外が返されます。 |
なし。
All Rights Reserved. Copyright (C) 2010, 2014, Hitachi, Ltd.