NDLI: Reliable speculative processing of out-of-order event streams in generic publish/subscribe middlewares

Please wait, while we are loading the content...

Frameworks and data initiatives for smart grid and other cyber-physical systems (invited keynote)

RIP: run-based intra-query parallelism for scalable complex event processing

Efficient content-based routing with network topology inference

HUGO: real-time analysis of component interactions in high-tech manufacturing equipment (industry article)

Efficient event detection by exploiting crowds

Dynamic expressivity with static optimization for streaming languages

MigCEP: operator migration for mobility driven distributed complex event processing

Real-time probabilistic data association over streams

Tutorial: stream processing optimizations

The DEBS 2013 grand challenge

Demo: do event-based systems have a passion for sports?

Poster: MADES - a multi-layered, adaptive, distributed event store

Adaptive input admission and management for parallel stream processing

StreamHub: a massively parallel architecture for high-performance content-based publish/subscribe

Proactive event processing in action: a case study on the proactive management of transport processes (industry article)

Towards complex actions for complex event processing

Towards unified and native enrichment in event processing systems

Opportunistic spatio-temporal event processing for mobile situation awareness

The hidden pub/sub of spotify: (industry article)

Tutorial: open source enterprise application integration - introducing the event processing capabilities of apache camel

Grand challenge: the bluebay soccer monitoring engine

Demo: measuring and estimating monetary cost for cloud-based data stream processing

Poster: Converging runtime and historic detection of areas of congestion within an urban bus network

Rollback-recovery without checkpoints in distributed event processing systems

DYNATOPS: a dynamic topic-based publish/subscribe architecture

Model-based validation of streaming data: (industry article)

Reliable speculative processing of out-of-order event streams in generic publish/subscribe middlewares

Adaptive online scheduling in storm

Event stream database based architecture to detect network intrusion: (industry article)

Tutorial: why is event-driven thinking different from traditional thinking about computing?

Grand challenge: SPRINT stream processing engine as a solution

Demo: elastic mapreduce-style processing of fast data

Ariadne: managing fine-grained provenance on data streams

Mobile QoS management using complex event processing: (industry article)

Tutorial: event-based systems meet software-defined networking

Grand challenge: real-time soccer analytics leveraging low-latency complex event processing

Demo: approximate semantic matching in the collider event processing engine

Tutorial: personal big data management in the cyber-physical systems - the role of event processing

Grand challenge: MapReduce-style processing of fast sensor data

Demo: ALERT - real-time coordination in open source software development

Grand challenge: the TechniBall system

Demo: a system for dynamic real-time personal fitness monitoring

Grand challenge: implementation by frequently emitting parallel windows and user-defined aggregate functions

Reliable speculative processing of out-of-order event streams in generic publish/subscribe middlewares

Content Provider	ACM Digital Library
Author	Mutschler, Christopher Philippsen, Michael
Abstract	In surveillance, sports, finances, etc., distributed event-based systems are used to detect meaningful events with low latency in high data rate event streams. Both known approaches to deal with the predominant out-of-order event arrival at the distributed detectors have their shortcomings: buffering approaches introduce latencies for event ordering and stream revision approaches may result in system overloads due to unbounded retraction cascades. This paper presents a speculative processing technique for out-of-order event streams that enhances typical buffering approaches. In contrast to other stream revision approaches our novel technique encapsulates the event detector, uses the buffering technique to delay events but also speculatively processes a portion of it, and adapts the degree of speculation at runtime to fit the available system resources so that detection latency becomes minimal. Our technique outperforms known approaches on both synthetical data and real sensor data from a Realtime Locating System (RTLS) with several thousands of out-of-order sensor events per second. Speculative buffering exploits system resources and reduces latency by 40% on average.
Starting Page	147
Ending Page	158
Page Count	12
File Format	PDF
ISBN	9781450317580
DOI	10.1145/2488222.2488263
Language	English
Publisher	Association for Computing Machinery (ACM)
Publisher Date	2013-06-29
Publisher Place	New York
Access Restriction	Subscribed
Subject Keyword	Message-oriented middleware Publish/subscribe Distributed event processing Out-of-order event processing
Content Type	Text
Resource Type	Article

Sl.	Authority	Responsibilities	Communication Details
1	Ministry of Education (GoI), Department of Higher Education	Sanctioning Authority	https://www.education.gov.in/ict-initiatives
2	Indian Institute of Technology Kharagpur	Host Institute of the Project: The host institute of the project is responsible for providing infrastructure support and hosting the project	https://www.iitkgp.ac.in
3	National Digital Library of India Office, Indian Institute of Technology Kharagpur	The administrative and infrastructural headquarters of the project	Dr. B. Sutradhar bsutra@ndl.gov.in
4	Project PI / Joint PI	Principal Investigator and Joint Principal Investigators of the project	Dr. B. Sutradhar bsutra@ndl.gov.in Prof. Saswat Chakrabarti will be added soon
5	Website/Portal (Helpdesk)	Queries regarding NDLI and its services	support@ndl.gov.in
6	Contents and Copyright Issues	Queries related to content curation and copyright issues	content@ndl.gov.in
7	National Digital Library of India Club (NDLI Club)	Queries related to NDLI Club formation, support, user awareness program, seminar/symposium, collaboration, social media, promotion, and outreach	clubsupport@ndl.gov.in
8	Digital Preservation Centre (DPC)	Assistance with digitizing and archiving copyright-free printed books	dpc@ndl.gov.in
9	IDR Setup or Support	Queries related to establishment and support of Institutional Digital Repository (IDR) and IDR workshops	idr@ndl.gov.in

Adaptive Speculative Processing of Out-of-Order Event Streams

Distributed Low-Latency Out-of-Order Event Processing for High Data Rate Sensor Streams

Demo: do event-based systems have a passion for sports?

Hermes: A Distributed Event-Based Middleware Architecture (2002)

Hermes: a distributed event-based middleware architecture.

Towards Dynamic Reconfiguration of Distributed Publish-Subscribe Middleware (2002)

Introducing Publiy: a multi-purpose distributed publish/subscribe system

Performance Evaluation Suite for Semantic Publish-Subscribe Message-oriented Middlewares

Exploiting Event Stream Interpretation in Publish-Subscribe Systems (2001)

Reliable speculative processing of out-of-order event streams in generic publish/subscribe middlewares

Similar Documents

Adaptive Speculative Processing of Out-of-Order Event Streams

Distributed Low-Latency Out-of-Order Event Processing for High Data Rate Sensor Streams

Demo: do event-based systems have a passion for sports?

Hermes: A Distributed Event-Based Middleware Architecture (2002)

Hermes: a distributed event-based middleware architecture.

Towards Dynamic Reconfiguration of Distributed Publish-Subscribe Middleware (2002)

Introducing Publiy: a multi-purpose distributed publish/subscribe system

Performance Evaluation Suite for Semantic Publish-Subscribe Message-oriented Middlewares

Exploiting Event Stream Interpretation in Publish-Subscribe Systems (2001)

Reliable speculative processing of out-of-order event streams in generic publish/subscribe middlewares