public class SegmentLoadDropHandler extends Object implements DataSegmentChangeHandler
Modifier and Type | Class and Description |
---|---|
static class |
SegmentLoadDropHandler.DataSegmentChangeRequestAndStatus |
static class |
SegmentLoadDropHandler.Status |
Constructor and Description |
---|
SegmentLoadDropHandler(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
SegmentLoaderConfig config,
DataSegmentAnnouncer announcer,
DataSegmentServerAnnouncer serverAnnouncer,
SegmentManager segmentManager) |
Modifier and Type | Method and Description |
---|---|
void |
addSegment(DataSegment segment,
DataSegmentChangeCallback callback) |
Collection<DataSegment> |
getPendingDeleteSnapshot() |
boolean |
isStarted() |
com.google.common.util.concurrent.ListenableFuture<List<SegmentLoadDropHandler.DataSegmentChangeRequestAndStatus>> |
processBatch(List<DataSegmentChangeRequest> changeRequests) |
void |
removeSegment(DataSegment segment,
DataSegmentChangeCallback callback) |
void |
start() |
void |
stop() |
@Inject public SegmentLoadDropHandler(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, SegmentLoaderConfig config, DataSegmentAnnouncer announcer, DataSegmentServerAnnouncer serverAnnouncer, SegmentManager segmentManager)
public void start() throws IOException
IOException
public void stop()
public boolean isStarted()
public void addSegment(DataSegment segment, DataSegmentChangeCallback callback)
addSegment
in interface DataSegmentChangeHandler
public void removeSegment(DataSegment segment, DataSegmentChangeCallback callback)
removeSegment
in interface DataSegmentChangeHandler
public Collection<DataSegment> getPendingDeleteSnapshot()
public com.google.common.util.concurrent.ListenableFuture<List<SegmentLoadDropHandler.DataSegmentChangeRequestAndStatus>> processBatch(List<DataSegmentChangeRequest> changeRequests)
Copyright © 2011–2018. All rights reserved.