} L190: docIds.addAll(resultIds); L191: Map<String, Object> scrollBody = new HashMap<>(); L192: scrollBody.put("scroll", "1m"); L193: scrollBody.put("scroll_id", scrollId); L194: response = given().contentType("application/json").body(scrollBody).get(getEsUrl() + "/_search/scroll"); L195: jsonPath = JsonPath.from(response.asString()); L196: } L197: L198: for (String docId : docIds) { L199: given(...

e().equals(type)) { L86: return FormatType.FAVORITES; L87: } L88: if (FormatType.PING.name().equals(type)) { L89: return FormatType.PING; L90: } L91: if (FormatType.SCROLL.name().equals(type)) { L92: return FormatType.SCROLL; L93: } L94: if (FormatType.SUGGEST.name().equals(type)) { L95: return FormatType.SUGGEST; L96: } L97: L98: // default L99: return FormatType.OTHER; L100: } L101: L102:...

,sv,ta,te,th,tl,tr,uk,ur,vi,zh_CN,zh_TW,zh L169:api.access.token.length=60 L170:api.access.token.required=false L171:api.access.token.request.parameter= L172:api.admin.access.permissions=Radmin-api L173:api.search.accept.referers= L174:api.search.scroll=false L175:api.json.response.headers= L176:api.json.response.exception.included=false L177:api.gsa.response.headers= L178:api.gsa.response.exception.included=false L179:api.dashboard.response.headers= L180:api.cors.allow.origin=* L181:api.cors.allow.methods=GET,...

element[upperSide];\n}\n","import getScroll from './getScroll';\n\n/*\n * Sum or subtract the element scroll values (left and top) from a given rect object\n * @method\n * @memberof Popper.Utils\n * @param {Object} rect - Rect object you want to change\n * @param {HTMLElement} element - The element from the function reads the scroll values\n * @param {Boolean} subtract - set to true if you want to subtract the scroll values\n * @return {Object} rect - The modifier rect object\n */\nexport default function includeScroll(rect,...

ception e) { L262: if (logger.isDebugEnabled()) { L263: logger.debug("Failed to process a scroll request.", e); L264: } L265: writeJsonResponse(HttpServletResponse.SC_BAD_REQUEST, e); L266: } catch (final Exception e) { L267: if (logger.isDebugEnabled()) { L268: logger.debug("Failed to process a scroll request.", e); L269: } L270: writeJsonResponse(HttpServletResponse.SC_INTERNAL_SERVER_ERROR, e);...

OutputStream getXContentOutputStream(final ToXContent xContent, final MediaType mediaType) { L53: return getXContentBuilderOutputStream((builder, params) -> xContent.toXContent(builder, params), mediaType); L54: } L55: L56: public static long scroll(final String index, final Function<SearchHit, Boolean> callback) { L57: final SearchEngineClient client = ComponentUtil.getSearchEngineClient(); L58: return client.<SearchHit> scrollSearch(index, searchRequestBuilder -> true, (searchResponse,...

asStream(filename).contentTypeOctetStream().stream(out -> { L88: try (final BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(out.stream(), Constants.CHARSET_UTF_8))) { L89: SearchEngineUtil.scroll(index, hit -> { L90: try { L91: writer.write("{\"index\":{\"_index\":\"" + index + "\",\"_id\":\"" L92: + StringEscapeUtils.escapeJson(hit.getId()) +...

=n*r,e.left+=i*r,e.right+=i*r,e}function m(e,t){var o='x'===t?'Left':'Top',n='Left'==o?'Right':'Bottom';return parseFloat(e['border'+o+'Width'])+parseFloat(e['border'+n+'Width'])}function h(e,t,o,n){return ee(t['offset'+e],t['scroll'+e],o['client'+e],o['offset'+e],o['scroll'+e],r(10)?parseInt(o['offset'+e])+parseInt(n['margin'+('Height'===e?'Top':'Left')])+parseInt(n['margin'+('Height'===e?'Bottom':'Right')]):0)}function c(e){var t=e.body,o=e.documentElement,n=r(10)&&getComputedStyle(o);return{h...

deleteScrollContext(scrollId); L959: } L960: return count; L961: } L962: L963: protected void deleteScrollContext(final String scrollId) { L964: if (scrollId != null) { L965: client.prepareClearScroll().addScrollId(scrollId) L966: .execute(wrap(res -> {}, e -> logger.warn("Failed to clear the scroll context.", e))); L967: } L968: } L969: L970: protected <T> T get(final String index, final String id, final SearchCondition<GetRequestBuilder>...

QueryFieldConfig queryFieldConfig = ComponentUtil.getQueryFieldConfig(); L206: queryHelper.processSearchPreference(searchRequestBuilder, userBean, query); L207: return SearchConditionBuilder.builder(searchRequestBuilder).scroll().query(query).size(pageSize) L208: .responseFields(queryFieldConfig.getScrollResponseFields()).searchRequestType(params.getType()).build(); L209: }, (searchResponse, hit) -> { L210: final...