snippet for elasticsearch Java scroll API

elasticsearch scroll API.java

SearchResponse scrollResp = client.prepareSearch("filebeat-*")
                      // set the timeout value - important for long running scrolls
	                    .setScroll(new TimeValue(60*60))
	                    // example of an "OR" filter using "should" boolean expression
	                    .setQuery(QueryBuilders.boolQuery().should(QueryBuilders.termQuery("Type", "TRAFFIC"))
	                    		.should(QueryBuilders.termQuery("pfsense_type", "filterlog:")).minimumShouldMatch("1"))
	                    // example of filter to query documents between a time range
	                    .setPostFilter(QueryBuilders.rangeQuery("@timestamp").from(QueryFrom).to(QueryTo))
	                    .setSize(1000).execute().actionGet(); //10,000 hits per shard will be returned for each scroll
	            
	            //Scroll until no hits are returned
	            while (true) {
	            	
	                for (SearchHit hit : scrollResp.getHits().getHits()) {
	                	//process the search hit
	                }
	                
	                //update the scroll ID
	                scrollResp = client.prepareSearchScroll(scrollResp.getScrollId()).setScroll(new TimeValue(timeValueSetting)).execute().actionGet();
	                
	                //Break condition: No hits are returned so the scroll is finished
	                if (scrollResp.getHits().getHits().length == 0) {
	                    break;
	                }
	            }

Hi, @dvas0004! Thanks for the code snippet! Did you try this approach with RxJava?

LGTM!