

API Docs - v1.0.11

Sinkmapper

This section explains how to map events processed via Siddhi in order to publish them in the binary format.

Syntax

@sink(..., @map(type="binary")

Examples EXAMPLE 1

@sink(type='inMemory', topic='WSO2', @map(type='binary')) define stream FooStream (symbol string, price float, volume long);

This will publish Siddhi event in binary format.

This extension is a binary input mapper that converts events received in binary format to Siddhi events before they are processed.

Syntax

@source(..., @map(type="binary")

Examples EXAMPLE 1

@source(type='inMemory', topic='WSO2', @map(type='binary'))define stream FooStream (symbol string, price float, volume long);

This query performs a mapping to convert an event of the binary format to a Siddhi event.