Skip to content

Commit

Permalink
add some documentation/notes on inner design
Browse files Browse the repository at this point in the history
  • Loading branch information
Hendrik Muhs committed Oct 18, 2018
1 parent 50669ca commit f331658
Showing 1 changed file with 6 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,12 @@ protected IterationResult<Map<String, Object>> doProcess(SearchResponse searchRe
}

/*
* Parses the result and creates indexable documents
* Parses the result and creates a stream of indexable documents
*
* Implementation decisions:
*
* Extraction uses generic maps as intermediate exchange format in order to hook in ingest pipelines/processors
* in later versions, see {@link IngestDocument).
*/
private Stream<IndexRequest> processBucketsToIndexRequests(CompositeAggregation agg) {
String indexName = job.getConfig().getDestinationIndex();
Expand Down

0 comments on commit f331658

Please sign in to comment.