Skip to content

API Docs - v1.0.12

Sinkmapper

binary (Sink Mapper)

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.

Sourcemapper

binary (Source Mapper)

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.