io.druid.segment.realtime.plumber

Class CoordinatorBasedSegmentHandoffNotifier

java.lang.Object

io.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifier

All Implemented Interfaces:

SegmentHandoffNotifier

public class CoordinatorBasedSegmentHandoffNotifier
extends Object
implements SegmentHandoffNotifier

Constructor Summary

Constructors

Constructor and Description
CoordinatorBasedSegmentHandoffNotifier(String dataSource, CoordinatorClient coordinatorClient, CoordinatorBasedSegmentHandoffNotifierConfig config)

Method Summary

Modifier and Type	Method and Description
boolean	registerSegmentHandoffCallback(io.druid.query.SegmentDescriptor descriptor, Executor exec, Runnable handOffRunnable) register a handOffCallback to be called when segment handoff is complete.
void	start() Perform any initial setup.
void	stop() Perform any final processing and clean up after ourselves.

Methods inherited from class java.lang.Object

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

Constructor Detail

CoordinatorBasedSegmentHandoffNotifier

public CoordinatorBasedSegmentHandoffNotifier(String dataSource,
                                              CoordinatorClient coordinatorClient,
                                              CoordinatorBasedSegmentHandoffNotifierConfig config)

Method Detail

registerSegmentHandoffCallback

public boolean registerSegmentHandoffCallback(io.druid.query.SegmentDescriptor descriptor,
                                              Executor exec,
                                              Runnable handOffRunnable)

Description copied from interface: SegmentHandoffNotifier

register a handOffCallback to be called when segment handoff is complete.

Specified by:

registerSegmentHandoffCallback in interface SegmentHandoffNotifier

Parameters:

descriptor - segment descriptor for the segment for which handoffCallback is requested

exec - executor used to call the runnable

handOffRunnable - runnable to be called when segment handoff is complete

start

public void start()

Description copied from interface: SegmentHandoffNotifier

Perform any initial setup. Should be called before using any other methods, and should be paired with a corresponding call to SegmentHandoffNotifier.stop().

Specified by:

start in interface SegmentHandoffNotifier

stop

public void stop()

Description copied from interface: SegmentHandoffNotifier

Perform any final processing and clean up after ourselves.

Specified by:

stop in interface SegmentHandoffNotifier