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.