io.druid.segment.realtime.plumber

Class MessageTimeRejectionPolicyFactory

java.lang.Object

io.druid.segment.realtime.plumber.MessageTimeRejectionPolicyFactory

All Implemented Interfaces:

RejectionPolicyFactory

public class MessageTimeRejectionPolicyFactory
extends Object
implements RejectionPolicyFactory

Constructor Summary

Constructors

Constructor and Description
MessageTimeRejectionPolicyFactory()

Method Summary

Modifier and Type	Method and Description
RejectionPolicy	create(org.joda.time.Period windowPeriod)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageTimeRejectionPolicyFactory

public MessageTimeRejectionPolicyFactory()

Method Detail

create

public RejectionPolicy create(org.joda.time.Period windowPeriod)

Specified by:

create in interface RejectionPolicyFactory