Strömbehandling blir allt viktigare när fler data blir tillgängliga i form av kontinuerliga strömmar och företag konkurrerar om att snabbt ta fram insikter från dem. I sådana applikationer, skjutfönster aggregering är en central operatör, och inkrementell aggregering hjälper till att undvika prestanda straff för omaggregatering från grunden för varje fönster förändring. I detta dokument presenteras Reactive Aggregator (RA), en ny ram för inkrementell glidande fönsteraggregation. RA är allmänt i det att det inte kräver aggregering funktioner för att vara inverterbar eller pendlande, och det kräver inte fönster för att vara FIFO. Vi implementerade RA som en drop-in ersättning för den Aggregate operatören av en kommersiell streaming motor. Eftersom m uppdateringar på ett fönster av storlek n, RA har en algoritmisk komplexitet av Opm`m logpn {mqqq, rivaliserande de bästa tidigare algoritmer för alla m. Dessutom, RA: s genomförande minimerar overheads från tilldelning och pekar traversals genom att använda en enda platt array.
Slutligen utför Reactive Aggregator REF inkrementellt glidfönsteraggregation och kan hantera OoO vickt i O(log n) tid.
General Incremental Sliding-Window Aggregation
{'venue': 'PVLDB', 'journal': 'PVLDB', 'mag_field_of_study': ['Computer Science']}