stream

stream copied to clipboard

Bumps [github.com/gorilla/websocket](https://github.com/gorilla/websocket) from 1.4.0 to 1.4.1. Release notes Sourced from github.com/gorilla/websocket's releases. v1.4.1 Notable Changes ⚠️ This release fixes a potential denial-of-service (DoS) vector in gorilla/websocket, and we recommend that...

dependabot[bot]

Hello, when I run the command "flogo create -f agg-flogo.json myApp" on Ubuntu, it shows: ``` Creating initial project structure, this might take a few seconds ... all dirs contained...

lwxn

Conditional filter

4

Added support to provide custom filter conditions in filter activity. Example usage - Filter all streams which meets certain condition e.g input value > threshold, input string contains keyword substring.

vpawar-tibco

Aggregator Code Bug Fixes & Example In Go Code

1

- Removed the reference to `activity.Context.GetSharedTempData()` because it returns `nil`, for `activityContext`, according to the flogo-project/core api - Add a `sharedData` map to the `aggregate` activity, so there is no...

n-is

Can we have some examples on how to use all the features of this project in go code?

n-is

What is the Expected behaviour of sum function in a timeTumbling window type.

2

I am running the steams example from > Labs > Streams: Aggregate and I am curious about the expected behaviour when using a SUM style aggregate approach. When I run...

bloomfm100

Add a sample for joining multiple streams into a pipeline.

mellistibco