Morphstream: Adaptive scheduling for scalable transactional stream processing on multicores

Y Mao, J Zhao, S Zhang, H Liu, V Markl - … of the ACM on Management of …, 2023 - dl.acm.org
Transactional stream processing engines (TSPEs) differ significantly in their designs, but all
rely on non-adaptive scheduling strategies for processing concurrent state transactions …

Harnessing scalable transactional stream processing for managing large language models [vision]

S Zhang, X Zeng, Y Wu, Z Yang - arXiv preprint arXiv:2307.08225, 2023 - arxiv.org
Large Language Models (LLMs) have demonstrated extraordinary performance across a
broad array of applications, from traditional language processing tasks to interpreting …

Orchestrating scheduling, grouping and parallelism to enhance the performance of distributed stream computing system

D Sun, H Chen, S Gao, R Buyya - Expert Systems with Applications, 2024 - Elsevier
In a big data stream computing environment, the arrival rate of data streams usually
fluctuates over time, posing a great challenge to the elasticity of system. The performance of …

Cstream: Parallel data stream compression on multicore edge devices

X Zeng, S Zhang - IEEE Transactions on Knowledge and Data …, 2024 - ieeexplore.ieee.org
In the burgeoning realm of Internet of Things (IoT) applications on edge devices, data stream
compression has become increasingly pertinent. The integration of added compression …

MorphStream: Scalable Processing of Transactions over Streams on Multicores

Y Mao, J Zhao, Z Yang, S Zhang, H Liu… - arXiv preprint arXiv …, 2023 - arxiv.org
Transactional Stream Processing Engines (TSPEs) form the backbone of modern stream
applications handling shared mutable states. Yet, the full potential of these systems …

A hardware-conscious stateful stream compression framework for iot applications (vision)

X Zeng, S Zhang - Proceedings of the 17th ACM International …, 2023 - dl.acm.org
Data stream compression has attracted vast interest in emerging IoT (Internet of Things)
applications. However, adopting stream compression on IoT applications is non-trivial due to …

Compressing network data with deep learning

D Gili Fernández De Romarategui - 2024 - upcommons.upc.edu
This thesis delves into the problem of compressing data generated by mobile networks,
which are formed by many antennas and IoT devices, that emit huge quantities of …

[PDF][PDF] Fast Parallel Recovery for Transactional Stream Processing on Multicores

J Zhao, H Liu, S Zhang, Z Duan, X Liao, H Jin, Y Zhang - intellistream.github.io
Transactional stream processing engines (TSPEs) have gained increasing attention due to
their capability of processing real-time stream applications with transactional semantics …