Creating StreamBase Input Data Source

The StreamBase 7.1 connector allows connection to the StreamBase CEP engine instance on a real-time streaming basis.

To use the StreamBase connector, Streambase 7.1 redistributable must be installed.

Refer to http://www.streambase.com/products/streambasecep/download-streambase/ for more information in downloading StreamBase products.

Steps:

1.    In the New Data Source page, select Input > StreamBase 7.1 in the Connector drop-down list.

 

2.     Enter the following properties:

Property	Description
Primary URL	Primary URL of the StreamBase 7.1. Default is sb://localhost:100000.
Secondary URL	Secondary URL of the StreamBase 7.1. NOTE: More than two StreamBase server URLs can be specified by comma separation.
User Id	User Id that will be used to connect to StreamBase 7.1.
Password	Password that will be used to connect to StreamBase 7.1.

 

3.     Click  to return a list of updated streams. Selection of a stream returns a list of available Id columns for the stream.

This populates the Id Column with the set of columns from the schema of type sym and the text array such as Character/Boolean/GUID, etc. The selected Id Column can be used to select a key column to manage data updates and inserts.

NOTE: Every message definition needs a text column to be defined as the Id column. By default, only the latest data will be loaded into memory.

Furthermore, a streaming time series window can be generated by creating a compound key with the Id Column, plus a separately specified Time Id column. This Time Id column can be from the source dataset, or alternatively automatically generated.

If the Time Id column is selected, then a scrolling time window can be specified.

For Automatic Time Id, define the Time Id Column Name.

As new data arrives from the subscription, new time slices will automatically be added, and old ones will be deleted.

If a new ID is received, a new row is added to the in-memory data set representing the StreamBase topic subscription. While if an existing ID is received, an existing row is updated.

4.     Enter the Predicate expression to force emission.

5.     The time zone of input parameters and output data is by default unchanged. Changing the time zone is supported through the Show in Timezone list box, based on the assumption that data is stored in UTC time and outputs are presented in the selected time zone.

6.     Select whether the parameters should be automatically enclosed in quotes, by selecting the Enclose parameters in quotes check box.

7.     Select the Reset Data on Reconnect check box to flush out the stale data and reload data after reconnection.

8.     Click . The new data source is added in the Data Sources list.