Changelog

This page details new additions to the stream processor engine in major release versions of Fluent Bit.

Fluent Bit v1.2

Release date: June 27, 2019

Added the ability to use nested maps and sub-keys to perform conditions and key selections. For example, consider the following record:

{
  "key1": 123,
  "key2": 456,
  "key3": {
    "sub1": {
      "sub2": 789
    }
  }
}

Now you can perform queries like:

SELECT key3['sub1']['sub2'] FROM STREAM:test WHERE key3['sub1']['sub2'] = 789;

For conditionals, added the new @record functions:

Function	Description
`@record.time()`	Returns the record timestamp.
`@record.contains(key)`	Returns `true` or false if `key` exists in the record, or `false` if not.

Added IS NULL and IS NOT NULL statements to determine whether an existing key in a record has a null value. For example:

SELECT * FROM STREAM:test WHERE key3['sub1'] IS NOT NULL;

Release date: May 09, 2019

Added the stream processor to Fluent Bit.