Package com.northconcepts.datapipeline.group
package com.northconcepts.datapipeline.group
Summarize batch and streaming data similar to "group by" in SQL.
-
ClassesClassDescriptionDeprecated.Base class for the set functions an
AggregateReaderapplies to each record passing through it.Determines whenGroupByReadercloses an open sliding window.Determines whenGroupByReaderopens a new sliding window.A proxy that divides records into groups and applies summary operations to each group; similar to "group by" in SQL, but applied to streaming data.SeeFieldPathfor supported field name expressions.Accumulates oneGroupOperation's result for a single group within aWindow.Windows accept detail data for aggregation while open and only yield its summary after being closed.
GroupByReaderinstead.