io.druid.segment.realtime.plumber

Class CoordinatorBasedSegmentHandoffNotifier

java.lang.Object

io.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifier

All Implemented Interfaces:

SegmentHandoffNotifier, Closeable, AutoCloseable

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
void	close() Perform any final processing and clean up after ourselves.
boolean	registerSegmentHandoffCallback(SegmentDescriptor descriptor, Executor exec, Runnable handOffRunnable) register a handOffCallback to be called when segment handoff is complete.
void	start() Perform any initial setup.

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(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 #stop().

Specified by:

start in interface SegmentHandoffNotifier

close

public void close()

Description copied from interface: SegmentHandoffNotifier

Perform any final processing and clean up after ourselves.

Specified by:

close in interface SegmentHandoffNotifier

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable