io.druid.server.coordination

Class SingleDataSegmentAnnouncer

java.lang.Object

io.druid.server.coordination.AbstractDataSegmentAnnouncer

io.druid.server.coordination.SingleDataSegmentAnnouncer

All Implemented Interfaces:

DataSegmentAnnouncer

public class SingleDataSegmentAnnouncer
extends AbstractDataSegmentAnnouncer

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	announceSegment(io.druid.timeline.DataSegment segment)
void	announceSegments(Iterable<io.druid.timeline.DataSegment> segments)
void	unannounceSegment(io.druid.timeline.DataSegment segment)
void	unannounceSegments(Iterable<io.druid.timeline.DataSegment> segments)

Methods inherited from class io.druid.server.coordination.AbstractDataSegmentAnnouncer

start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleDataSegmentAnnouncer

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

Method Detail

announceSegment

public void announceSegment(io.druid.timeline.DataSegment segment)
                     throws IOException

Throws:

IOException

unannounceSegment

public void unannounceSegment(io.druid.timeline.DataSegment segment)
                       throws IOException

Throws:

IOException

announceSegments

public void announceSegments(Iterable<io.druid.timeline.DataSegment> segments)
                      throws IOException

Throws:

IOException

unannounceSegments

public void unannounceSegments(Iterable<io.druid.timeline.DataSegment> segments)
                        throws IOException

Throws:

IOException