Commit Graph

45 Commits

Author SHA1 Message Date
Artem Bilan
daebf0f786 Limit aggregator tests for 10 seconds to wait 2021-04-07 12:02:02 -04:00
Soby Chacko
d0a0df5a44 Restructuing with maven revision feature
Preserving the maven revision feature from the previous commit,
but perform a bit more restructuring the hierarchy.
2020-10-13 15:17:52 -04:00
Daniel Frey
724c4ace5f Refactor hardcoded versions in functions submodule branches
This is so they can be updated in a minimal amount of places and leverage the maven hierarchy to propagate them where appropriate.
While working with SNAPSHOT releases of Spring Boot, Spring Integration, and Spring Cloud, it required touching every pom.xml file
in order to reflect the use of the SNAPSHOT. After this change, it will only be required to change the property in the top
functions pom.xml and the versions will reflect to all submodules.

Maven introduced the ability use a key property, revision to propagate this information to the <parent> declarations in each pom.

This was enabled in Maven 3.5+
https://maven.apache.org/maven-ci-friendly.html
2020-10-13 15:15:59 -04:00
David Turanski
80f9545ae9 Upgrade apps to 3.0.0-SNAPSHOT 2020-10-11 10:43:16 -04:00
Soby Chacko
86f0ca0c07 Next version updates
Functions: 1.0.0-SNAPSHOT
  Core Apps: 3.0.0-SNAPSHOT
  Apps: 3.0.0-SNAPSHOT
  Aggregate Next:2020.0.0-SNAPSHOT
2020-09-29 18:28:20 -04:00
Soby Chacko
e1d29f8d24 Functions: Release - 1.0.0-M3 2020-09-29 14:59:33 -04:00
David Turanski
13fe23ccc0 Remove SplitterFunction autoconfiguration for sources 2020-09-14 14:00:52 -04:00
Christian Tzolov
fcbf941457 Fix another filter function checkstyle issue 2020-08-31 08:47:15 +02:00
Christian Tzolov
35608d28cb Fix a [ImportOrder] checkstyle issue 2020-08-31 08:05:36 +02:00
Artem Bilan
0144476a25 GH-110: Fix filter function for emitting null (#111)
* GH-110: Fix filter function for emitting `null`

Fixes https://github.com/spring-cloud/stream-applications/issues/110

Turns out when functions are composed in the Spring Cloud Stream environment,
they are called via reactive wrappers which don't allow to emit `null` from the
`map()` operator.

* Make `filterFunction` fully reactive to reply on the `Flux.filter()` operator
* Add `config-common` for auto-conversion string configuration options into `Expression` instances
* Add `spring-boot-starter-json` dependency since it is required by the `SpelExpressionConverterConfiguration`
* Add `reactor-test` dependency to test the final solution
* Remove redundant dependencies from the `filter-processor`

* * Add `proxyBeanMethods = false` into `FilterFunctionConfiguration`
* Fix default expression to `true` instead of `payload`, which does not fit to filter logic
* Fix JavaDoc for `expression` property
* Remove redundant `application.properties` from the `filter-function`
2020-08-28 15:55:08 -04:00
Soby Chacko
800b177852 Fixing missing filter processor properties in README 2020-08-25 14:07:06 -04:00
Artem Bilan
4463c1afb6 Add Aggregator function & processor
* Have all the required dependencies in class path which give us a `MessageGroupStore` implementation
* Disable all their auto-configurations in the `ExcludeStoresAutoConfigurationEnvironmentPostProcessor`
* Enable only those which are configured by the `aggregator.messageStoreType` property
* Implement a fully reactive function around an aggregator making an interaction via a pair of `FluxMessageChannel`
* Fix checkstyle issues
* Change the app generator maven plugin to new coordinates
2020-08-20 15:54:51 -04:00
David Turanski
6b0f08712b Add max-buffer-size and fix app deps 2020-08-13 13:27:15 -04:00
David Turanski
93d87a4155 Refactor to use SpEL in function properties
* Clean up per review
2020-08-12 15:39:56 -04:00
Soby Chacko
0c07b4af05 Remove duplicate dependency in twitter-function
Add relativePath to core parent
2020-08-07 16:50:15 -04:00
Christian Tzolov
f8ed9f9c38 Remove double quotes in the properties comments 2020-08-05 15:18:25 +02:00
David Turanski
be818e02de Support filterFunction and spelFunction composition 2020-07-28 12:26:26 -04:00
David Turanski
30caf06198 Fix function definition property (#91)
* Remove deprecated spring.cloud.stream.function.definition property

* Restore tasklauncher-function

Co-authored-by: David Turanski <dturanski@pivotal.io>
2020-07-20 18:23:30 -04:00
Soby Chacko
d29a238569 Next version updates
Functions: 1.0.0-SNAPSHOT
  Core Apps: 3.0.0-SNAPSHOT
  Apps: 3.0.0-SNAPSHOT
  Aggregate Next:2020.0.0-SNAPSHOT
2020-07-13 16:02:05 -04:00
Soby Chacko
0e685334b2 Functions: Release - 1.0.0-M2 2020-07-13 14:43:36 -04:00
Soby Chacko
4b1dd074ba Renaming internal test boot applications in functions 2020-07-02 18:31:58 -04:00
Soby Chacko
51ed4d2f6d Next version updates
Functions: 1.0.0-SNAPSHOT
  Core Apps: 3.0.0-SNAPSHOT
  Apps: 3.0.0-SNAPSHOT
  Aggregate Build: 2020.0.0-SNAPSHOT
2020-06-26 13:49:35 -04:00
Soby Chacko
87e4a2d740 Functions: Release - 1.0.0-M1 2020-06-25 17:42:02 -04:00
Christian Tzolov
a1e26baba8 Replace http https 2020-06-25 18:29:17 +02:00
Christian Tzolov
2a965d1fdc fix readme links 2020-06-25 14:33:55 +02:00
Christian Tzolov
e60184839a fix readme links 2020-06-25 14:30:17 +02:00
Christian Tzolov
db740ebdfd semantic segmentation processor 2020-06-25 12:41:39 +02:00
Christian Tzolov
dffb467da4 Tensorflow functions and applications
* initial step
 * Tensorflow models functional model redesign

      -- Based on https://tzolov.github.io/mind-model-services
      -- Resolves #5

 * Add object detection processor README
 * Add image recognition processor README
 * Initial Tensorflow commonn README
 * Initial Tensorflow commonn README
 * Tensorflow common diagram
 * Tensorflow docs code
 * Tensorflow docs code snippets improve
 * Tensorflow docs code snippets improve
 * Tensorflow docs code snippets improve
 * Tensorflow docs code snippets improve
 * Add semantic segmentation function. add object detecteion function readme
 * oo images
 * Furether oo readme improvments
 * Final obj detection readme fixes
 * Add image recognition readme
 * Add image recognition readme 2
 * Semantic segmentation readme
 * Segmentation readme
 * Semantic segmentation readme 3
 * Fix image recognition and object detcion app starter dependecies

 * Add metadata for Tensorflow apps
2020-06-24 18:37:03 -04:00
Christian Tzolov
3bb9e066b9 Port in the Geo and Users twitter function. Fix issue with handling SpEL expression porperties in the twitter functions. 2020-06-24 12:58:47 +02:00
Christian Tzolov
b1a57fc191 Address twitter review suggestions 2020-06-24 09:58:26 +02:00
Christian Tzolov
1892736b98 Twitter functional apps
* Streaming source
* Add twitter search and messasge sources
* Add more twitter source, sink and processors
* Add IT tests for twitter update sink
* Add IT tests for twitter message sink
* Add IT tests for twitter trend processor
* twitter suppliers readme
* twitter consumers readme
* twitter functions readme
* Disable TwitterStreamSourceTests
2020-06-23 14:48:34 -04:00
David Turanski
dab3da942d Upgrade Spring Cloud Stream to Horsham.SR6 and Spring Cloud Function to 3.0.8.RELEASE 2020-06-22 15:29:01 -04:00
David Turanski
d56525b27a Add composite function support for the sources 2020-06-19 18:15:26 -04:00
David Turanski
92b2fc2f39 Implement task-launch-request-function
Removed task-launch-request from stream-applications-core

Fix Checkstyle errors
2020-06-19 17:50:44 -04:00
David Turanski
8bdd18a34a Implement Tasklauncher function
Clean up test
2020-06-16 18:00:45 -04:00
Soby Chacko
da04bb3050 README changes.
Properties cleanup.
2020-06-04 15:55:18 -04:00
Soby Chacko
2b1a75b413 Update versions
Fix tests
2020-06-03 13:27:22 -04:00
David Turanski
27e53d1fba Add http-request-function and processor app
* Update README
* Clean up per review
* Added function README
* Remove `HttpRequestProcessorProperties$Retry` from the whitelist
2020-05-28 11:01:36 -04:00
Soby Chacko
696af34459 Update test config class names 2020-05-15 14:01:00 -04:00
Soby Chacko
fa0a1844e8 Add Header Enricher function 2020-05-08 14:17:09 -04:00
Soby Chacko
e361e59aee Update functions to 1.0.0-SNAPSHOT from BUILD-SNAPSHOT 2020-05-07 18:11:18 -04:00
Soby Chacko
2dfafcd571 Introducing checkstyle changes for functions 2020-05-06 17:42:11 -04:00
David Turanski
9bde4d51f0 Fix groupId 2020-05-05 15:43:17 -04:00
Soby Chacko
b4c511a689 Remove unnecessary .gitignore files 2020-05-04 17:56:39 -04:00
Soby Chacko
6edfb852f9 Initial Commit
Migrating the existing structure from the following location:
https://github.com/spring-cloud-stream-app-starters/stream-applications/tree/restructuring
2020-05-04 17:51:05 -04:00