io.druid.server.coordination

Class BatchDataSegmentAnnouncer

java.lang.Object

io.druid.server.coordination.BatchDataSegmentAnnouncer

All Implemented Interfaces:

DataSegmentAnnouncer

public class BatchDataSegmentAnnouncer
extends Object
implements DataSegmentAnnouncer

Constructor Summary

Constructors

Constructor and Description
BatchDataSegmentAnnouncer(DruidServerMetadata server, BatchDataSegmentAnnouncerConfig config, ZkPathsConfig zkPaths, Announcer announcer, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BatchDataSegmentAnnouncer

@Inject
public BatchDataSegmentAnnouncer(DruidServerMetadata server,
                                         BatchDataSegmentAnnouncerConfig config,
                                         ZkPathsConfig zkPaths,
                                         Announcer announcer,
                                         com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Detail

announceSegment

public void announceSegment(DataSegment segment)
                     throws IOException

Specified by:

announceSegment in interface DataSegmentAnnouncer

Throws:

IOException

unannounceSegment

public void unannounceSegment(DataSegment segment)
                       throws IOException

Specified by:

unannounceSegment in interface DataSegmentAnnouncer

Throws:

IOException

announceSegments

public void announceSegments(Iterable<DataSegment> segments)
                      throws IOException

Specified by:

announceSegments in interface DataSegmentAnnouncer

Throws:

IOException

unannounceSegments

public void unannounceSegments(Iterable<DataSegment> segments)
                        throws IOException

Specified by:

unannounceSegments in interface DataSegmentAnnouncer

Throws:

IOException

getSegmentChangesSince

public com.google.common.util.concurrent.ListenableFuture<SegmentChangeRequestsSnapshot> getSegmentChangesSince(SegmentChangeRequestHistory.Counter counter)

Returns Future that lists the segment load/drop requests since given counter.