SpringCloud/stream-applications
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
220 Commits 10 Branches 0 Tags
def034e2db07edcf378efb9e9505d3e16cd1d23b
Commit Graph

40 Commits

Author SHA1 Message Date
Soby Chacko
73a3e55299 Functions: Release - 1.0.0-M3 2020-09-29 14:59:33 -04:00
David Turanski
f7efc39164 Remove SplitterFunction autoconfiguration for sources 2020-09-14 14:00:52 -04:00
Christian Tzolov
b9f6d9e9a9 Fix another filter function checkstyle issue 2020-08-31 08:47:15 +02:00
Christian Tzolov
d899d0856b Fix a [ImportOrder] checkstyle issue 2020-08-31 08:05:36 +02:00
Artem Bilan
a91aa2cd3f 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
d962e6e233 Fixing missing filter processor properties in README 2020-08-25 14:07:06 -04:00
Artem Bilan
b27897227d 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
d13a1fceaf Add max-buffer-size and fix app deps 2020-08-13 13:27:15 -04:00
David Turanski
eee707da00 Refactor to use SpEL in function properties 
* Clean up per review
 2020-08-12 15:39:56 -04:00
Soby Chacko
3d01487565 Remove duplicate dependency in twitter-function 
Add relativePath to core parent
 2020-08-07 16:50:15 -04:00
Christian Tzolov
2ffbe371b6 Remove double quotes in the properties comments 2020-08-05 15:18:25 +02:00
David Turanski
f8c342077c Support filterFunction and spelFunction composition 2020-07-28 12:26:26 -04:00
David Turanski
562aa5c990 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
d59e4f5d86 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
7066283aa2 Functions: Release - 1.0.0-M2 2020-07-13 14:43:36 -04:00
Soby Chacko
49468e6148 Renaming internal test boot applications in functions 2020-07-02 18:31:58 -04:00
Soby Chacko
5c59ff6823 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
327641fb05 Functions: Release - 1.0.0-M1 2020-06-25 17:42:02 -04:00
Christian Tzolov
f470152810 Replace http https 2020-06-25 18:29:17 +02:00
Christian Tzolov
c379b680ba fix readme links 2020-06-25 14:33:55 +02:00
Christian Tzolov
19c4eca165 fix readme links 2020-06-25 14:30:17 +02:00
Christian Tzolov
e2932661dd semantic segmentation processor 2020-06-25 12:41:39 +02:00
Christian Tzolov
ebe05bc315 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
052f86cf91 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
9792768d55 Address twitter review suggestions 2020-06-24 09:58:26 +02:00
Christian Tzolov
873f17414e 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
9bf8dcc4e7 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
f07085992b Add composite function support for the sources 2020-06-19 18:15:26 -04:00
David Turanski
1a6be1c031 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
f98f6f5b20 Implement Tasklauncher function 
Clean up test
 2020-06-16 18:00:45 -04:00
Soby Chacko
f6a057d8b2 README changes. 
Properties cleanup.
 2020-06-04 15:55:18 -04:00
Soby Chacko
1528886cfa Update versions 
Fix tests
 2020-06-03 13:27:22 -04:00
David Turanski
1ef16b9b3e 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
730332f3e6 Update test config class names 2020-05-15 14:01:00 -04:00
Soby Chacko
0e23e07127 Add Header Enricher function 2020-05-08 14:17:09 -04:00
Soby Chacko
e2d59034c7 Update functions to 1.0.0-SNAPSHOT from BUILD-SNAPSHOT 2020-05-07 18:11:18 -04:00
Soby Chacko
f61fbb4dc9 Introducing checkstyle changes for functions 2020-05-06 17:42:11 -04:00
David Turanski
5819e9a8b7 Fix groupId 2020-05-05 15:43:17 -04:00
Soby Chacko
45fb7a55d2 Remove unnecessary .gitignore files 2020-05-04 17:56:39 -04:00
Soby Chacko
517ccd5b40 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