Decision, 由Spark流 & Siddhi供电

分享于 

2分钟阅读

GitHub

  繁體 雙語
Stratio Streaming
  • 源代码名称:Decision
  • 源代码网址:http://www.github.com/Stratio/Decision
  • Decision源代码文档
  • Decision源代码下载
  • Git URL:
    git://www.github.com/Stratio/Decision.git
    Git Clone代码到本地:
    git clone http://www.github.com/Stratio/Decision
    Subversion代码到本地:
    $ svn co --depth empty http://www.github.com/Stratio/Decision
    Checked out revision 1.
    $ cd repo
    $ svn up trunk
    

    Coverage Status

    DECISION-CEP-ENGINE

    决策CEP引擎是一个基于Spark流的复杂事件处理。

    它是将火花流作为连续计算框架和 Siddhi as引擎组合成复杂事件处理引擎的结果。

    什么是复杂事件处理?

    复杂事件处理( that ) 是一种事件处理,它将来自多个源的数据结合起来推断出更复杂。

    CEP作为一种技术,通过分析和关联其他事件来帮助发现复杂事件

    决策Cep引擎组件

    基于的流查询语言

    1 流定义语言( SDL )

    • 创建,更改或者删除流,添加新查询或者删除现有查询

    2 流操作语言( SML )

    • 将事件插入流并列出引擎中的现有流。

    3 流操作语言( SAL )

    • 侦听流( Kafka ),将流保存到Cassandra或者 mongoDB ( 自动创建表),将流索引为ElasticSearch或者 solr。 在这里你应该可以找到有用的操作。

    • 按需启动&停止每个操作

    内置功能4

    • 审核决策引擎中的所有请求( Cassandra或者 MongoDB )
    • 统计信息( 每个操作请求,每个流请求。)
    • 故障转移系统( 从Cassandra或者MongoDB恢复 Windows。流和查询)

    决策Cep引擎: API

    • Java & Scala API
    • 简单编程模型
    • 作为 Maven 依赖项可用

    决策Cep引擎: SHELL

    • 自动完成&帮助
    • 流名称的制表符补全
    • 构建在API之上

    关于决策Cep引擎的兴趣事实

    • 它在Spark峰会 2014 ( 链接 ) 中展示
    • 一个 node 中每分钟最多 10万个事件。
    • 它是完全开源的。

    变更日志

    有关更改,请参阅变更日志


    str  POW  SID  spa  spark  Spark Streaming  
    相关文章