NDLI: CASQD: continuous detection of activity-based subgraph pattern queries on dynamic graphs

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

Diversified set monitoring over distributed data streams

Spreadsheets for stream processing with unbounded windows and partitions

A model driven approach for event processing applications

Highly-available content-based publish/subscribe via gossiping

Bandwidth-efficient content-based routing on software-defined networks

AQuA: adaptive quality analytics

Theory and implementation of a distributed event based platform

Data-centric publish/subscribe routing middleware for realizing proactive overlay software-defined networking

The DEBS 2016 grand challenge

SPASS: scalable event stream processing leveraging sharing opportunities: poster

Taming velocity and variety simultaneously in big data with stream reasoning: tutorial

Adaptive steering of cyber-physical systems with atomic complex event processing services: doctoral symposium

Frames: data-driven windows

Load-aware shedding in stream processing systems

OMen: overlay mending for topic-based publish/subscribe systems under churn

Routing and scheduling of spatio-temporal tasks for optimizing airborne sensor system utilization

Breaking BAD: a data serving vision for big active data

Continuous graph pattern matching over knowledge graph streams

Incremental deployment and migration of geo-distributed situation awareness applications in the fog

High performance top-k processing of non-linear windows over data streams

Complex event processing for the non-expert with autoCEP: demo

Design and development of high performance, scalable content based publish subscribe system: doctoral symposium

Quality-driven disorder handling for concurrent windowed stream queries with shared operators

Optimal operator placement for distributed stream processing applications

Shared dictionary compression in publish/subscribe systems

Smooth and crispy: integrating continuous event proximity calculation and discrete event detection

Reducing expenses of top-k monitoring in sensor cloud services

CASQD: continuous detection of activity-based subgraph pattern queries on dynamic graphs

Energy efficient, context-aware cache coding for mobile information-centric networks

Continuous analytics on graph data streams using WSO2 complex event processor

Evolving pub/sub subscriptions for multiplayer online games: demo

Proactive scaling of distributed stream processing work flows using workload modelling: doctoral symposium

Enorm: efficient window-based computation in large-scale distributed stream processing systems

Benchmarking integration pattern implementations

Distributed k-core decomposition and maintenance in large dynamic graphs

Lessons learned using a process mining approach to analyze events from distributed applications

RFID-based logistics monitoring with semantics-driven event processing

Proactive disruption management system: how not to be surprised by upcoming situations

GraphCEP: real-time data analytics using parallel complex event and graph processing

Complex event processing over streaming multi-cloud platforms: the FERARI approach: demo

Automatic learning of predictive rules for complex event processing: doctoral symposium

Monitoring top-k on real-time dynamic social-network graphs

Enabling semantic access to static and streaming distributed data with optique: demo

A policy-based coordination architecture for distributed complex event processing in the internet of things: doctoral symposium

Real-time social network graph analysis using StreamMine3G

The SABER system for window-based hybrid stream processing with GPGPUs: demo

Placement of distributed stream processing over heterogeneous infrastructures: doctoral symposium

Experience of event stream processing for top-k queries and dynamic graphs

Partial pattern fulfillment and its application in event processing: poster

Dependable distributed content-based publish/subscribe systems: doctoral symposium

Multi-query outlier detection over data streams: poster

Modeling and recognition of events from multidimensional data: doctoral symposium

RxSpatial: a framework for real-time spatio-temporal operations: demo

Automating computational placement in IoT environments: doctoral symposium

Distributed streaming reconstruction of information diffusion: poster

SnappyData: a hybrid system for transactions, analytics, and streaming: demo

Infusing trust in indoor tracking: poster

In-memory indexation of event streams

Dynamic graph management for streaming social media analytics

Real-time analysis of social networks leveraging the flink framework

Stateful complex event detection on event streams using parallelization of event stream aggregations and detection tasks

CASQD: continuous detection of activity-based subgraph pattern queries on dynamic graphs

Content Provider	ACM Digital Library
Author	Deshpande, Amol Mondal, Jayanta
Abstract	The ability to detect and analyze interesting subgraph patterns on large and dynamic graph-structured data in near-real time is crucial for many applications; example includes anomaly detection in phone call networks, advertisement targeting in social networks, malware detection in file download graphs, and many more. Such patterns often need to reason about how the nodes are connected to each other (i.e., the structural component) as well as how the nodes behave in the network (i.e., the activity component). An example of such an activity-driven subgraph pattern is a clique of users in a social network (the structural predicate), who each have posted more than 10 messages in last 2 hours (the activity-based predicate). In this paper, we present Casqd, a system for continuous detection and analysis of such active subgraph pattern queries over large dynamic graphs. Some of key challenges in executing such queries include: handling a wide variety of user-specified activities of interest, low selectivities of activity-based predicates and the resultant exponential search space, and high ingestion rates. A key abstraction in Casqd is a notion called graph-view, which acts as an independence layer between the query language and the underlying physical representation of the graph and the active attributes. This abstraction is aimed at simplifying the query language, while empowering the query optimizer. Considering the balance between expressibility (i.e., patterns that cover many real-world use cases) and optimizability of such patterns, we primarily focus on efficient continuous detection of the active regular structures (specifically, active cliques, active stars, and active bi-cliques). We develop a series of optimization techniques including model-based neighborhood explorations, lazy evaluation of the activity predicates, neighborhood-based search space pruning, and others, for efficient query evaluation. We perform a thorough comparative study of the execution strategies under various settings, and show that our system is capable of achieving event processing throughputs over 800k/s using a single, powerful machine.
Starting Page	226
Ending Page	237
Page Count	12
File Format	PDF
ISBN	9781450340212
DOI	10.1145/2933267.2933316
Language	English
Publisher	Association for Computing Machinery (ACM)
Publisher Date	2016-06-13
Publisher Place	New York
Access Restriction	Subscribed
Subject Keyword	Event detection Query processing Information network Continous analytics Data streams Subgraph pattern matching
Content Type	Text
Resource Type	Article

Central Library (ISO-9001:2015 Certified)
Indian Institute of Technology Kharagpur
Kharagpur, West Bengal, India | PIN - 721302

See location in the Map
03222 282435
Mail: support@ndl.gov.in

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