Examples of org.elasticsearch.search.query.ScrollQuerySearchResult

org.elasticsearch.search.query.ScrollQuerySearchResult
@author kimchy (shay.banon)

        try {
            contextProcessing(context);
            processScroll(request, context);
            contextProcessedSuccessfully(context);
            queryPhase.execute(context);
            return new ScrollQuerySearchResult(context.queryResult(), context.shardTarget());
        } catch (RuntimeException e) {
            logger.trace("Query phase failed", e);
            freeContext(context);
            throw e;
        } finally {

View Full Code Here

    }


    public void sendExecuteQuery(DiscoveryNode node, final InternalScrollSearchRequest request, final SearchServiceListener<QuerySearchResult> listener) {
        if (clusterService.state().nodes().localNodeId().equals(node.id())) {
            try {
                ScrollQuerySearchResult result = searchService.executeQueryPhase(request);
                listener.onResult(result.queryResult());
            } catch (Exception e) {
                listener.onFailure(e);
            }
        } else {
            transportService.sendRequest(node, SearchQueryScrollTransportHandler.ACTION, request, new BaseTransportResponseHandler<ScrollQuerySearchResult>() {


                @Override public ScrollQuerySearchResult newInstance() {
                    return new ScrollQuerySearchResult();
                }


                @Override public void handleResponse(ScrollQuerySearchResult response) {
                    listener.onResult(response.queryResult());
                }

View Full Code Here

        @Override public InternalScrollSearchRequest newInstance() {
            return new InternalScrollSearchRequest();
        }


        @Override public void messageReceived(InternalScrollSearchRequest request, TransportChannel channel) throws Exception {
            ScrollQuerySearchResult result = searchService.executeQueryPhase(request);
            channel.sendResponse(result);
        }

View Full Code Here

        } else {
            transportService.sendRequest(node, QUERY_SCROLL_ACTION_NAME, request, new BaseTransportResponseHandler<ScrollQuerySearchResult>() {


                @Override
                public ScrollQuerySearchResult newInstance() {
                    return new ScrollQuerySearchResult();
                }


                @Override
                public void handleResponse(ScrollQuerySearchResult response) {
                    listener.onResult(response.queryResult());

View Full Code Here

            return new InternalScrollSearchRequest();
        }


        @Override
        public void messageReceived(InternalScrollSearchRequest request, TransportChannel channel) throws Exception {
            ScrollQuerySearchResult result = searchService.executeQueryPhase(request);
            channel.sendResponse(result);
        }

View Full Code Here

TOP

Related Classes of org.elasticsearch.search.query.ScrollQuerySearchResult

org.elasticsearch.search.action.SearchServiceTransportAction

org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryScrollTransportHandler

org.elasticsearch.search.SearchService

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.