Real-Time Processing refers to the method of handling and analyzing data or information as it is generated or received, with a focus on immediate or near-instantaneous response times. In real-time processing systems, data is processed and acted upon without any noticeable delay, ensuring that the output is available in a timeframe that meets specific timing constraints or requirements.


Real-Time Photonic Blind Interference Cancellation

mmWave devices can broadcast multiple spatially-separated data streams simultaneously in order to increase data transfer rates. Data transfer can, however, be compromised by interference. Photonic blind interference cancellation systems offer a power-efficient means of mitigating interference, but previous demonstrations of such systems have been limited by high latencies and the need for regular calibration. Here, we demonstrate real-time photonic blind interference cancellation using an FPGA-photonic system executing a zero-calibration control algorithm. Our system offers a greater than 200-fold reduction in latency compared to previous work, enabling sub-second cancellation weight identification. We further investigate key trade-offs between system latency, power consumption, and success rate, and we validate sub-Nyquist sampling for blind interference cancellation. We estimate that photonic interference cancellation can reduce the power required for digitization and signal recovery by greater than 74 times compared to the digital electronic alternative.

DataX: A system for Data eXchange and transformation of streams

The exponential growth in smart sensors and rapid progress in 5G networks is creating a world awash with data streams. However, a key barrier to building performant multi-sensor, distributed stream processing applications is high programming complexity. We propose DataX, a novel platform that improves programmer productivity by enabling easy exchange, transformations, and fusion of data streams. DataX abstraction simplifies the application’s specification and exposes parallelism and dependencies among the application functions (microservices). DataX runtime automatically sets up appropriate data communication mechanisms, enables effortless reuse of microservices and data streams across applications, and leverages serverless computing to transform, fuse, and auto-scale microservices. DataX makes it easy to write, deploy and reliably operate distributed applications at scale. Synthesizing these capabilities into a single platform is substantially more transformative than any available stream processing system.