Types of toolkits

Teracloud® Streams provides several toolkits out of the box. If provided toolkits do not meet application needs, custom toolkits can be created.

Toolkits can be categorized into the following types:

Toolkits shipped in Teracloud® Streams
Standard toolkit
The SPL standard toolkit is included with Teracloud® Streams. It contains operators, functions, types, and other artifacts that are available by default to develop stream applications.

Here are some standard operators that you might use in your application.

Aggregate
The Aggregate operator is used to compute user-specified aggregations over tuples that are gathered in a window.
Beacon
The Beacon operator is a utility source that generates tuples dynamically.
FileSink
The FileSink operator writes tuples to a file.
FileSource
The FileSource operator reads data from a file and produces tuples as a result.
Filter
The Filter operator removes tuples from a stream by passing along only those tuples that satisfy a user-specified condition.
Join
The Join operator is used to correlate tuples from two streams that are based on user-specified match predicates and window configurations.
Split
The Split operator is used to split a stream into one or more output streams, which are based on a user-specified split condition.
Throttle
The Throttle operator is used to pace a stream to make it flow at a specified rate.
Specialized toolkits
Specialized toolkits are toolkits developed for specific protocols, integrations, and business environments. Some commonly used specialized toolkits include:
  • Geospatial toolkit
  • Kafka toolkit
  • TimeSeries Toolkit
Custom toolkits

A custom toolkit is any toolkit not shipped by Teracloud® Streams. They may be internal to your organization, provided by third-parties, or open source. Users may want to create custom toolkits to share functionality, reduce redundancy, or standardize flows across their stream applications.

Teracloud Streams requires custom toolkits to be indexed in order to be available by compilers and tools. Streams provides the spl-make-toolkit program to perform this indexing.