Package com.splunk.shuttl.server.distributed

Examples of com.splunk.shuttl.server.distributed.RequestOnSearchPeers


      bucketsWithSize.add(getBucketWithSize(b));

    JSONObject jsonObject = JsonUtils.writeKeyValueAsJson(
        JsonObjectNames.BUCKET_COLLECTION, bucketsWithSize);

    RequestOnSearchPeers requestOnSearchPeers = RequestOnSearchPeers.createGet(
        ShuttlConstants.ENDPOINT_LIST_BUCKETS, index, from, to);
    SearchPeerResponse peerResponse = requestOnSearchPeers.execute();
    List<JSONObject> jsons = peerResponse.jsons;
    jsons.add(jsonObject);

    return RestUtil.mergeBucketCollectionsAndAddTotalSize(jsons)
        .put(JsonObjectNames.EXCEPTIONS, peerResponse.exceptions).toString();
View Full Code Here

TOP

Related Classes of com.splunk.shuttl.server.distributed.RequestOnSearchPeers

Copyright © 2018 www.massapicom. All rights reserved.
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.