public class SegmentListerResource extends Object
Modifier and Type | Field and Description |
---|---|
protected com.fasterxml.jackson.databind.ObjectMapper |
jsonMapper |
protected static EmittingLogger |
log |
protected com.fasterxml.jackson.databind.ObjectMapper |
smileMapper |
Constructor and Description |
---|
SegmentListerResource(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
com.fasterxml.jackson.databind.ObjectMapper smileMapper,
BatchDataSegmentAnnouncer announcer,
SegmentLoadDropHandler loadDropRequestHandler) |
Modifier and Type | Method and Description |
---|---|
void |
applyDataSegmentChangeRequests(long timeout,
List<DataSegmentChangeRequest> changeRequestList,
javax.servlet.http.HttpServletRequest req)
This endpoint is used by HttpLoadQueuePeon to assign segment load/drop requests batch.
|
void |
getSegments(long counter,
long hash,
long timeout,
javax.servlet.http.HttpServletRequest req)
This endpoint is used by HttpServerInventoryView to keep an up-to-date list of segments served by
historical/realtime nodes.
|
protected static final EmittingLogger log
protected final com.fasterxml.jackson.databind.ObjectMapper jsonMapper
protected final com.fasterxml.jackson.databind.ObjectMapper smileMapper
@Inject public SegmentListerResource(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.fasterxml.jackson.databind.ObjectMapper smileMapper, @Nullable BatchDataSegmentAnnouncer announcer, @Nullable SegmentLoadDropHandler loadDropRequestHandler)
public void getSegments(long counter, long hash, long timeout, @Context javax.servlet.http.HttpServletRequest req) throws IOException
counter
- counter received in last response.hash
- hash received in last response.timeout
- after which response is sent even if there are no new segment updates.req
- IOException
public void applyDataSegmentChangeRequests(long timeout, List<DataSegmentChangeRequest> changeRequestList, @Context javax.servlet.http.HttpServletRequest req) throws IOException
IOException
Copyright © 2011–2018. All rights reserved.