Aggregation Jobs

Table of Contents

Aggregation properties
Configuration properties

Aggregation jobs compile your raw signals into aggregated signals. Most Fusion jobs that consume signals require aggregated signals.

Default job name

COLLECTION_NAME_click_signals_aggregation

Input

Raw signals (the COLLECTION_NAME_signals collection by default)

Output

Aggregated signals (the COLLECTION_NAME_signals_aggr collection by default)

query

count_i

type

timstamp_tdt

user_id

doc_id

session_id

fusion_query_id

Required signals fields:

[1]

1 Required if you are using response signals.

Aggregation properties

The aggregation process is specified by an aggregation type consisting of the following list of properties:

Name Description

Name	Description
`id`	Aggregation ID
`groupingFields`	List of signal field names
`signalTypes`	List of signal types
`aggregator`	Symbolic name of the aggregator implementation
`selectQuery`	Query string, default `:`
`sort`	Ordering of aggregated signals
`timeRange`	String specifying time range, e.g., `[* TO NOW]`
`outputPipeline`	Pipeline ID for processing aggregated events
`outputCollection`	Output collection name
`rollupPipeline`	Rollup pipeline ID
`rollupAggregator`	Name of the aggregator implementation used for rollups
`sourceRemove`	Boolean, default is false
`sourceCatchup`	Boolean, default is true
`outputRollup`	Boolean, default is true
`aggregates`	List of aggregation functions
`params`	Arbitrary parameters to be used by specific aggregator implementations

id

Aggregation ID

groupingFields

List of signal field names

signalTypes

List of signal types

aggregator

Symbolic name of the aggregator implementation

selectQuery

Query string, default *:*

sort

Ordering of aggregated signals

timeRange

String specifying time range, e.g., [* TO NOW]

outputPipeline

Pipeline ID for processing aggregated events

outputCollection

Output collection name

rollupPipeline

Rollup pipeline ID

rollupAggregator

Name of the aggregator implementation used for rollups

sourceRemove

Boolean, default is false

sourceCatchup

Boolean, default is true

outputRollup

Boolean, default is true

aggregates

List of aggregation functions

params

Arbitrary parameters to be used by specific aggregator implementations

Aggregation Jobs

Aggregation properties

Configuration properties