Event Stream Processor includes advanced programming
examples that incorporate a variety of CCL elements.
Note: The example syntax occasionally wraps due to space constraints. Wrapped lines should be entered on a single line.
Portfolio Valuation
Compute volume-weighted average prices on a stock portfolio.
Performance Tuning Using Partitioning
Example demonstrating how to determine the source of performance issues in an ESP project and increase throughput using automatic partitioning. Automatic partitioning is the creation of parallel instances of an element and splitting input data across these instances. Partitioning project elements this way can result in an overall project throughput increase as the workload is split across the parallel instances.
Partitioning a Module
Automatic partitioning is the creation of parallel instances of an element and splitting input data across these instances. This can improve the performance of an element and complex projects, which perform computationally expensive operations such as aggregation and joins. This example demonstrates how to partition a module when loading it into an ESP project. Though you can only partition a module on load, this example also demonstrates how you can have nested partitioning when creating a module.
Declaring a Partitioning Global Parameter
Automatic partitioning is the creation of parallel instances of an element and splitting input data across these instances. This can improve the performance of an element and complex projects, which perform computationally expensive operations such as aggregation and joins. This example demonstrates how to create a global parameter to indicate the number of partitions you wish to create.
Trades Log
Use a Flex stream to manually delete data from windows.