io.druid.segment.realtime.plumber

Interface SegmentHandoffNotifier

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

CoordinatorBasedSegmentHandoffNotifier

public interface SegmentHandoffNotifier
extends Closeable

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.

Method Detail

registerSegmentHandoffCallback

boolean registerSegmentHandoffCallback(SegmentDescriptor descriptor,
                                       Executor exec,
                                       Runnable handOffRunnable)

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

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

void start()

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

close

void close()

Perform any final processing and clean up after ourselves.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable