Nile: A query processing engine for data streams

M. A. Hammad; M. F. Mokbel; M. H. Ali; W. G. Aref; A. C. Catlin; A. K. Elmagarmid; M. Eltabakh; M. G. Elfeky; T. M. Ghanem; R. Gwadera; I. F. Ilyas; M. Marzouk; X. Xiong

doi:10.1109/ICDE.2004.1320080

Nile: A query processing engine for data streams

M. A. Hammad, M. F. Mokbel, M. H. Ali, W. G. Aref, A. C. Catlin, A. K. Elmagarmid, M. Eltabakh, M. G. Elfeky, T. M. Ghanem, R. Gwadera, I. F. Ilyas, M. Marzouk, X. Xiong

Computer Science and Engineering

Research output: Chapter in Book/Report/Conference proceeding › Conference contribution

62 Scopus citations

Abstract

The design of "STEAM", Purdue Boiler Makers' stream database system, which allows the processing of continuous and snap-shot queries over data streams is discussed. Nile extends the query processor engine, of a object-relational database management system, PREDATOR, to process continuous queries over data streams. Nile uses several approaches based on window-based operators and W-Expire, for emulating tuple addition to and subtraction from the window content. Nile implements each operator as a separate preemptive system-scheduled thread, with operators communicating with each other through a network of FIFO queues.

Original language	English (US)
Title of host publication	Proceedings - 20th International Conference on Data Engineering - ICDE 2004
Number of pages	1
Volume	20
DOIs	https://doi.org/10.1109/ICDE.2004.1320080
State	Published - Jun 3 2004
Event	Proceedings - 20th International Conference on Data Engineering - ICDE 2004 - Boston, MA., United States Duration: Mar 30 2004 → Apr 2 2004

Other

Other	Proceedings - 20th International Conference on Data Engineering - ICDE 2004
Country	United States
City	Boston, MA.
Period	3/30/04 → 4/2/04

Access

10.1109/ICDE.2004.1320080

Fingerprint Dive into the research topics of 'Nile: A query processing engine for data streams'. Together they form a unique fingerprint.

Cite this

Hammad, M. A., Mokbel, M. F., Ali, M. H., Aref, W. G., Catlin, A. C., Elmagarmid, A. K., Eltabakh, M., Elfeky, M. G., Ghanem, T. M., Gwadera, R., Ilyas, I. F., Marzouk, M., & Xiong, X. (2004). Nile: A query processing engine for data streams. In Proceedings - 20th International Conference on Data Engineering - ICDE 2004 (Vol. 20) https://doi.org/10.1109/ICDE.2004.1320080

Nile : A query processing engine for data streams. / Hammad, M. A.; Mokbel, M. F.; Ali, M. H.; Aref, W. G.; Catlin, A. C.; Elmagarmid, A. K.; Eltabakh, M.; Elfeky, M. G.; Ghanem, T. M.; Gwadera, R.; Ilyas, I. F.; Marzouk, M.; Xiong, X.

Proceedings - 20th International Conference on Data Engineering - ICDE 2004. Vol. 20 2004.

Research output: Chapter in Book/Report/Conference proceeding › Conference contribution

Hammad, MA, Mokbel, MF, Ali, MH, Aref, WG, Catlin, AC, Elmagarmid, AK, Eltabakh, M, Elfeky, MG, Ghanem, TM, Gwadera, R, Ilyas, IF, Marzouk, M & Xiong, X 2004, Nile: A query processing engine for data streams. in Proceedings - 20th International Conference on Data Engineering - ICDE 2004. vol. 20, Proceedings - 20th International Conference on Data Engineering - ICDE 2004, Boston, MA., United States, 3/30/04. https://doi.org/10.1109/ICDE.2004.1320080

@inproceedings{fa81a535f7f44972a62485ec06e28ac3,

title = "Nile: A query processing engine for data streams",

abstract = "The design of {"}STEAM{"}, Purdue Boiler Makers' stream database system, which allows the processing of continuous and snap-shot queries over data streams is discussed. Nile extends the query processor engine, of a object-relational database management system, PREDATOR, to process continuous queries over data streams. Nile uses several approaches based on window-based operators and W-Expire, for emulating tuple addition to and subtraction from the window content. Nile implements each operator as a separate preemptive system-scheduled thread, with operators communicating with each other through a network of FIFO queues.",

author = "Hammad, {M. A.} and Mokbel, {M. F.} and Ali, {M. H.} and Aref, {W. G.} and Catlin, {A. C.} and Elmagarmid, {A. K.} and M. Eltabakh and Elfeky, {M. G.} and Ghanem, {T. M.} and R. Gwadera and Ilyas, {I. F.} and M. Marzouk and X. Xiong",

year = "2004",

month = jun,

day = "3",

doi = "10.1109/ICDE.2004.1320080",

language = "English (US)",

volume = "20",

booktitle = "Proceedings - 20th International Conference on Data Engineering - ICDE 2004",

note = "Proceedings - 20th International Conference on Data Engineering - ICDE 2004 ; Conference date: 30-03-2004 Through 02-04-2004",

}

TY - GEN

T1 - Nile

T2 - Proceedings - 20th International Conference on Data Engineering - ICDE 2004

AU - Hammad, M. A.

AU - Mokbel, M. F.

AU - Ali, M. H.

AU - Aref, W. G.

AU - Catlin, A. C.

AU - Elmagarmid, A. K.

AU - Eltabakh, M.

AU - Elfeky, M. G.

AU - Ghanem, T. M.

AU - Gwadera, R.

AU - Ilyas, I. F.

AU - Marzouk, M.

AU - Xiong, X.

PY - 2004/6/3

Y1 - 2004/6/3

N2 - The design of "STEAM", Purdue Boiler Makers' stream database system, which allows the processing of continuous and snap-shot queries over data streams is discussed. Nile extends the query processor engine, of a object-relational database management system, PREDATOR, to process continuous queries over data streams. Nile uses several approaches based on window-based operators and W-Expire, for emulating tuple addition to and subtraction from the window content. Nile implements each operator as a separate preemptive system-scheduled thread, with operators communicating with each other through a network of FIFO queues.

AB - The design of "STEAM", Purdue Boiler Makers' stream database system, which allows the processing of continuous and snap-shot queries over data streams is discussed. Nile extends the query processor engine, of a object-relational database management system, PREDATOR, to process continuous queries over data streams. Nile uses several approaches based on window-based operators and W-Expire, for emulating tuple addition to and subtraction from the window content. Nile implements each operator as a separate preemptive system-scheduled thread, with operators communicating with each other through a network of FIFO queues.

UR - http://www.scopus.com/inward/record.url?scp=2442715487&partnerID=8YFLogxK

UR - http://www.scopus.com/inward/citedby.url?scp=2442715487&partnerID=8YFLogxK

U2 - 10.1109/ICDE.2004.1320080

DO - 10.1109/ICDE.2004.1320080

M3 - Conference contribution

AN - SCOPUS:2442715487

VL - 20

BT - Proceedings - 20th International Conference on Data Engineering - ICDE 2004

Y2 - 30 March 2004 through 2 April 2004

ER -

Nile: A query processing engine for data streams

Abstract

Other

Access

Other files and links

Cite this