DEBS '20: Proceedings of the 14th ACM International Conference on Distributed and Event-based Systems
Full Citation in the ACM Digital LibraryStreaming graph processing and analytics
Graphs are now ubiquitous as many applications emerge where the relationships among entities are paramount and require being modeled as first-class objects. Graph database systems empower such applications by enabling querying and processing both the data stored on the graph and its topology, and they have gained significant attention both in industry and academia. The graphs used in many modern applications are not static and not fully available for analysis; rather the graph vertices and edges are streamed, and the graph "emerges" over time. These are called streaming graphs. Processing and analyzing streaming graphs are challenging, because the difficulties of streaming combine with the complexities of graph processing. In this talk, I have two objectives. First is the introduction and positioning of the problem and the environment. The second is to highlight some of our recent work in this area within the context of s-Graffito project.
DEBS '14- Proceedings of the 8th ACM International Conference on Distributed Event-Based Systems
Full Citation in the ACM Digital LibrarySESSION: Research track papers: Streams
Quality matters: supporting quality-aware pervasive applications by probabilistic data stream management
Latency-aware elastic scaling for distributed data stream processing systems
JetStream: enabling high performance event streaming across cloud data-centers
An event processing approach to text stream analysis: basic principles of event based information filtering
SESSION: Research track papers: Event processing
Learning from the past: automated rule generation for complex event processing
RECEP: selection-based reuse for distributed complex event processing
Complex event service provision and composition based on event pattern matchmaking
DS-EPL: domain-specific event processing language
SESSION: Research track papers: Publish/subscribe and filtering
Distributed event aggregation for content-based publish/subscribe systems
The overlay scan attack: inferring topologies of distributed pub/sub systems through broker saturation
Automated quality-of-service-aware configuration of publish-subscribe systems at design-time
Content-based filtering discovery protocol (CFDP): scalable and efficient OMG DDS discovery protocol
SESSION: Research track papers: Applications
We have a DREAM: distributed reactive programming with consistency guarantees
The process-oriented event model (PoEM): a conceptual model for industrial events
Energy-efficient context-aware routing in heterogeneous WSN
Effective switch memory management in OpenFlow networks
SESSION: Industry track papers
P2S: a fault-tolerant publish/subscribe infrastructure
Scalable and elastic realtime click stream analysis using StreamMine3G
Handling location uncertainty in event driven experimentation
An event processing architecture for operational risk management in an industrial environment
Using mobile-based complex event processing to realize collaborative remote person monitoring
TUTORIAL SESSION: Tutorials
Tutorial on the internet of everything
Cloud-based data stream processing
Policy enforcement within emerging distributed, event-based systems
Mobile CEP in real-time big data processing: challenges and opportunities
SESSION: DEBS grand challenge
The DEBS 2014 grand challenge
Predicting energy consumption with StreamMine3G
Scalable stateful stream processing for smart grids
Predictive load management in smart grid environments
Solving the grand challenge using an opensource CEP engine
Real time load prediction and outliers detection using STORM
Predicting power needs in smart grids
Smart plug monitoring using oracle event processing
In-memory, high speed stream processing
DEMONSTRATION SESSION: Demonstrations and posters
A cloud-enabled coordination service for internet-scale OMG DDS applications
A cost model for complex event operators
Auto-scaling techniques for elastic data stream processing
Understanding event attendance through analysis of human crowd behavior in social networks
VizPub: visualizing the performance of overlay-based pub/sub systems
Supporting quality-aware pervasive applications by probabilistic data stream management
Distributed event notification in VANET with multiple service providers
Machine-learning approaches for P2P botnet detection using signal-processing techniques
Architecture of a light-weight non-threaded event oriented workflow engine
Verifying QoS properties of trusted data sensing
Mobile CEP architecture: from intelligent sensing to collaborative monitoring
Achieving high throughput for large scale event streaming across geographically distributed data-centers with JetStream
Automated publish-subscribe middleware configuration with M2etis
DEBS '15- Proceedings of the 9th ACM International Conference on Distributed Event-Based Systems
Full Citation in the ACM Digital LibrarySESSION: Research track: event processing
Model-based verification of event-driven business processes
Efficient analysis of event processing applications
Complex event processing for reactive security monitoring in virtualized computer systems
Lazy evaluation methods for detecting complex events
SESSION: Research track: stream processing
Herding "small" streaming queries
TOPiCo: detecting most frequent items from multiple high-rate event streams
Quality-driven processing of sliding window aggregates over out-of-order data streams
Efficient key grouping for near-optimal load balancing in stream processing systems
SESSION: Research track: publish/subscribe
Distributed control plane for software-defined networks: a case study using event-based middleware
Dissemination of anonymized streaming data
Towards prioritized event matching in a content-based publish/subscribe system
Analyzing content-based publish/subscribe systems
SESSION: Research track: systems and frameworks
An algebra for pattern matching, time-aware aggregates and partitions on relational data streams
An adaptive replication scheme for elastic data stream processing systems
ThingStore: a platform for internet-of-things application development and deployment
Improving packet processing performance in the ATLAS FELIX project: analysis and optimization of a memory-bounded algorithm
SESSION: Industry track
The uncertain case of credit card fraud detection
Autofunk, a fast and scalable framework for building formal models from production systems
Dynamic monitoring for improving worker safety at the workplace: use case from a manufacturing shop floor
Spring XD: a modular distributed stream and batch processing system
Reliable event messaging in big data enterprises: looking for the balance between producers and consumers
Reactive stream processing for data-centric publish/subscribe
SESSION: Tutorials
When artificial intelligence meets the internet of things
Solution patterns for realtime streaming analytics
Tackling variety in event-based systems
SESSION: DEBS grand challenge
The DEBS 2015 grand challenge
Real time data analysis of taxi rides using StreamMine3G
Continuous analytics on geospatial data streams with WSO2 complex event processor
RDF stream processing with CQELS framework for real-time analysis
Top-K queries in RDF graph-based stream processing with actors
A high-throughput, scalable solution for calculating frequent routes and profitability of New York taxis
A high throughput processing engine for taxi-generated data streams
Deterministic real-time analytics of geospatial data streams through ScaleGate objects
Pimp my taxi ride
Using odysseus for real-time analysis over high volume geospatial data streams
High performance stream queries in scala
Geospatial event analytics leveraging reactive programming
The PipeFlow approach
Parallel event processing on unbound streams with multi-step windowing
StreamPipes: solving the challenge with semantic stream processing pipelines
SESSION: Posters
Operator fission for load balancing in distributed heterogeneous data stream processing systems
A complex event processing for large-scale M2M services and its performance evaluations
Towards content-based publish/subscribe for distributed social networks
Distributed QoS-aware scheduling in storm
Concept of multiscoping for distributed event-based systems
A conceptual model for event-sourced graph computing
SESSION: Demonstrations
Herakles: real-time sport analysis using a distributed data stream management system
Approximative event processing on sensor data streams
Spontaneous and ephemeral social networks: an event-based framework
The pipeflow approach: write once, run in different stream-processing engines
DEBS '17- Proceedings of the 11th ACM International Conference on Distributed and Event-based Systems
Full Citation in the ACM Digital Library