public class CoordinatorBasedSegmentHandoffNotifier extends Object implements SegmentHandoffNotifier
Constructor and Description |
---|
CoordinatorBasedSegmentHandoffNotifier(String dataSource,
CoordinatorClient coordinatorClient,
CoordinatorBasedSegmentHandoffNotifierConfig config) |
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.
|
public CoordinatorBasedSegmentHandoffNotifier(String dataSource, CoordinatorClient coordinatorClient, CoordinatorBasedSegmentHandoffNotifierConfig config)
public boolean registerSegmentHandoffCallback(io.druid.query.SegmentDescriptor descriptor, Executor exec, Runnable handOffRunnable)
SegmentHandoffNotifier
registerSegmentHandoffCallback
in interface SegmentHandoffNotifier
descriptor
- segment descriptor for the segment for which handoffCallback is requestedexec
- executor used to call the runnablehandOffRunnable
- runnable to be called when segment handoff is completepublic void start()
SegmentHandoffNotifier
SegmentHandoffNotifier.stop()
.start
in interface SegmentHandoffNotifier
public void stop()
SegmentHandoffNotifier
stop
in interface SegmentHandoffNotifier
Copyright © 2011–2016. All rights reserved.