io.druid.server.coordination

Class BatchDataSegmentAnnouncer

java.lang.Object

io.druid.server.coordination.AbstractDataSegmentAnnouncer

io.druid.server.coordination.BatchDataSegmentAnnouncer

All Implemented Interfaces:

DataSegmentAnnouncer

public class BatchDataSegmentAnnouncer
extends AbstractDataSegmentAnnouncer

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)
boolean	isAnnounced(DataSegment segment)
void	unannounceSegment(DataSegment segment)
void	unannounceSegments(Iterable<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

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

Throws:

IOException

unannounceSegment

public void unannounceSegment(DataSegment segment)
                       throws IOException

Throws:

IOException

announceSegments

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

Throws:

IOException

unannounceSegments

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

Throws:

IOException

isAnnounced

public boolean isAnnounced(DataSegment segment)

Returns:

true if the segment was already announced, otherwise false