Skip to content

API Docs - v2.0.5

Tested Siddhi Core version: 5.1.13

It could also support other Siddhi Core minor versions.

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.