Package | Description |
---|---|
io.druid.server.coordination | |
io.druid.server.http |
Modifier and Type | Class and Description |
---|---|
class |
SegmentChangeRequestDrop |
class |
SegmentChangeRequestLoad |
class |
SegmentChangeRequestNoop |
Modifier and Type | Method and Description |
---|---|
DataSegmentChangeRequest |
SegmentLoadDropHandler.DataSegmentChangeRequestAndStatus.getRequest() |
Modifier and Type | Method and Description |
---|---|
List<DataSegmentChangeRequest> |
SegmentChangeRequestsSnapshot.getRequests() |
Modifier and Type | Method and Description |
---|---|
void |
SegmentChangeRequestHistory.addSegmentChangeRequest(DataSegmentChangeRequest request)
Add single segment change update.
|
Modifier and Type | Method and Description |
---|---|
void |
SegmentChangeRequestHistory.addSegmentChangeRequests(List<DataSegmentChangeRequest> requests)
Add batch of segment changes update.
|
com.google.common.util.concurrent.ListenableFuture<List<SegmentLoadDropHandler.DataSegmentChangeRequestAndStatus>> |
SegmentLoadDropHandler.processBatch(List<DataSegmentChangeRequest> changeRequests) |
static SegmentChangeRequestsSnapshot |
SegmentChangeRequestsSnapshot.success(SegmentChangeRequestHistory.Counter counter,
List<DataSegmentChangeRequest> requests) |
Constructor and Description |
---|
DataSegmentChangeRequestAndStatus(DataSegmentChangeRequest request,
SegmentLoadDropHandler.Status status) |
Constructor and Description |
---|
SegmentChangeRequestsSnapshot(boolean resetCounter,
String resetCause,
SegmentChangeRequestHistory.Counter counter,
List<DataSegmentChangeRequest> requests) |
Modifier and Type | Method and Description |
---|---|
void |
SegmentListerResource.applyDataSegmentChangeRequests(long timeout,
List<DataSegmentChangeRequest> changeRequestList,
javax.servlet.http.HttpServletRequest req)
This endpoint is used by HttpLoadQueuePeon to assign segment load/drop requests batch.
|
Copyright © 2011–2018. All rights reserved.