公开(公告)号：US20150222696A1

公开(公告)日：2015-08-06

申请号：US14606084

申请日：2015-01-27

Applicant: Electronics and Telecommunications Research Instit

Inventor： Choon Seo PARK ,  Jin Hwan JEONG ,  Mi Young LEE ,  Sung Jin HUR ,  Myung Cheol LEE ,  Yong Ju LEE

IPC: H04L29/08 ,  G06F17/30

CPC classification number: G06F17/30876 ,  G06F17/30516

Abstract: Provided are a method and apparatus for processing a data stream capable of providing a data flow processing language to support real-time processing of an exploding data stream and providing an environment for executing the data flow processing language in a cluster system. The data flow-based exploding data stream processing method includes receiving a big data real-time processing service described in a real-time data flow language, interpreting the big data real-time processing service to generate a distributed stream processing service, and distributively deploying the distributed stream processing service in a cluster system including multiple nodes and configuring an execution environment for executing the distributed stream processing service in each node.

Abstract translation: 提供了一种用于处理能够提供数据流处理语言以支持爆炸数据流的实时处理并提供用于在集群系统中执行数据流处理语言的环境的数据流的方法和装置。 基于数据流的爆炸数据流处理方法包括接收以实时数据流语言描述的大数据实时处理服务，解释大数据实时处理服务以生成分布式流处理服务，并且分布式部署 在包括多个节点的集群系统中的分布式流处理服务并且配置用于在每个节点中执行分布式流处理服务的执行环境。