Skip to content
Home

Selected Earlier Work · Streaming Data and Complex Event Processing

Streaming Data and Complex Event Processing

Query languages and systems for mining streams and matching complex patterns over structured data.

Stream Mill Miner

K*SQL

XSeq

Research question

How can query languages express and execute complex patterns over continuously arriving, structured data?

Approach

Extend query languages and execution engines with sequence patterns, nested-word semantics, incremental mining, and optimized event processing.

Key results

  • Stream Mill Miner integrates continuous queries and data mining over streams.
  • K*SQL unifies sequence-pattern queries across relational and XML data.
  • XSeq extends XPath for high-performance complex-event processing over XML streams, earning the SIGMOD 2012 Best Paper Award.

Publications

A Data Stream Mining System

Hetal Thakkar, Barzan Mozafari, Carlo Zaniolo

ICDM Workshops 2008 · IEEE International Conference on Data Mining Workshops

Paper ↗Project ↗
Cite
@inproceedings{0c6165a7-5632-49b4-a501-a86c49031fd4,
  title = {A Data Stream Mining System},
  author = {Hetal Thakkar and Barzan Mozafari and Carlo Zaniolo},
  booktitle = {IEEE International Conference on Data Mining Workshops},
  year = {2008},
  doi = {10.1109/ICDMW.2008.133}
}

K*SQL: a unifying engine for sequence patterns and XML

Barzan Mozafari, Kai Zeng, Carlo Zaniolo

SIGMOD 2010 · ACM SIGMOD International Conference on Management of Data

Paper ↗Project ↗
Cite
@inproceedings{42521ab9-b6d0-42cb-9b1b-395bacfdffc4,
  title = {K*SQL: a unifying engine for sequence patterns and XML},
  author = {Barzan Mozafari and Kai Zeng and Carlo Zaniolo},
  booktitle = {ACM SIGMOD International Conference on Management of Data},
  year = {2010},
  doi = {10.1145/1807167.1807302}
}

High-performance complex event processing over XML streams

Barzan Mozafari, Kai Zeng, Carlo Zaniolo

SIGMOD 2012 · ACM SIGMOD International Conference on Management of Data

Paper ↗Project ↗
Cite
@inproceedings{05587a10-0360-4b57-abdc-f56badf929f2,
  title = {High-performance complex event processing over XML streams},
  author = {Barzan Mozafari and Kai Zeng and Carlo Zaniolo},
  booktitle = {ACM SIGMOD International Conference on Management of Data},
  year = {2012},
  doi = {10.1145/2213836.2213866}
}
Paper ↗Project ↗
Cite
@inproceedings{e4b63f8e-1771-4670-95ff-85617ce4d962,
  title = {Complex pattern matching in complex structures: The XSeq approach},
  author = {Kai Zeng and Mohan Yang and Barzan Mozafari and Carlo Zaniolo},
  booktitle = {IEEE International Conference on Data Engineering},
  year = {2013},
  doi = {10.1109/ICDE.2013.6544936}
}
Project ↗
Cite
@inproceedings{7ccb269e-e026-4b8f-bbbd-d3de83764f62,
  title = {Extending Relational Query Languages for Data Streams},
  author = {Nikolay Laptev and Barzan Mozafari and Hamid Mousavi and Hetal Thakkar and Haixun Wang and Kai Zeng and Carlo Zaniolo},
  booktitle = {Data Stream Management},
  year = {2016},
  doi = {10.1007/978-3-540-28608-0_18}
}
Paper ↗Project ↗
Cite
@inproceedings{3aa631e0-31d2-4d6d-929d-41476b51594d,
  title = {SMM: A data stream management system for knowledge discovery},
  author = {Hetal Thakkar and Nikolay Laptev and Hamid Mousavi and Barzan Mozafari and Vincenzo Russo and Carlo Zaniolo},
  booktitle = {IEEE International Conference on Data Engineering},
  year = {2011},
  doi = {10.1109/ICDE.2011.5767879}
}
Paper ↗Project ↗
Cite
@article{b1ccc0f4-295d-4a87-b560-5420bc1976cf,
  title = {From Regular Expressions to Nested Words: Unifying Languages and Query Execution for Relational and XML Sequences},
  author = {Barzan Mozafari and Kai Zeng and Carlo Zaniolo},
  journal = {Proceedings of the VLDB Endowment},
  year = {2010},
  doi = {10.14778/1920841.1920865}
}
Paper ↗Project ↗
Cite
@inproceedings{421a620d-05d6-48fb-afa5-75d259a7a201,
  title = {Verifying and Mining Frequent Patterns from Large Windows over Data Streams},
  author = {Barzan Mozafari and Hetal Thakkar and Carlo Zaniolo},
  booktitle = {IEEE International Conference on Data Engineering},
  year = {2008},
  doi = {10.1109/ICDE.2008.4497426}
}