io.druid.segment.realtime.appenderator

Class AppenderatorPlumberSchool

java.lang.Object

io.druid.segment.realtime.appenderator.AppenderatorPlumberSchool

All Implemented Interfaces:

PlumberSchool

public class AppenderatorPlumberSchool
extends Object
implements PlumberSchool

Constructor Summary

Constructors

Constructor and Description
AppenderatorPlumberSchool(AppenderatorFactory appenderatorFactory, DataSegmentAnnouncer segmentAnnouncer, SegmentHandoffNotifierFactory handoffNotifierFactory, SegmentPublisher segmentPublisher)

Method Summary

Modifier and Type	Method and Description
Plumber	findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics) Creates a Plumber
AppenderatorFactory	getAppenderatorFactory()

Methods inherited from class java.lang.Object

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

Constructor Detail

AppenderatorPlumberSchool

public AppenderatorPlumberSchool(AppenderatorFactory appenderatorFactory,
                                 DataSegmentAnnouncer segmentAnnouncer,
                                 SegmentHandoffNotifierFactory handoffNotifierFactory,
                                 SegmentPublisher segmentPublisher)

Method Detail

findPlumber

public Plumber findPlumber(DataSchema schema,
                           RealtimeTuningConfig config,
                           FireDepartmentMetrics metrics)

Description copied from interface: PlumberSchool

Creates a Plumber

Specified by:

findPlumber in interface PlumberSchool

Returns:

returns a plumber

getAppenderatorFactory

public AppenderatorFactory getAppenderatorFactory()