  Focusing on comprehensive networking, big data, and artificial intelligence,
the Industrial Internet-of-Things (IIoT) facilitates efficiency and robustness
in factory operations. Various sensors and field devices play a central role,
as they generate a vast amount of real-time data that can provide insights into
manufacturing. The synergy of complex event processing (CEP) and machine
learning (ML) has been developed actively in the last years in IIoT to identify
patterns in heterogeneous data streams and fuse raw data into tangible facts.
In a traditional compute-centric paradigm, the raw field data are continuously
sent to the cloud and processed centrally. As IIoT devices become increasingly
pervasive and ubiquitous, concerns are raised since transmitting such amount of
data is energy-intensive, vulnerable to be intercepted, and subjected to high
latency. The data-centric paradigm can essentially solve these problems by
empowering IIoT to perform decentralized on-device ML and CEP, keeping data
primarily on edge devices and minimizing communications. However, this is no
mean feat because most IIoT edge devices are designed to be computationally
constrained with low power consumption. This paper proposes a framework that
exploits ML and CEP's synergy at the edge in distributed sensor networks. By
leveraging tiny ML and micro CEP, we shift the computation from the cloud to
the power-constrained IIoT devices and allow users to adapt the on-device ML
model and the CEP reasoning logic flexibly on the fly without requiring to
reupload the whole program. Lastly, we evaluate the proposed solution and show
its effectiveness and feasibility using an industrial use case of machine
safety monitoring.
