TimeSWAD: A Dataflow Engine for TimeBased Single Window Stream Aggregation High throughput and low latency streaming aggregation is essential for many applications that analyze massive volumes of data in realtime. Incoming data need to be stored in a single sliding window before processing, in cases where incremental aggregations are wasteful or not possible at all; this puts tremendous pressure to the memory bandwidth. In addition, particular problems call for timebased windows, defined by a timeinterval, where the amount of data per window may vary and as a consequence are more challenging to handle. This paper describes TimeSWAD, the first accelerator for timebased singlewindow stream aggregation. TimeSWAD is a dataflow engine (DFE), implemented on a Maxeler machine, offering high processing throughput, up to 150 Mtuplessec, similar to related GPU systems, which however do not support both timebased and single windows. It uses a direct feed of incoming data from the network and has direct access to offchip DRAM, enabling ultralow processing latency of 110 xc2xb5sec, at least 4 orders of magnitude lower than softwarebased solutions.

Dynamic Data Streaming for an Appliance Many applications require to analyse large amounts of continuous flows of data produced by different data sources before the data is stored. Data streaming engines emerged as a solution for processing data on the fly. At the same time, computer architectures have evolved to systems with several interconnected CPUs and Non Uniform Memory Access (NUMA), where the cost of accessing memory from a core depends on how CPUs are interconnected. In order to get better resource utilization and adaptiveness to the load dynamic migration of queries must be available in data streaming engines. Moreover, data streaming applications require high availability so that failures do not cause service interruption and losing data. This paper presents the dynamic migration and faulttolerance capabilities of UPMCEP, a data streaming engine designed to take advantage of NUMA architectures. The preliminary evaluation using Intel HiBench benchmark shows the effect of the query migration and faulttolerance on the system performance.