public class SegmentChangeRequestHistory extends Object
Modifier and Type | Class and Description |
---|---|
static class |
SegmentChangeRequestHistory.Counter |
Constructor and Description |
---|
SegmentChangeRequestHistory() |
SegmentChangeRequestHistory(int maxSize) |
Modifier and Type | Method and Description |
---|---|
void |
addSegmentChangeRequest(DataSegmentChangeRequest request)
Add single segment change update.
|
void |
addSegmentChangeRequests(List<DataSegmentChangeRequest> requests)
Add batch of segment changes update.
|
SegmentChangeRequestHistory.Counter |
getLastCounter() |
com.google.common.util.concurrent.ListenableFuture<SegmentChangeRequestsSnapshot> |
getRequestsSince(SegmentChangeRequestHistory.Counter counter)
Returns a Future that , on completion, returns list of segment updates and associated counter.
|
public SegmentChangeRequestHistory()
public SegmentChangeRequestHistory(int maxSize)
public void addSegmentChangeRequests(List<DataSegmentChangeRequest> requests)
public void addSegmentChangeRequest(DataSegmentChangeRequest request)
public com.google.common.util.concurrent.ListenableFuture<SegmentChangeRequestsSnapshot> getRequestsSince(SegmentChangeRequestHistory.Counter counter)
public SegmentChangeRequestHistory.Counter getLastCounter()
Copyright © 2011–2018. All rights reserved.