aggregate

README

tibco-aggregate

This activity provides your flogo application with rudimentary aggregation.

Installation

flogo add activity github.com/TIBCOSoftware/flogo-contrib/activity/aggregate

Schema

Inputs and Outputs:

{
  "input":[
    {
      "name": "function",
      "type": "string",
      "allowed" : ["block_avg", "moving_avg", "timeblockavg"]
    },
    {
      "name": "windowSize",
      "type": "integer",
    },
    {
      "name": "autoReset",
      "type": "boolean"
    },
    {
      "name": "value",
      "type": "number"
    }
  ],
  "output": [
    {
      "name": "result",
      "type": "number"
    },
    {
      "name": "report",
      "type": "boolean"
    }
  ]
}

Settings

Setting	Description
function	The aggregate fuction, currently only average is supported
windowSize	The window size of the values to aggregate
autoReset	Flag indicating if the window should be reset after it reports
value	The value to aggregate

Configuration Examples

Configure a task to aggregate a 'temperature' attribute with a moving window of size 5:

{
  "id": 3,
  "type": 1,
  "activityType": "tibco-aggregate",
  "name": "Aggregate Temperature",
  "attributes": [
      { "name": "function", "value": "average" }
      { "name": "windowSize", "value": "5" }
  ]
  "inputMappings": [
    { "type": 1, "value": "temperature", "mapTo": "value" }
  ]
}

Documentation

Index

• func NewActivity(metadata *activity.Metadata) activity.Activity
• type AggregateActivity
  • func (a *AggregateActivity) Eval(context activity.Context) (done bool, err error)
  • func (a *AggregateActivity) Metadata() *activity.Metadata

Functions

func NewActivity

func NewActivity(metadata *activity.Metadata) activity.Activity

NewActivity creates a new AppActivity

Types

type AggregateActivity

type AggregateActivity struct {
	// contains filtered or unexported fields
}

AggregateActivity is an Activity that is used to Aggregate a message to the console inputs : {function, windowSize, autoRest, value} outputs: {result, report}

func (*AggregateActivity) Eval

func (a *AggregateActivity) Eval(context activity.Context) (done bool, err error)

Eval implements api.Activity.Eval - Aggregates the Message

func (*AggregateActivity) Metadata

func (a *AggregateActivity) Metadata() *activity.Metadata

Metadata returns the activity's metadata