Package com.northconcepts.datapipeline.group

Summarize batch and streaming data similar to "group by" in SQL.

See: Description

Class Summary

Class	Description
AggregateReader	Deprecated use GroupByReader instead.
AggregateReader.AggregateOperation
CloseWindowStrategy	Determines when GroupByReader closes an open sliding window.
CreateWindowStrategy	Determines when GroupByReader opens a new sliding window.
GroupByReader	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.
GroupOperation<T>	See FieldPath for supported field name expressions.
GroupOperationField<T>
Window	Windows accept detail data for aggregation while open and only yield its summary after being closed.

Package com.northconcepts.datapipeline.group Description

Summarize batch and streaming data similar to "group by" in SQL.