To reconfigure accumulated data in order to increase the efficiency of a reconfiguration process for the accumulated data distributed in data accumulation devices, when stream data are stored as they are distributed to a plurality of data accumulation devices.
An information management apparatus 30 of a distributed stream processing system 1 obtains an information source ID for data to be reconfigured from a reference client 70. Based on the information source ID, a reconfiguration plan creation unit 35 of the information management apparatus 30 searches for accumulated data position information stored in a data position management database 322, and creates a reconfiguration plan for the stream data stored in each data accumulation device 20. Next, the reconfiguration plan creation unit 35 sends the created reconfiguration plan to a reconfiguration process unit 24 of each data accumulation device 20. Based on the reconfiguration plan, the reconfiguration process unit 24 obtains the stream data from another data accumulation data 20 storing the stream data to be moved, and reconfigures the accumulated data.
COPYRIGHT: (C)2011,JPO&INPIT
Hiroki Akama
Motohiro Matsuda
Masashi Yamamuro
| JP2008294774A | ||||
| JP2006048871A | ||||
| JP2005078394A | ||||
| JP2001265628A |
| WO2009088007A1 |
Shinji Nakamura