実行環境の構成要素

Source Operation

• Streamingデータを生成するオペレーション

• 生成されたStreamingデータはTupleと呼ぶ

• TupleはJSON形式で表現される

Sink Operation

• Streamingデータを外部へ出力するオペレーション

• Tupleを受け取る

UDSF（User-Defined Stream-Generating Functions）Operation

• Streamingデータの変換を行うオペレーション

• Tupleを受け取る

• 変換されたStreamingデータをTupleとして出力する