Sinks

Streaming MASSIF Sinks

We define some prebuilt sinks that allow you to capture that processed data out of the platform.

PrintSink

Simply prints the output to the console.

PrintSink example:

SinkInf printSink = new PrintSink();
PipeLineComponent sinkComp = new PipeLineComponent(printSink,null);

As the Sinks have no more output components, the ouputs can be null.

HTTPPostSink

Allows to send to results to a remote HTTP server through a HTTP Post request. Parameters:

• url: the URL of the remote server

HTTPPostSink example:

String url=...
SinkInf postSink = new HTTPPostSink(url);
PipeLineComponent sinkComp = new PipeLineComponent(postSink,null);

WebSocketClientSink

Opens a websocket client such that it can send data to a websocket server

WebSocketServerSink

Opens a websocket server, such that it can send data to one or more websocket clients