[go: up one dir, main page]

WO2009078428A1 - Data stream processing system, method, and program - Google Patents

Data stream processing system, method, and program Download PDF

Info

Publication number
WO2009078428A1
WO2009078428A1 PCT/JP2008/072954 JP2008072954W WO2009078428A1 WO 2009078428 A1 WO2009078428 A1 WO 2009078428A1 JP 2008072954 W JP2008072954 W JP 2008072954W WO 2009078428 A1 WO2009078428 A1 WO 2009078428A1
Authority
WO
WIPO (PCT)
Prior art keywords
data stream
processing
stream processing
processing system
program
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Ceased
Application number
PCT/JP2008/072954
Other languages
French (fr)
Japanese (ja)
Inventor
Kenichiro Fujiyama
Kouji Kida
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
NEC Corp
Original Assignee
NEC Corp
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by NEC Corp filed Critical NEC Corp
Priority to JP2009546277A priority Critical patent/JP5540706B2/en
Publication of WO2009078428A1 publication Critical patent/WO2009078428A1/en
Anticipated expiration legal-status Critical
Ceased legal-status Critical Current

Links

Classifications

    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F15/00—Digital computers in general; Data processing equipment in general
    • G06F15/16—Combinations of two or more digital computers each having at least an arithmetic unit, a program unit and a register, e.g. for a simultaneous processing of several programs

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Hardware Design (AREA)
  • Theoretical Computer Science (AREA)
  • Software Systems (AREA)
  • Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)
  • Two-Way Televisions, Distribution Of Moving Picture Or The Like (AREA)
  • Image Processing (AREA)
  • Multi Processors (AREA)

Abstract

It is possible to improve the throughput of the entire DSM by correcting throughput differences between respective nodes in the DSMS. A data stream processing system includes: a processing device having a plurality of nodes; and a managing device for managing the processing device. Each of nodes of the processing device has: a plurality of data stream processing units for successively processing the data stream; and a data stream processing switching unit which switches the data stream processing unit used for processing the data stream in accordance with the data stream processing state.
PCT/JP2008/072954 2007-12-18 2008-12-17 Data stream processing system, method, and program Ceased WO2009078428A1 (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP2009546277A JP5540706B2 (en) 2007-12-18 2008-12-17 Data stream processing system, method and program

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
JP2007326366 2007-12-18
JP2007-326366 2007-12-18

Publications (1)

Publication Number Publication Date
WO2009078428A1 true WO2009078428A1 (en) 2009-06-25

Family

ID=40795542

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/JP2008/072954 Ceased WO2009078428A1 (en) 2007-12-18 2008-12-17 Data stream processing system, method, and program

Country Status (2)

Country Link
JP (1) JP5540706B2 (en)
WO (1) WO2009078428A1 (en)

Cited By (7)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2011128738A (en) * 2009-12-16 2011-06-30 Nec Corp Data stream processing system and method, processing node rearrangement device, and program
JPWO2014034060A1 (en) * 2012-08-30 2016-08-08 日本電気株式会社 Event processing control device, node device, event processing system, and event processing control method
US9483306B2 (en) 2011-08-26 2016-11-01 Hitachi, Ltd. Predictive sequential calculation device
JP2016218930A (en) * 2015-05-26 2016-12-22 株式会社Ａｔｌ−Ｓｄ Parallel data processing method, parallel data processing circuit using the method, and audio mixer incorporating the parallel data processing circuit
JP2017509075A (en) * 2014-03-06 2017-03-30 華為技術有限公司Ｈｕａｗｅｉ Ｔｅｃｈｎｏｌｏｇｉｅｓ Ｃｏ．，Ｌｔｄ． Data processing method, control node, and stream calculation system in stream calculation system
JP2019506648A (en) * 2015-12-01 2019-03-07 インターナショナル・ビジネス・マシーンズ・コーポレーションＩｎｔｅｒｎａｔｉｏｎａｌ Ｂｕｓｉｎｅｓｓ Ｍａｃｈｉｎｅｓ Ｃｏｒｐｏｒａｔｉｏｎ Multi-level parallel buffering and context-based streaming data preprocessing system for vehicle domain
JPWO2021111611A1 (en) * 2019-12-06 2021-06-10

Families Citing this family (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN107819693B (en) * 2016-09-12 2019-05-07 北京百度网讯科技有限公司 Data stream processing method and device for data stream system

Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2005208767A (en) * 2004-01-20 2005-08-04 Hitachi Ltd Job management system, job management method, and job management program
JP2006039754A (en) * 2004-07-23 2006-02-09 Canon Inc Image processing apparatus and method
JP2009054003A (en) * 2007-08-28 2009-03-12 Fujifilm Corp Image processing apparatus and program

Family Cites Families (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JPH07191924A (en) * 1993-10-19 1995-07-28 Canon Inc Data processing device
JPH08212084A (en) * 1995-02-02 1996-08-20 Hitachi Ltd Information processing device
JP4906317B2 (en) * 2005-11-10 2012-03-28 キヤノン株式会社 Information processing apparatus and method

Patent Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2005208767A (en) * 2004-01-20 2005-08-04 Hitachi Ltd Job management system, job management method, and job management program
JP2006039754A (en) * 2004-07-23 2006-02-09 Canon Inc Image processing apparatus and method
JP2009054003A (en) * 2007-08-28 2009-03-12 Fujifilm Corp Image processing apparatus and program

Cited By (11)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2011128738A (en) * 2009-12-16 2011-06-30 Nec Corp Data stream processing system and method, processing node rearrangement device, and program
US9483306B2 (en) 2011-08-26 2016-11-01 Hitachi, Ltd. Predictive sequential calculation device
JPWO2014034060A1 (en) * 2012-08-30 2016-08-08 日本電気株式会社 Event processing control device, node device, event processing system, and event processing control method
JP2017509075A (en) * 2014-03-06 2017-03-30 華為技術有限公司Ｈｕａｗｅｉ Ｔｅｃｈｎｏｌｏｇｉｅｓ Ｃｏ．，Ｌｔｄ． Data processing method, control node, and stream calculation system in stream calculation system
US10097595B2 (en) 2014-03-06 2018-10-09 Huawei Technologies Co., Ltd. Data processing method in stream computing system, control node, and stream computing system
US10630737B2 (en) 2014-03-06 2020-04-21 Huawei Technologies Co., Ltd. Data processing method in stream computing system, control node, and stream computing system
JP2016218930A (en) * 2015-05-26 2016-12-22 株式会社Ａｔｌ−Ｓｄ Parallel data processing method, parallel data processing circuit using the method, and audio mixer incorporating the parallel data processing circuit
JP2019506648A (en) * 2015-12-01 2019-03-07 インターナショナル・ビジネス・マシーンズ・コーポレーションＩｎｔｅｒｎａｔｉｏｎａｌ Ｂｕｓｉｎｅｓｓ Ｍａｃｈｉｎｅｓ Ｃｏｒｐｏｒａｔｉｏｎ Multi-level parallel buffering and context-based streaming data preprocessing system for vehicle domain
JPWO2021111611A1 (en) * 2019-12-06 2021-06-10
WO2021111611A1 (en) * 2019-12-06 2021-06-10 日本電信電話株式会社 Thread synchronization device, thread synchronization method, and program
JP7384220B2 (en) 2019-12-06 2023-11-21 日本電信電話株式会社 Thread synchronizers, thread synchronization methods, and programs

Also Published As

Publication number Publication date
JP5540706B2 (en) 2014-07-02
JPWO2009078428A1 (en) 2011-04-28

Similar Documents

Publication Publication Date Title
WO2009078428A1 (en) Data stream processing system, method, and program
WO2010018374A3 (en) Switching table in an ethernet bridge
WO2007047250A3 (en) Video encoder with multiple processors
IL204679A0 (en) Method, system, and computer program product for adaptive congestion control on virtual lanes for data center ethernet architecture
ZA200900861B (en) Apparatus, system and method for sharing output contacts across multiple relays
WO2007067562A3 (en) Methods and apparatus for multi-core processing with dedicated thread management
EP3970153A4 (en) Methods and systems for quantum computing enabled molecular ab initio simulations
WO2011094211A3 (en) Reducing latency in serializer-deserializer links
GB2497493A (en) Performance and power optimized computer system architectures and methods leveraging power optimized tree fabric interconnect
WO2008121667A3 (en) Intra-macroblock video processing
EP2517424A4 (en) Transmission management system, transmission system, computer program product, program providing system, and maintenance system
DK1981300T3 (en) Mobility management approach in a system architecture that supports mobility between different access systems
WO2013096772A3 (en) Unified partition mode table for intra-mode coding
WO2012167178A3 (en) Daisy chain devices and systems for digital signal switching and distribution
WO2006119186A3 (en) Systems, devices, and methods for interpreting movement
EP2564521A4 (en) Method, apparatus and system for switching traffic streams among multiple frequency bands
GB2466580A (en) Data processing apparatus and method of processing data
MY161489A (en) System and method for adaptive streaming in a multipath environment
WO2010016889A3 (en) Flexible and expandable memory architectures
GB2411540B (en) Cascade control system for network units
FI20075409L (en) Systems, methods and devices for complementary metal oxide semiconductor (CMOS) antenna switches using switched resonators
WO2013013908A3 (en) Device for operating decentralized functional units arranged in an industrial installation
IL207812A (en) Methods, systems and computer software for multi-local cryptographic separation for message transfer
WO2011142548A3 (en) Method for selecting a master device in a coexistence system
WO2011126712A3 (en) Classification and encoder selection based on content

Legal Events

Date Code Title Description
121 Ep: the epo has been informed by wipo that ep was designated in this application

Ref document number: 08861777

Country of ref document: EP

Kind code of ref document: A1

ENP Entry into the national phase

Ref document number: 2009546277

Country of ref document: JP

Kind code of ref document: A

NENP Non-entry into the national phase

Ref country code: DE

122 Ep: pct application non-entry in european phase

Ref document number: 08861777

Country of ref document: EP

Kind code of ref document: A1