io.druid.segment.realtime.plumber

Class CoordinatorBasedSegmentHandoffNotifierFactory

java.lang.Object

io.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifierFactory

All Implemented Interfaces:

SegmentHandoffNotifierFactory

public class CoordinatorBasedSegmentHandoffNotifierFactory
extends Object
implements SegmentHandoffNotifierFactory

Constructor Summary

Constructors

Constructor and Description
CoordinatorBasedSegmentHandoffNotifierFactory(CoordinatorClient client, CoordinatorBasedSegmentHandoffNotifierConfig config)

Method Summary

Modifier and Type	Method and Description
SegmentHandoffNotifier	createSegmentHandoffNotifier(String dataSource)

Methods inherited from class java.lang.Object

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

Constructor Detail

CoordinatorBasedSegmentHandoffNotifierFactory

@Inject
public CoordinatorBasedSegmentHandoffNotifierFactory(CoordinatorClient client,
                                                             CoordinatorBasedSegmentHandoffNotifierConfig config)

Method Detail

createSegmentHandoffNotifier

public SegmentHandoffNotifier createSegmentHandoffNotifier(String dataSource)

Specified by:

createSegmentHandoffNotifier in interface SegmentHandoffNotifierFactory