public class BatchDataSegmentAnnouncer extends Object implements DataSegmentAnnouncer
Constructor and Description |
---|
BatchDataSegmentAnnouncer(DruidServerMetadata server,
BatchDataSegmentAnnouncerConfig config,
ZkPathsConfig zkPaths,
Announcer announcer,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Modifier and Type | Method and Description |
---|---|
void |
announceSegment(DataSegment segment) |
void |
announceSegments(Iterable<DataSegment> segments) |
com.google.common.util.concurrent.ListenableFuture<SegmentChangeRequestsSnapshot> |
getSegmentChangesSince(SegmentChangeRequestHistory.Counter counter)
Returns Future that lists the segment load/drop requests since given counter.
|
void |
unannounceSegment(DataSegment segment) |
void |
unannounceSegments(Iterable<DataSegment> segments) |
@Inject public BatchDataSegmentAnnouncer(DruidServerMetadata server, BatchDataSegmentAnnouncerConfig config, ZkPathsConfig zkPaths, Announcer announcer, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)
public void announceSegment(DataSegment segment) throws IOException
announceSegment
in interface DataSegmentAnnouncer
IOException
public void unannounceSegment(DataSegment segment) throws IOException
unannounceSegment
in interface DataSegmentAnnouncer
IOException
public void announceSegments(Iterable<DataSegment> segments) throws IOException
announceSegments
in interface DataSegmentAnnouncer
IOException
public void unannounceSegments(Iterable<DataSegment> segments) throws IOException
unannounceSegments
in interface DataSegmentAnnouncer
IOException
public com.google.common.util.concurrent.ListenableFuture<SegmentChangeRequestsSnapshot> getSegmentChangesSince(SegmentChangeRequestHistory.Counter counter)
Copyright © 2011–2018. All rights reserved.