ストリームデータ処理基盤 uCosminexus Stream Data Platform - Application Framework アプリケーション開発ガイド

[目次][索引][前へ][次へ]

executeStreamFunc(Collection<Object[]>[] ObjectArrayCollection,Timestamp timestamp)メソッド

形式

abstract List<Object[]> executeStreamFunc(Collection<Object[]>[] ObjectArrayCollection,Timestamp timestamp)

説明

外部定義ストリーム間演算関数の処理を実装する抽象メソッドです。

SDPサーバは,クエリ定義で指定した外部定義関数の入力ストリームにタプルが到着したときに,このメソッドを実行します。

パラメーター

ObjectArrayCollection

Collection<Object[]>[]型で,入力ストリーム別に,同時刻に発生したタプルが格納されたデータオブジェクト配列を指定します。

timestamp

Timestamp型で,ストリームデータのタプルの時刻情報を指定します。

例外

なし。

戻り値

出力ストリームのタプルが格納されたデータオブジェクト配列のリスト(List <Object[]>型オブジェクト)。

注意事項

一つの入力ストリームに対して複数のタプルが入力された場合,そのタプル間の順序は不定となります。メソッドでは,引数で渡されるタプルの順序に依存しない処理を実装する必要があります。