Package | Description |
---|---|
io.druid.server.coordination |
Modifier and Type | Method and Description |
---|---|
static SegmentChangeRequestsSnapshot |
SegmentChangeRequestsSnapshot.fail(String resetCause) |
static SegmentChangeRequestsSnapshot |
SegmentChangeRequestsSnapshot.success(SegmentChangeRequestHistory.Counter counter,
List<DataSegmentChangeRequest> requests) |
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<SegmentChangeRequestsSnapshot> |
SegmentChangeRequestHistory.getRequestsSince(SegmentChangeRequestHistory.Counter counter)
Returns a Future that , on completion, returns list of segment updates and associated counter.
|
com.google.common.util.concurrent.ListenableFuture<SegmentChangeRequestsSnapshot> |
BatchDataSegmentAnnouncer.getSegmentChangesSince(SegmentChangeRequestHistory.Counter counter)
Returns Future that lists the segment load/drop requests since given counter.
|
Copyright © 2011–2018. All rights reserved.