The Kuiper team would like to announce the release of Kuiper 0.1.
Kuiper 0.1 now is available for download.
EMQ X Kuiper is an edge lightweight IoT data analytics / streaming software implemented by Golang, and it can be run at all kinds of resource constrained edge devices. One goal of Kuiper is to migrate the cloud streaming software frameworks (such as Apache Spark，Apache Storm and Apache Flink) to edge side. Kuiper references these cloud streaming frameworks, and also considered special requirement of edge analytics, and introduced rule engine, which is based on
SQL (business logic) and
Sink, rule engine is used for developing streaming applications at edge side.
This release includes several new features and bug fixes.
Github Repository: https://github.com/emqx/kuiper
concurrencysetting in source: How many instances will be started. By default, only an instance will be run. If more than one instance is specified, the topic must be a shared subscription topic.
concurrencysettings in sink: Specify how many instances of the sink will be run. If the value is bigger than 1, the order of the messages may not be retained.
concurrencysettings in SQL plans: A rule is processed by several phases of plans according to the SQL statement. This option will specify how many instances will be run for each plan. If the value is bigger than 1, the order of the messages may not be retained.
in, out, exceptionmessage count for all operators
process_latency_msfor all operators
buffer_length, the used buffer length for all operators
last_invocation, the last invocation timestamp for all operators
clicommand if any error is found during starting a rule.
If having any problems for Kuiper, feel free to contact us through firstname.lastname@example.org