Package org.apache.druid.frame.processor

Class Bouncer

java.lang.Object

org.apache.druid.frame.processor.Bouncer

public class Bouncer
extends Object

Limiter for access to some resource. Used by FrameProcessorExecutor.runAllFully(org.apache.druid.frame.processor.manager.ProcessorManager<T, ? extends R>, int, org.apache.druid.frame.processor.Bouncer, java.lang.String) to limit the number of outstanding processors.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	Bouncer.Ticket

Constructor Summary

Constructors

Constructor	Description
Bouncer(int maxCount)	Create a Bouncer that issues a limited number of tickets.
Bouncer(int maxCount, Bouncer parentBouncer)	Create a Bouncer that issues a limited number of tickets from a parent.

Method Summary

Modifier and Type	Method	Description
int	getMaxCount()
com.google.common.util.concurrent.ListenableFuture<Bouncer.Ticket>	ticket()
static Bouncer	unlimited()

Methods inherited from class java.lang.Object

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

Constructor Details

Bouncer

public Bouncer(int maxCount)

Create a Bouncer that issues a limited number of tickets.

Bouncer

public Bouncer(int maxCount,
 @Nullable
 Bouncer parentBouncer)

Create a Bouncer that issues a limited number of tickets from a parent.

Method Details

unlimited

public static Bouncer unlimited()

getMaxCount

public int getMaxCount()

ticket

public com.google.common.util.concurrent.ListenableFuture<Bouncer.Ticket> ticket()