StreamBase Component Exchange (SBX)

The StreamBase Component Exchange (SBX) is the Complex Event Processing (CEP) industry’s first developer community that allows users to download and distribute reusable components. Developers and business users around the world can now exchange ideas and collaborate freely to build the next generation of event processing applications. If you have any questions or comments about the SBX or its content, please send email to sbase-jira-sbx@tibco.com. For instructions on submitting components to the exchange please see the developer notes.

How to Download and Load a Component

Developers can download components from StreamBase Studio’s Component Exchange Menu item. Once downloaded, components are imported into the platform’s integrated development environment where users can collaboratively extend their existing applications and test new ideas. Components require an installation of StreamBase CEP. If you do not already have StreamBase CEP, go ahead and download StreamBase CEP now.

Video Tutorial

To learn more about downloading components and importing them into StreamBase, watch the short tutorial here.

Title: Alarm Clock
Version: 1.0
SB Release: 6.6
Summary: Generates a signal every day at the same time
Description: This application is designed to generate a signal at a specific time every day. Note that this time can be set and reset.
Title: Analyzing StreamBase Server profile data
Version: 1.5
SB Release: 6.6.9
Summary: StreamBase applications to read and summarize server profile data
Description: This component provides StreamBase applications that read and summarize performance profile data. A provided bash script makes it easy to get profile data summarized from the command line.
Title: Apple Push Notification Adapter and iOS application
Version: 1.1
SB Release: 7.1
Summary: Apple Push Notification StreamBase Output Adapter and iOS application
Description: This is an example of a StreamBase output adapter that will send an Apple Application Push Notification to an iPhone or iPad application. The respective Apple demo application must be installed and run to register and get user permission to receive push notifications. iOS Objective-C source code is included and a complete presentation on how to activate and run this application. To run this example, you will need to obtain an authentication certificate, device code and apple mobileprovision file needed to sign and run the iOS application. Uses the Google JavaPNS library.
Title: Benford Analysis
Version: 1.0
SB Release: 7.0
Summary: A component to perform first digit Benford’s Law analysis
Description: Performs first digit Benford’s Law analysis on data provided in a CSV formatted file. This analysis is often used in accounting for fraud detection, but can be used for other purposes.
Title: Binomial Model – Option Pricing
Version: 1.5
SB Release: 6.4
Summary: Prices Asian Call Options, European Call Options and European Put Options through the Binomial Pricing Model.
Description: The binomial options pricing model is a numerical approach for the valuation of options, as first proposed by Cox, Ross and Rubinstein (1979). Essentially, the model uses a “discrete-time” to trace the evolution of the underlying price via a binomial lattice (tree), for a given number of time steps between the valuation date and the option’s expiration.
Title: Bollinger Band Signaling Algorithm
Version: 1.0
SB Release: 6.4
Summary: Automated trading simulation using Bollinger Bands trading indicator.
Description: Bollinger Bands are a technical analysis tool that can be used to measure the height or depth of a price relative to previous trades. Bollinger Bands consist of a middle band being an N-period simple moving average (SMA), an upper band at +K times the standard deviation of the simple moving average (SMA+K*sigma), and a lower band at -K times the standard deviation of the simple moving average (SMA-K*sigma).
Title: Calling a RESTful Web Service
Version: 1.1
SB Release: 7.1
Summary: RESTful Web Service calls using Apache Jersey
Description: This is a simple demo of calling a RESTful Web Service using Apache Jersey and javax.ws.rs as a web service client. You must install a (free) GlassFish server and run the web service on that platform. The StreamBase application makes simple calls to set and get a string field.
Title: Calling Python from StreamBase
Version: 1.2
SB Release: 6.4
Summary: Performs calculus operations in Python.
Description: Requires: Python; the NumPy Python library; C compiler to build NumPy
The purpose of this module is to call a process external to StreamBase to handle certain calculations. The module demonstrates calling a Python script that loads the NumPy math library to perform either integration or differentiation of a polynomial. To use this module, you must have a supported version of Python, as described in the API Guide in the StreamBase documentation, and you must obtain and install the NumPy library from http://numpy.scipy.org.
Title: Client Connectivity Plug-in for Eclipse
Version: 1.0
SB Release: 6.5
Summary: Eclipse plug-in providing high-level connectivity to input and output streams of a StreamBase application
Description: This Eclipse plug-in may be used in Rich Client Platform applications for accessing input and output streams of a StreamBase application. The plug-in includes a dequeue thread and an enqueue thread. It also defines extension points which can be used to declare the fully qualified names of the output streams to dequeue, and how to receive the dequeued tuples.
Title: Communicating with Insteon and X10 Devices
Version: 1.0
SB Release: 7.3
Summary: An adapter that allows communicating with Insteon and X10 devices
Description: This component provides two StreamBase CEP output adapters; one for Insteon devices, and one for X10 devices, using an insteon HUB
Title: Connectivity to Gnip
Version: 1.0
SB Release: 7.3
Summary: Provides an adapter to consume social media data from Gnip
Description: The StreamBase GNIP Adapter connects a GNIP server to a StreamBase Server. The GNIP Adapter connects to a GNIP server and processes all Twitter streams that the GNIP server subscribes to, parsing its results and sending them into StreamBase for further processing.
Title: Currency Arbitrage
Version: 1.0
SB Release: 7.2
Summary: Calculates currency arbitrage opportunities for streaming FX data.
Description: The currency arbitrage operator creates a directed graph at runtime where the vertices represent currencies and edges (and their respective edge weights) represent the conversion rate between currency pairs. It then finds arbitrage opportunities in real-time, by finding cycles in the graph.
Title: Data Cache Framework
Version: 1.5
SB Release: 6.6
Summary: Data Cache provides drop-in snapshot/delta views over StreamBase table data. Java and .NET Data Cache bindings are included, as well as GUI examples.
Description: The Data Cache Framework component provides drop-in EventFlow modules that provide snapshot/delta streams over StreamBase table data. This component includes working source for .NET (3.5) and Java (J2SE 1.5 or higher) Data Cache services, suitable for rapid development of user interfaces to visualize table data within a StreamBase application. Included are three Java GUI examples (in Java Swing, Eclipse JFace, and JFace Data Binding), and one .NET WPF GUI that use this component’s framework.
Title: Datasports DirectoryWatcher Adapter
Version: 1.0
SB Release: 7.1
Summary: Watches a specified directory for file system events (create, update, rename, delete)
Description: The Datasports DirectoryWatcher adapter is a general-purpose solution to perform a common task: watch a directory structure and raise events (in the form of StreamBase tuples) when changes occur in that directory structure. These changes include creation, update, deletion, and re-naming of files and directories. The adapter makes use of the JNotify library, a cross-platform freeware Java library which uses a set of native libs to hook into the OS on Windows, Linux, and Mac OS. A redistributable version of JNotify is included.
Title: Datasports WebServiceListener Adapter
Version: 1.1
SB Release: 7.1
Summary: Exposes a WebService interface with 2 methods that can be called remotely and then processed as StreamBase events
Description: The Datasports WebServiceListener adapter shows how to create an input adapter that exposes a webservice. It is meant as a guide or tutorial used in conjunction with the associated article. The adapter features a configurable URI for the webservice, optional run time control interface, and a webservice that exposes two methods, with a corresponding output port for each. A remote call to either webmethod results in a tuple being sent out from the corresponding output port.
Title: Delay Operator
Version: 1.2
SB Release: 6.4
Summary: Delays the transmission of data along a stream by a specified amount of time.
Description: The Delay operator postpones sending data along a stream for a specified amount of time. This sample application includes a DelayFiveSeconds operator, to demonstrate delaying the stream by a constant amount of time, and a DelayVariable operator, to demonstrate delaying by a variable amount of time. Example uses might include an application that needs to load a set of trading parameters prior to receiving market data, or traders may want to build up a trading metric (like the beta of a portfolio) by analyzing market data over a specified interval before initiating their trading strategies.
Title: Duplicate Tuple Eliminator
Version: 1.0
SB Release: 6.6
Summary: Eliminates tuples whose fields are all the same, excluding specified fields.
Description: This pass-through Java operator emits only unique tuples, when filtering by a specific field value (such as unique tuples for each market data security symbol). Tuples are considered the same if all their fields have the same values. You can specify fields to exclude from the comparison.
Title: Dynamic Log Level Modification
Version: 1.0
SB Release: 7.3
Summary: Dynamically change the log level of a running StreamBase server instance
Description: This component demonstrates how to dynamically change the log level of a running StreamBase server instance when using the default Logback logging back end. Note that the StreamBase-supported Log4j version (1.2) does not automatically enable JMX monitoring by default, as the org.apache.log4j.jmx package is not of production quality. Hence, instructions for dynamically changing the log level when using Log4j are not included in this component.
Title: Dynamic RSS Reader
Version: 1.0
SB Release: 6.6
Summary: RSS Reader adapter with support for adding and remove feeds at runtime
Description: Similar to the RSS Adapter that ships with StreamBase, but adds support for adding, removing and listing RSS feeds at runtime.
Title: Earthquake Monitor
Version: 1.3
SB Release: 7.1
Summary: Real-time tracking and plotting of earthquakes worldwide from IRIS
Description: This component monitors recent earthquakes from the Incorporated Research Institutions for Seismology (IRIS). All earthquakes that took place in the last 30 days with magnitude >= 4.0 are loaded, and then real-time tracking begins, with the application reporting daily metrics and emitting warnings of extremely large earthquakes. Additionally, all seismic activity can be plotted on demand. Two applications are provided, one that tracks worldwide, one that can narrow down on a given latitude/longitude and radius.
Title: Erlang in StreamBase
Version: 1.0
SB Release: 7.0
Summary: Erlang integration with StreamBase using Erjang
Description: This is a sample/demonstration project showing how the Erjang implementation of Erlang could be exposed to StreamBase. This is a project made in support of a presentation made to the London Erlang User Group on 20th of April, 2011.
Title: Examples of Using MATLAB in StreamBase
Version: 2.0
SB Release: 7.2
Summary: A number of examples that show how to use MATLAB with StreamBase
Description:

Requires: “MATLAB Adapters” v2.0

Several examples are provided including: Black Scholes option pricing, Cornish Fisher VaR calculations, foreign exchange European options pricing, portfolio evaluation, QR matrix decomposition, a random matrix generator, a numerical integration example and two plotting examples.

Title: Examples of Using R in StreamBase
Version: 2.1
SB Release: 6.6
Summary: Examples that demonstrate how to communicate with R from within StreamBase
Description: Requires: “R Adapters” component v2.1
A number of example applications using R are provided: computing normality tests, generating random variables, probit regressions, bond pricing, data frame construction and time series predictions. The purpose of these examples is to demonstrate how to use R when it is embedded within StreamBase.
Title: Examples of Using TERR in StreamBase
Version: 1.0
SB Release: 7.3
Summary: Examples that demonstrate how to communicate with TERR from within StreamBase
Description: Requires: “TERR Adapters” component v1.0
A number of example applications using TERR are provided: computing normality tests, generating random variables, bond pricing, data frame construction and time series predictions. The purpose of these
examples is to demonstrate how to use TERR when it is embedded within StreamBase.
Title: Extreme Value Classification Operator
Version: 1.1
SB Release: 6.4
Summary: Classifies incoming data as being either an extreme value or a regular value depending on the underlying distribution of the data.
Description: The extreme value operator determines whether data being passed to it is within the regular interval or is “extreme valued.” The determination of whether data is extreme valued depends on a three parameters you must set when using this component: Threshold, Tail, and Distribution.
Title: Fast Flower Delivery EPTS Use Case
Version: 1.1
SB Release: 6.5
Summary: Implements the Fast Flower Delivery use case from the Event Processing in Action book.
Description: This component represents an implementation of the Fast Flower Delivery use case conceived by members of the Event Processing Technical Society, and described in details in the Event Processing in Action book by Opher Etzion and Peter Niblett (ISBN 9781935182214). The specification is available in Appendix B, and a copy of the specification is included in this component as specification.pdf.
Title: Fast LiveView Feedsim publishing
Version: 1.2
SB Release: 7.4
Summary: Publishes feed simulation data as fast as possible to LiveView.
Description: This component provides StreamBase applications that take a feed simulation file designed for a LiveView table and, by using a feedback loop, adjust the publish rate to be as high as possible without data queueing anywhere in the table.
Title: Feed Simulator ITCH 3.1 Reader Plug-in
Version: 1.0
SB Release: 6.6.2
Summary: Feed Simulator Reader Plug-in that supports ITCH 3.1 formatted files
Description: This component provides a Feed Simulator Reader Plug-in class that reads NASDAQ TotalView ITCH 3.1 formatted files. Both uncompressed and GZIP compressed files are supported. A sample Feed Simulator file that emits messages based on ITCH timestamps is provided (using a sample ITCH 3.1-format data file), as well as a trivial sample application.
Title: Feed Simulator Market Factory Reader Plug-in
Version: 1.0
SB Release: 6.5.8
Summary: Feed Simulator Reader Plug-in for reading Market Factory formatted historical data files
Description: This component provides a Feed Simulator Reader Plug-in class that reads Market Factory historical data file format. Uncompressed, bz2, and GZIP compressed files are supported. A sample Feed Simulator file that reads a fictitious data file is provided, as well as a trivial sample application.
Title: Feed Simulator Regular Expression Reader Plug-in
Version: 1.0
SB Release: 6.5.8
Summary: Feed Simulator Reader Plug-in that does regular expression parsing of files
Description: This component provides a Feed Simulator Reader Plug-in class that reads file formats that can be parsed with a regular expression. Both uncompressed and GZIP compressed files are supported. A sample Feed Simulator file that parses two different file formats onto two different streams is provided, as well as a trivial sample application.
Title: FIFA World Cup(tm) Sentiment Analysis
Version: 1.0
SB Release: 6.5
Summary: Basic sentiment analysis application analyzing twitter tweets about the 2010 FIFA World Cup(tm)
Description: Performs rudimentary sentiment analysis on tweets that pertain to the 2010 World Cup. It then demonstrates how to use trending indicators (Bollinger Bands and Percent R) on top of the sentiment analysis.
Title: FIX Message Latency Benchmark Application
Version: 1.0
SB Release: 7.1
Summary: Demonstrates a sensible methodology for gathering FIX message processing latency times in the StreamBase FIX adapter
Description: Demonstrates a sensible methodology for gathering FIX message processing latency times in the StreamBase FIX adapter.
Title: FIX Message Throughput Benchmark Application
Version: 1.0
SB Release: 7.1
Summary: Demonstrates a sensible methodology for gathering FIX message throughput in the StreamBase FIX adapter
Description: Demonstrates a sensible methodology for gathering FIX message throughput in the StreamBase FIX adapter.
Title: FIX Venue Simulator
Version: 1.0
SB Release: 7.2
Summary: FIX Venue Simulator for use in Integration and Performance Testing
Description: This application is a FIX venue simulation that will receive and handle FIX order requests, including New (Day, IOC), Cancel, Replace.
Orders are partially filled at a controllable rate. This tool has been used in testing and performance tuning. A demonstration mode is included.
Title: GenerateClientAPICode
Version: 1.0
SB Release: 6.6
Summary: Generator of Java code for interacting with a StreamBase application’s input and output streams via the Java Client API.
Description: GenerateClientAPICode generates customizable Java code for interacting with a StreamBase application’s input and output streams. The generated code includes:(1) Stream names as final static String constants (for input and output streams);
(2) Field names as final static String constants
(3) Methods to create and populate Tuples that will be sent to server-side input streams
(4) Methods to turn Tuples received from server-side output streams into simple, record-like Java objects

The utility is based on templates which include VTL (Velocity Template Language) directives. This utility helps avoid the drudgery in writing and maintaining all that by hand, but – more importantly – automatically synchronizes client code with the server. In contrast, client-code maintained by hand can easily become out-of-sync when changes are only made server-side, and that leads to hidden runtime regressions in the client.

Note: See the READ_ME.pdf file if running the utility in a pre-6.6 version of Studio.

Title: Graphing Example: Stock Charting Demo
Version: 1.1
SB Release: 7.1
Summary: Stock charting demo with a model-view-controller pattern
Description: Implements a Java Swing Charting Demo with a model-view-controller pattern, using JFreeChart.
Title: Handling Blocking Queues
Version: 1.1
SB Release: 6.6
Summary: Demonstrates how to deal with queues in StreamBase
Description: This component has two functions. The first uses Monte Carlo simulation to demonstrate how to deal with queues (or blocking) in event-driven applications. A European option is written on an asset that moves according to a Student-T distribution (or a distribution with a fatter tail then the Normal). The option uses streaming stock prices for its initial stock quote and thus some of the quotes must be discarded so that we can be assured that we are using the most recent stock price in pricing. The second function is to provide a general framework with which to write programs that may have components that block.
Title: JMS XML-formatted TextMessages
Version: 1.0
SB Release: 7.3
Summary: Provides custom converter classes for the JMS adapter for processing XML-formatted TextMessages
Description: This component demonstrates the use of the JMS Reader and JMS Writer embedded adapters with XML-formatted TextMessages. The default JMS TextMessage converters (provided with the adapter) are used to convert incoming JMS messages to XML strings. These converters only require StreamBase and generic JMS classes, so they can be used with multiple JMS providers. Example configurations for Tibco EMS and ActiveMQ are included in this project.
Title: Jython Adapters
Version: 1.1
SB Release: 6.6
Summary: Adapters that allow Jython to run inside StreamBase
Description: This module is a Java-Python interface for StreamBase, which allows you to run Jython (http://www.jython.org/) inside StreamBase applications.
Title: Jython Examples
Version: 1.1
SB Release: 6.6
Summary: Examples that demonstrate how to use the Jython Adapters component
Description: Requires: “Jython Adapters” v1.1
This component includes a number of application examples that demonstrate using the Jython Adapters component
Title: kdb+ QDBC Adapters
Version: 1.1
SB Release: 7.0
Summary: Adapters that integrate StreamBase with kdb+ from KxSystems via QDBC
Description: Adapters that allow issuing queries against a kdb+ (http://www.kx.com/) instance using QDBC.
Title: Latency Caliper
Version: 1.1
SB Release: 6.5
Summary: A simple module to help measure latency.
Description: The LatencyCaliper module can be used to measure the time it takes for a tuple to traverse a portion of an EventFlow application’s graph.
Title: Least Squares Fitting
Version: 1.0
SB Release: 6.4
Summary: Fits an nth degree polynomial to data using the method of least squares.
Description: Demonstrates complex statistical analysis. Specifically, this component allows you to perform a non-linear least squares fit (called polynomial regression).
Title: Linear Regression
Version: 1.1
SB Release: 6.4
Summary: Performs a standard simple linear regression in StreamBase.
Description: This component performs a simple linear regression with only one regressor between the daily stock prices of a stock index and one of its components. Daily stock prices were downloaded for the month of August, 2009 for both the Dow Jones Index and one of its components, Coca-Cola, and the daily prices are stored in the two CSV files provided. The application uses the CSV files to read the stock prices for the month, gathers the readings together, and then regresses the component on the index. The alpha (the y-intercept) and the beta (the slope) of the regression are then returned.
Title: List Operations
Version: 1.3
SB Release: 6.4
Summary: Provides a number of useful list operations.
Description: This component provides a number of list operations implemented as StreamBase applications and custom Java functions. The functions support various mathematical operations on lists. The applications makes it easy to collect a number of tuples into a list and apply operations to all the elements in a list.
Title: LiveView Chat Room
Version: 1.0
SB Release: 7.3.10
Summary: Use StreamBase LiveView as a chat room.
Description: This sample demonstrates how to use StreamBase LiveView as a chat room. Instant messages from users are sent to the ‘Messages’ table via LiveView Desktop using the ‘Send Tuple’ View functionality. Messages can be shared between all users with access to the ‘Messages’ table. Messages may be filtered by room name (i.e. the ‘Lobby’ field), using the ‘Perspectives’ functionality of the LiveView Desktop Workspace.
Title: LiveView Configuration Files for TIBCO ActiveSpaces Demos
Version: 1.0
SB Release: 7.4
Summary: Connects the TIBCO ActiveSpaces Paint and TIBCO ActiveSpaces Operations Demos with TIBCO LiveView
Description: This component demonstrates connectivity between TIBCO ActiveSpaces and TIBCO LiveView. It contains LiveView configuration files for the ActiveSpaces Paint and ActiveSpaces Operations Demos as well as preconfigured launchers for LiveView and both demos.
Title: LiveView Desktop Custom View – Active Spaces Paint
Version: 1.0
SB Release: 7.4
Summary: Integrates an ActiveSpaces Paint Demo into LiveView as a custom view
Description: This component adds a custom view to LiveView Desktop which brings the ActiveSpaces Paint demo to Desktop. It can also execute a query against the drawing’s shape data to display a subset of the shapes.
Title: LiveView Plane Tracker
Version: 1.0
SB Release: 7.3.9
Summary: Display airplane locations in real-time using the LiveView client API
Description: This component demonstrates how to display real-time positions of planes on a map. Using the LiveView Javascript API, maps are updated in real-time. The sample illustrates the real-time updates by displaying airplane locations which are fed in from the PlanesToLiveView C# client application and a Software Defined Radio (SDR). The C# client application and USB drivers for the SDR are provided separately, and are not bundled in this project.
Title: Mapping StreamBase LiveView Results
Version: 1.0
SB Release: 7.3
Summary: Sample web pages displaying query results from LiveView on maps
Description: This project is a StreamBase LiveView project that includes a LiveView Desktop workspace and two web pages displaying LiveView data points in real-time against either a Bing-powered map, or a LeafletJS/Maporama/TIBCO GeoAnalytics map.
Title: MATLAB Adapters
Version: 2.2
SB Release: 7.2
Summary: Adapters that provide MATLAB integration with StreamBase
Description: This module is a Java/MATLAB Interface for StreamBase, which allows you to run MATLAB (http://www.mathworks.com/) inside StreamBase applications, using the open source MATLAB control library (http://code.google.com/p/matlabcontrol/).
Title: Mortgage Calculator
Version: 1.1
SB Release: 6.4
Summary: This component calculates monthly mortgage payments.
Description: This module has two purposes:
1. To calculate mortgage payments.
2. To demonstrate how tuples are coded in Java.
The application in this module uses a custom Java function, payments(), which is defined in MortgageCalculator.java.
Title: Multiple LiveView Services Layers
Version: 1.0
SB Release: 7.4
Summary: How to use multiple LiveView services layers to increase throughput to clients.
Description: This component demonstrates how to use multiple LiveView services layers to increase total throughput to clients. The project uses 4 copies of an ‘Orders’ table, where access to each copy is provided by a separate services layer. Each of the 3 additional services layers connects to the data layer that is served by the base services layer.
Title: Multiple Regression
Version: 1.1
SB Release: 6.4
Summary: Performs multiple linear regression on a set of data.
Description: This component extends the capabilities of StreamBase to perform complex statistical analysis. Specifically, this component allows you to perform linear regression on a number of explanatory variables (called multiple linear regression).
Title: Nintendo Wii Remote Adapter
Version: 1.1
SB Release: 6.5
Summary: Use Wiiusej to integrate StreamBase and Nintendo Wii remotes.
Description: This component demonstrates using the Wiiusej library (http://code.google.com/p/wiiusej/) in a StreamBase application, allowing you to access Nintendo Wii Remote events.
Title: NVIDIA CUDA Black Scholes
Version: 1.0
SB Release: 7.0
Summary: NVIDIA CUDA Black Scholes demo integration with StreamBase
Description: This demo is based on the BlackScholes CUDA demo that ships with the NVIDIA SDK samples. The purpose of this demo is to demonstrate how to integrate CUDA C GPU kernels with StreamBase.
Title: Option Pricing using Monte Carlo
Version: 1.0
SB Release: 6.4
Summary: Performs a Monte Carlo simulation to price the Vanilla, Asian, and Lookback options.
Description: This module demonstrates how to price of both the Asian, Lookback, and Vanilla put and call options using a Monte Carlo method programmed in StreamBase. To price a Vanilla option, you do not need to simulate the price of the stock and thus, this is the easiest to compute. However, for both the Asian and Lookback options, the stock price must first be simulated before attempting to find the price of the option. Thus, for these options, we first attempt to approximate the stock price by geometric Brownian motion, and this is done using a feedback loop to compute the price of the stock on a fixed number of dates.
Title: Play back queries and data into LiveView
Version: 1.1
SB Release: 7.3.7
Summary: LiveView query/publisher playback example
Description: This component has a sample of how to replay data and queries that have been recorded from LiveView deployments. The playback rate is adjustable.
Title: Portfolio Pre-Trade Risk Simulator
Version: 1.1
SB Release: 6.5
Summary: Implements a simple pre-trade risk analysis by checking whether a prospective trade pushes the portfolio factors above specified risk limits
Description: Both a set of risk limits and a correlation matrix that maps trades to factors is given as input to the program (in the form of csv files). Then a portfolio is built up in such a way that the sum of each of the factors of the securities in the portfolio is not greater than the specified risk limits.
Title: Precompiled applications in multiple environments
Version: 1.0
SB Release: 7.4
Summary: How to run pre-compiled application archives in multiple environments.
Description: This component demonstrates how to create pre-compiled application archives (.sbars) that may be run in multiple environments, even if the application has operator/adapter property values that differ in each environment. The ‘FileName’ property for the CSV File Writer adapter is used as an example, where the resulting csv file name differs between QA and production environments.
Title: Pricing the American Put Option Using a Monte Carlo Simulation
Version: 1.0
SB Release: 6.5
Summary: Prices the American Put Option using a simulation method from Longstaff and Schwartz (2001)
Description: This module demonstrates how to price an American Put Option using a Monte Carlo simulation strategy published by Longstaff and Schwartz (2001). The method simulates the stock price over a number of trials and then regresses the payoff of the option on a set of orthogonal polynomials which are functions of the stock price. The program then computes both the price of the American put option price as well as its confidence interval from the input parameters.
Title: Provides tools for simulations with Brownian Motion
Version: 1.0
SB Release: 7.1
Summary: Brownian Motion & Brownian Prices
Description: Generates a Brownian bridge vector (or a vector of stock prices derived from a Brownian bridge) with the desired number of data points. Simulates the final, minimal and maximal values of Brownian motion (or prices derived from Brownian motion).
Title: R Adapters
Version: 2.2
SB Release: 7.2
Summary: This component contains various StreamBase to R adapters
Description: This module is a Java/R Interface for StreamBase, which allows you to run R (http://www.r-project.org/) natively inside StreamBase applications, using the open source JRI library (http://rosuda.org/JRI/).
Title: Redis Adapters
Version: 1.0
SB Release: 7.3
Summary: Adapters to send and receive messages from a Redis database, including streaming
Description: These adapters connect StreamBase to Redis (http://redis.io/) for input and output.
Title: Risk Management Demo
Version: 1.1
SB Release: 7.0
Summary: Simple Risk Management
Description: A simple Risk Management demo that will reject incoming orders if the trader organization hierarchy exceeds a configurable limit.
There are also example sbtest and streambase-JUnit tests provided for this application.
Title: RSS News Mailer
Version: 1.1
SB Release: 6.5
Summary: RSS News Mailer
Description: The RSS News Mailer EventFlow application sends filtered RSS feed news items to subscribers via email. The subscribers and the search terms used to select or filter their news stories are defined in the config.csv file. The RSS feeds are defined within the properties of the StreamBase RSS Reader Input Adapter. The RSS Reader Input Adapter awakens at a user-defined prescribed interval and reads the news feeds sending them downstream to be filtered by the prescribed search terms.
Title: Sentiment Analysis Engine
Version: 1.1
SB Release: 6.6
Summary: Implements a Sentiment Analysis Engine using LingPipe
Description: This module analyzes news articles and calculates the sentiment so that trading decisions can be made. It combines the ability of StreamBase to process large amounts of data very quickly, with the expertise of LingPipe for processing text using computational linguistics.
For more information on LingPipe, see http://alias-i.com/lingpipe/.
Title: Shared Adapter Example
Version: 1.0
SB Release: 7.1
Summary: Shows example of using the StreamBase 7.1 API class Operator.SharedObject for sharing state between a pair adapters along with container state management
Description: Sometimes StreamBase adapters need to share state. For example, StreamBase FIX input and output adapters share a common FIX connection. Other sharing patterns are common too. The example in this project demonstrates how to implement input and output adapters that access a common Java class called MySharedObject.
Title: Simple AMQP using RabbitMQ
Version: 1.1
SB Release: 7.0
Summary: Simple RabbitMQ adapter demonstrating AMQP integration with StreamBase
Description: This component demonstrates how to integrate with AMQP brokers such as RabbitMQ via the RabbitMQ client API. This simple integration demonstrates how to write direct (queue) or topic based AMQP producers and consumers with StreamBase.
Title: Simulates a Crossing Network
Version: 1.0
SB Release: 6.6
Summary: Exchange Simulator
Description: This component simulates a crossing network, a non-displayed trading venue where market orders are submitted and matched. Traders place both buy and sell orders for a particular security and specify the desired number of shares and a predetermined length of time. Buy orders are filled by sell orders (and vice versa) according to a variety of user defined filling policies. However, if the predetermined length of time expires before the entire order is filled, then the order abandons the system with only a partial fill.
Title: SLF4J Logback appender that sends log messages to a StreamBase Server
Version: 1.0
SB Release: 7.2
Summary: SLF4J Logback appender that sends log messages to StreamBase Server
Description: This component provides an SLF4J Logback appender that sends log messages to the configured StreamBase Server. A sample application that demonstrates its use is included.
Title: SNMP – Configuring StreamBase to send SNMP traps
Version: 1.0
SB Release: 7.0.1
Summary: How to configure StreamBase to send SNMP traps
Description: This component shows an example of how to configure StreamBase and Log4j to send SNMP traps from applications.
Title: SSL Proxy for C++ and .NET StreamBase Clients
Version: 1.0
SB Release: 7.3
Summary: Configure non-SSL-capable StreamBase .NET and C++ clients for 1-way SSL authentication
Description: This component demonstrates how to configure non-SSL-capable StreamBase C++ and .NET clients for 1-way SSL authentication. This solution requires the client-side installation of sTunnel, which serves as an SSL encryption wrapper between a remote client and server. In this sample, the ‘client’ is an sbc command-line client (C++), and the ‘server’ is the sbd instance.
Title: StreamBase .NET Operator Performance Benchmark
Version: 1.0
SB Release: 7.3
Summary: Demonstrates a sensible methodology for gathering performance data for the .NET Operator
Description: Demonstrates a sensible methodology for gathering performance data for the .NET Operator.
Title: Streambase Adapter for TUIO-compatible multitouch interfaces
Version: 1.2
SB Release: 6.5
Summary: A StreamBase Adapter to consume TUIO events from multitouch interfaces.
Description: This StreamBase project allows a user to access multitouch tangible interfaces using the TUIO protocol on StreamBase server. Use it as a starting point to develop your high-speed interactive system for motion tracking and sensing, remote control, hand gesture capturing, music creation etc. Unleash your imagination using best of breed low latency, high-availability, high-frequency technology used around the world.
Title: StreamBase Entitlements System
Version: 1.3
SB Release: 6.5
Summary: Entitlement system module for role and rights control for capital market applications.
Description: StreamBase Entitlements relies on a simple set of tables (requiring a database back-end, Oracle or PostgreSQL preferred) to store and maintain the user, role, entitlements information. At run time, the entitlements are kept in StreamBase in-memory Query Tables in a denormalized form that maps users directly to entitlements without having to traverse the intermediate roles. This form is efficient for entitlement checking on a per tuple-basis at high tuple rates.
Title: StreamBase Entitlements System UI (Eclipse Plug-in)
Version: 1.0
SB Release: 6.5
Summary: User Interface plug-in for use with the StreamBase Entitlements System.
Description: Requires: “Client Connectivity Plug-in for Eclipse”, Eclipse Plug-in Development Environment.
This Eclipse plug-in provides a re-usable user interface (UI) for the StreamBase Entitlements System component, implemented using Eclipse SWT/JFace. The UI lets end-users view and/or modify user, role and entitlements that are stored in the Entitlements System’s tables. A sample application is provided by the StreamBase Entitlements System UI Sample component.
Title: StreamBase Entitlements System UI Sample
Version: 1.0
SB Release: 6.5
Summary: Sample User Interface application for the StreamBase Entitlements System.
Description: Requires: “StreamBase Entitlements System UI (Eclipse Plug-in)”.
This Eclipse Rich Client Platform (RCP) application provides a simple, minimal user interface (UI) for the StreamBase Entitlements System, using the StreamBase Entitlements System UI (Eclipse Plug-in) component.
Title: StreamBase Feedback Enqueuer
Version: 1.0
SB Release: 7.2.1
Summary: Enqueue to applications as fast as possible, using queue sizes and network pushback as a rate limiter
Description: This component provides an application that will run a feed simulation configuration file and enqueue data as fast as the target application can accept data. Target application queue sizes are monitored and the enqueue rate is slowly increased until the queue sizes are between a configured limit. Network pushback is also monitored and will be identified.
Title: StreamBase JMX Adapter
Version: 1.0
SB Release: 7.0
Summary: StreamBase JMX adapter that provides general JVM information to a StreamBase Application
Description: This component provides an adapter that reads JVM operational information and provides this data to an EventFlow application. These statistics include GC collection times, heap sizes, thread information, etc.
Title: StreamBase JMX command line client
Version: 1.0
SB Release: 7.0
Summary: Java command line client to access StreamBase JMX
Description: This component provides a simple command line client that provides easy access to StreamBase JMX beans. A sample StreamBase application is included that can be used as a test target.
Title: StreamBase JMX Output Adapter
Version: 1.0
SB Release: 7.3
Summary: StreamBase JMX output adapter that creates JMX Mbeans that applications can set.
Description: This component provides an adapter that creates JMX Mbeans an application can set. Like any other MBean, these set values are readable by any JMX compatible client.
Title: StreamBase Monitor Adapter
Version: 1.3
SB Release: 7.0.2
Summary: StreamBase Monitor adapter that provides server profile data to applications
Description: This component provides an adapter that consumes StreamBase Server performance and profile statistics and provides them to an EventFlow application. These statistics include CPU usage, input and output rates, thread counts, and memory usage.
Title: TERR Adapters
Version: 1.0
SB Release: 7.3
Summary: This component contains various StreamBase to TERR adapters
Description: This module is a Java/TERR Interface for StreamBase, which allows you to run TIBCO(R) Enterprise Runtime for R (https://www.tibcommunity.com/community/products/analytics/terr) natively inside StreamBase applications, using the terrJava library.
Title: Thinning of a Poisson Process
Version: 1.0
SB Release: 6.4
Summary: Demonstrates how to simulate a thinned poisson process.
Description: Requires: SB_DelayOperator
This component first simulates the exponential inter-arrival times of a Poisson process by generating a random variable from the exponential distribution. It then feeds this number into the Delay operator to simulate the inter-arrival times. After the tuple leaves the Delay operator, the component simulates a uniform random variable to determine which of the four bins the event belongs to. At the end of the simulation, the number of events that belong to each bin is output from the stream, as well as a list of all the inter-arrival times. This produces five output streams, one for each of the four bins and
one for the list of inter-arrival times.
Title: TIBCO Hawk Demo using TIBCO LiveView
Version: 1.0
SB Release: 7.4
Summary: Demonstrates how to monitor remote systems via TIBCO Hawk and TIBCO LiveView
Description: The purpose of this component is to demonstrate how to monitor remote systems via TIBCO Hawk using TIBCO LiveView
Title: TIBCO tibbr Adapter
Version: 1.1
SB Release: 7.3.9
Summary: Adapter for posting and interacting with TIBCO tibbr
Description: This adapter allows posting to TIBCO tibbr, and perform other operations such as retrieving information about subjects, users and unread message counts.
Title: Trade Metric Tracker
Version: 1.0
SB Release: 6.4
Summary: A component that keeps track of trade metrics.
Description: Use this module to keep track of metrics associated with trades. After a new trader is added into the system, the returns associated with a specific trader are used as input into this module. A number of metrics are maintained and you can read the values of the metrics at any time. New traders can be added to the system, metrics associated with the trader can be reset, and the trader can be removed from the table.
Title: Tree Walk
Version: 1.1
SB Release: 6.6
Summary: This component demonstrates how to walk a tree in StreamBase
Description: This application walks a tree of nodes starting at a specified node and returns a sum of the weights of the specified node and all its descendants in the tree.
Title: Twitter Input/Output Adapters
Version: 2.0
SB Release: 7.3
Summary: Twitter input/output adapters for the StreamBase platform, based on twitter4j
Description: The Twitter input/output adapters allows a StreamBase application to interact with the Twitter service, using the twitter4j library from http://twitter4j.org/. It supports sending and receiving tweets as well as various other commands, including search, and filter.
Title: U.S. Securities and Exchange Commission EDGAR Monitor
Version: 1.0
SB Release: 6.6
Summary: Monitors SEC EDGAR filings
Description: Monitors most recent company filings and specific company filings from the EDGAR database (maintained and run by the U.S. Securities and Exchange Commission).
Title: Uncommons Maths
Version: 1.0
SB Release: 6.5
Summary: This component ports the Uncommons Maths library to StreamBase.
Description: This module implements the following capabilities found in the Uncommons Maths library:
Combination generator – identifies the set of combinations of a given length from a list
Permutation generator – identifies the set of permutations of a list
Seeding Strategies – implements a number of seeding strategies
Random Numbers – generates pseudo-random numbers using a variety of methods
Random Distributions – generates random numbers from a particular distribution
Utilities – implements various useful mathematical utilities
The application integrates a number of the unique capabilities of the library to StreamBase. For more information on the Uncommons Math Library, see https://uncommons-maths.dev.java.net/.
Title: Unit Testing Extensions for StreamBase 6.6
Version: 1.0
SB Release: 6.6
Summary: Extensions to the StreamBase Unit Testing API
Description: This component provides useful extensions and utility methods that wrap the StreamBase Unit Testing API to provide greater flexibility and ease of use.
Title: Unit Testing Extensions for StreamBase 7.0
Version: 1.0
SB Release: 7.0
Summary: Extensions to the StreamBase Unit Testing API
Description: This component provides useful extensions and utility methods that wrap the StreamBase Unit Testing API to provide greater flexibility and ease of use.
Title: Unit Testing Extensions for StreamBase 7.1
Version: 1.0
SB Release: 7.1
Summary: Extensions to the StreamBase Unit Testing API
Description: This component provides useful extensions and utility methods that wrap the StreamBase Unit Testing API to provide greater flexibility and ease of use.
Title: VWAP Algorithm
Version: 1.0
SB Release: 7.0
Summary: Simulates a market order VWAP execution algorithm using futures data
Description: This VWAP algorithms divides an order into slices based on historical volume distributions, and trades these slices throughout the trading day. It incorporates intelligent volume splicing, simple anti-gaming techniques, and a minimum volume threshold so as not to move the market.
Title: Weather RESTful Web Service Client
Version: 1.2
SB Release: 7.2
Summary: RESTful Web Service calls using Apache Jersey to NOAA’s National Weather Service
Description: This is a simple demo of calling a RESTful Web Service using Apache Jersey and javax.ws.rs as a web service client. The StreamBase application makes a web service call to get weather for a zip code. This web service client uses the REST web service offered by the American National Weather Service (NOAA).
Title: Wikimedia Edits Input Adapter
Version: 1.0
SB Release: 7.4
Summary: Real-time Wikimedia (incl. Wikipedia) Edits Input Adapter
Description: The Wikimedia Edits Input Adapter connects to the Wikimedia IRC servers to retrieve real-time information about edits to Wikimedia properties such as Wikipedia.