Package | Description |
---|---|
io.druid.server.coordination |
Modifier and Type | Field and Description |
---|---|
static SegmentChangeRequestHistory.Counter |
SegmentChangeRequestHistory.Counter.ZERO |
Modifier and Type | Method and Description |
---|---|
SegmentChangeRequestHistory.Counter |
SegmentChangeRequestsSnapshot.getCounter() |
SegmentChangeRequestHistory.Counter |
SegmentChangeRequestHistory.getLastCounter() |
SegmentChangeRequestHistory.Counter |
SegmentChangeRequestHistory.Counter.inc() |
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.
|
boolean |
SegmentChangeRequestHistory.Counter.matches(SegmentChangeRequestHistory.Counter other) |
static SegmentChangeRequestsSnapshot |
SegmentChangeRequestsSnapshot.success(SegmentChangeRequestHistory.Counter counter,
List<DataSegmentChangeRequest> requests) |
Constructor and Description |
---|
SegmentChangeRequestsSnapshot(boolean resetCounter,
String resetCause,
SegmentChangeRequestHistory.Counter counter,
List<DataSegmentChangeRequest> requests) |
Copyright © 2011–2018. All rights reserved.