OpenSearch/modules/ingest-common
Przemko Robakowski 3fb7ad0e67
[7.x] Refactor ForEachProcessor to use iteration instead of recursion (#51104) (#51322)
* Refactor ForEachProcessor to use iteration instead of recursion (#51104)

* Refactor ForEachProcessor to use iteration instead of recursion

This change makes ForEachProcessor iterative and still non-blocking.
In case of non-async processors we use single for loop and no recursion at all.
In case of async processors we continue work on either current thread or thread
started by downstream processor, whichever is slower (usually processor thread).
Everything is synchronised by single atomic variable.

Relates #50514

* Update IngestCommonPlugin.java
2020-01-22 20:03:37 +01:00
..
src [7.x] Refactor ForEachProcessor to use iteration instead of recursion (#51104) (#51322) 2020-01-22 20:03:37 +01:00
build.gradle Backport: add templating support to pipeline processor (#49643) 2019-11-27 15:53:40 +01:00